addDatabase(std::string dbName, DatabaseID dbId) | pdb::PangeaStorageServer | |
addDatabase(std::string dbName) | pdb::PangeaStorageServer | |
addDatabaseByPartitionedFiles(string dbName, DatabaseID dbId, boost::filesystem::path dbMetaPath) | pdb::PangeaStorageServer | protected |
addDatabaseBySequenceFiles(string dbName, DatabaseID dbId, boost::filesystem::path dbPath) | pdb::PangeaStorageServer | protected |
addSet(std::string dbName, std::string typeName, std::string setName, SetID setId, size_t pageSize=DEFAULT_PAGE_SIZE) | pdb::PangeaStorageServer | |
addSet(std::string dbName, std::string typeName, std::string setName, size_t pageSize=DEFAULT_PAGE_SIZE) | pdb::PangeaStorageServer | |
addSet(std::string dbName, std::string setName, size_t pageSize=DEFAULT_PAGE_SIZE) | pdb::PangeaStorageServer | |
addTempSet(std::string setName, SetID &setId, size_t pageSize=DEFAULT_PAGE_SIZE) | pdb::PangeaStorageServer | |
addType(std::string typeName, UserTypeID typeId) | pdb::PangeaStorageServer | |
allRecords | pdb::PangeaStorageServer | private |
bufferRecord(pair< std::string, std::string > databaseAndSet, Record< Vector< Handle< Object >>> *addMe) | pdb::PangeaStorageServer | |
cache | pdb::PangeaStorageServer | private |
cleanup(bool flushOrNot=true) | pdb::PangeaStorageServer | |
pdb::ServerFunctionality::cleanup() | pdb::ServerFunctionality | inlinevirtual |
clearDB(DatabaseID dbId, string dbName) | pdb::PangeaStorageServer | protected |
conf | pdb::PangeaStorageServer | private |
counterMutex | pdb::PangeaStorageServer | private |
createRootDirs() | pdb::PangeaStorageServer | protected |
createTempDirs() | pdb::PangeaStorageServer | protected |
databaseLock | pdb::PangeaStorageServer | private |
databaseSeqId | pdb::PangeaStorageServer | private |
dataRootPaths | pdb::PangeaStorageServer | private |
dataTempPaths | pdb::PangeaStorageServer | private |
dbs | pdb::PangeaStorageServer | private |
encodeDBPath(string rootPath, DatabaseID dbId, string dbName) | pdb::PangeaStorageServer | protected |
exportToFile(std::string dbName, std::string setName, std::string path, std::string format, std::string &errMsg) | pdb::PangeaStorageServer | |
exportToHDFSFile(std::string dbName, std::string setName, std::string hdfsNameNodeIp, int hdfsNameNodePort, std::string path, std::string format, std::string &errMsg) | pdb::PangeaStorageServer | |
flushBuffer | pdb::PangeaStorageServer | private |
flushers | pdb::PangeaStorageServer | private |
getCache() | pdb::PangeaStorageServer | |
getConf() | pdb::PangeaStorageServer | |
getDatabase(DatabaseID dbId) | pdb::PangeaStorageServer | |
getFlushBuffer() | pdb::PangeaStorageServer | |
getFunctionality() | pdb::ServerFunctionality | inline |
getLogger() | pdb::PangeaStorageServer | |
getNewPage(pair< std::string, std::string > databaseAndSet) | pdb::PangeaStorageServer | |
getNodeId() | pdb::PangeaStorageServer | |
getPathToBackEndServer() | pdb::PangeaStorageServer | |
getServerName() | pdb::PangeaStorageServer | |
getSet(std::pair< std::string, std::string > databaseAndSet) | pdb::PangeaStorageServer | |
getSet(DatabaseID dbId, UserTypeID typeId, SetID setId) | pdb::PangeaStorageServer | |
getSharedMem() | pdb::PangeaStorageServer | |
getTempSet(SetID setId) | pdb::PangeaStorageServer | |
getWorker() | pdb::PangeaStorageServer | |
initializeFromRootDirs(string metaRootPath, vector< string > dataRootPath) | pdb::PangeaStorageServer | protected |
isStandalone() | pdb::PangeaStorageServer | |
logger | pdb::PangeaStorageServer | private |
metaRootPath | pdb::PangeaStorageServer | private |
metaTempPath | pdb::PangeaStorageServer | private |
name2id | pdb::PangeaStorageServer | private |
name2tempSetId | pdb::PangeaStorageServer | private |
names2ids | pdb::PangeaStorageServer | private |
nodeId | pdb::PangeaStorageServer | private |
numWaitingBufferDataRequests | pdb::PangeaStorageServer | private |
PangeaStorageServer(SharedMemPtr shm, PDBWorkerQueuePtr workers, PDBLoggerPtr logger, ConfigurationPtr conf, bool standalone=true) | pdb::PangeaStorageServer | |
pathToBackEndServer | pdb::PangeaStorageServer | private |
recordServer(PDBServer &recordMe) | pdb::ServerFunctionality | inline |
registerHandlers(PDBServer &forMe) override | pdb::PangeaStorageServer | virtual |
removeDatabase(std::string dbName) | pdb::PangeaStorageServer | |
removeSet(std::string dbName, std::string typeName, std::string setName) | pdb::PangeaStorageServer | |
removeSet(std::string dbName, std::string setName) | pdb::PangeaStorageServer | |
removeTempSet(SetID setId) | pdb::PangeaStorageServer | |
removeType(std::string typeName) | pdb::PangeaStorageServer | |
removeTypeFromDatabase(std::string dbName, std::string typeName) | pdb::PangeaStorageServer | |
serverName | pdb::PangeaStorageServer | private |
shm | pdb::PangeaStorageServer | private |
sizes | pdb::PangeaStorageServer | private |
standalone | pdb::PangeaStorageServer | private |
startFlushConsumerThreads() | pdb::PangeaStorageServer | |
stopFlushConsumerThreads() | pdb::PangeaStorageServer | |
tempsetLock | pdb::PangeaStorageServer | private |
tempSets | pdb::PangeaStorageServer | private |
tempsetSeqId | pdb::PangeaStorageServer | private |
totalObjects | pdb::PangeaStorageServer | private |
typeLock | pdb::PangeaStorageServer | private |
typename2id | pdb::PangeaStorageServer | private |
usersetLock | pdb::PangeaStorageServer | private |
userSets | pdb::PangeaStorageServer | private |
usersetSeqIds | pdb::PangeaStorageServer | private |
workers | pdb::PangeaStorageServer | private |
workingMutex | pdb::PangeaStorageServer | private |
writeBackRecords(pair< std::string, std::string > databaseAndSet, bool flushOrNot=true, bool directPutOrNot=false) | pdb::PangeaStorageServer | |
~PangeaStorageServer() | pdb::PangeaStorageServer | |