A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
DistributedStorageManagerClientTemplate.cc
Go to the documentation of this file.
1 /*****************************************************************************
2  * *
3  * Copyright 2018 Rice University *
4  * *
5  * Licensed under the Apache License, Version 2.0 (the "License"); *
6  * you may not use this file except in compliance with the License. *
7  * You may obtain a copy of the License at *
8  * *
9  * http://www.apache.org/licenses/LICENSE-2.0 *
10  * *
11  * Unless required by applicable law or agreed to in writing, software *
12  * distributed under the License is distributed on an "AS IS" BASIS, *
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
14  * See the License for the specific language governing permissions and *
15  * limitations under the License. *
16  * *
17  *****************************************************************************/
18 
19 #ifndef DISTRIBUTED_STORAGE_MANAGER_CLIENT_TEMPLATE_CC
20 #define DISTRIBUTED_STORAGE_MANAGER_CLIENT_TEMPLATE_CC
21 
22 #include "PDBDebug.h"
24 #include "StorageAddSet.h"
25 #include "SimpleRequest.h"
27 #include "SimpleRequestResult.h"
28 #include "DataTypes.h"
29 #include <cstddef>
30 #include <fcntl.h>
31 #include <fstream>
32 #include <iostream>
33 
34 namespace pdb {
35 
36 
37  template <class DataType>
38  bool DistributedStorageManagerClient::createSet(const std::string& databaseName,
39  const std::string& setName,
40  std::string& errMsg,
41  size_t pageSize) {
42  std::string typeName = getTypeName<DataType>();
43  int16_t typeId = getTypeID<DataType>();
44  PDB_COUT << "typeName for set to create =" << typeName << ", typeId=" << typeId << std::endl;
45  return simpleRequest<DistributedStorageAddSet, SimpleRequestResult, bool>(
46  logger,
47  port,
48  address,
49  false,
50  1024,
51  generateResponseHandler("Could not add set to distributed storage manager:", errMsg),
52  databaseName,
53  setName,
54  typeName,
55  pageSize);
56  }
57 
58 }
59 #endif
std::function< bool(Handle< SimpleRequestResult >)> generateResponseHandler(std::string description, std::string &errMsg)
bool createSet(const std::string &databaseName, const std::string &setName, const std::string &typeName, std::string &errMsg, size_t pageSize=DEFAULT_PAGE_SIZE)
#define PDB_COUT
Definition: PDBDebug.h:31