Searched refs:StorageEngine (Results 1 – 10 of 10) sorted by relevance
25 const int StorageEngine::MAX_WAIT_TIME = 30;26 const int StorageEngine::MAX_WRITE_SIZE = 1;27 const int StorageEngine::MAX_READ_SIZE = 16;29 StorageEngine::StorageEngine() in StorageEngine() function in DistributedDB::StorageEngine42 StorageEngine::~StorageEngine() in ~StorageEngine()47 void StorageEngine::CloseAllExecutor() in CloseAllExecutor()101 int StorageEngine::Init() in Init()127 int StorageEngine::ReInit() in ReInit()291 void StorageEngine::Release() in Release()380 int StorageEngine::ExecuteMigrate() in ExecuteMigrate()[all …]
57 StorageEngine *StorageEngineManager::GetStorageEngine(const KvDBProperties &property, int &errCode) in GetStorageEngine()85 int StorageEngineManager::ReleaseStorageEngine(StorageEngine *storageEngine) in ReleaseStorageEngine()125 int StorageEngineManager::ExecuteMigration(StorageEngine *storageEngine) in ExecuteMigration()191 StorageEngine *storageEngine = nullptr; in LockStatusNotifier()199 StorageEngine *CreateSingleVerStorageEngine(int databaseType) in CreateSingleVerStorageEngine()209 StorageEngine *StorageEngineManager::CreateStorageEngine(const KvDBProperties &property, int &errCo… in CreateStorageEngine()228 StorageEngine *StorageEngineManager::FindStorageEngine(const std::string &identifier) in FindStorageEngine()249 storageEngines_.insert(std::pair<std::string, StorageEngine *>(identifier, storageEngine)); in InsertStorageEngine()260 StorageEngine *storageEngine = nullptr; in ReleaseResources()277 int StorageEngineManager::ReleaseEngine(StorageEngine *releaseEngine) in ReleaseEngine()[all …]
38 class StorageEngine : public RefObject {40 StorageEngine();41 ~StorageEngine() override;44 DISABLE_COPY_ASSIGN_MOVE(StorageEngine);
30 static StorageEngine *GetStorageEngine(const KvDBProperties &property, int &errCode);32 static int ReleaseStorageEngine(StorageEngine *storageEngine);36 static int ExecuteMigration(StorageEngine *storageEngine);51 StorageEngine *CreateStorageEngine(const KvDBProperties &property, int &errCode);53 StorageEngine *FindStorageEngine(const std::string &identifier);55 void InsertStorageEngine(const std::string &identifier, StorageEngine *&storageEngine);61 int ReleaseEngine(StorageEngine *releaseEngine);72 std::map<std::string, StorageEngine *> storageEngines_;
28 class MultiVerStorageEngine : public StorageEngine {
42 if (StorageEngine::CheckEngineAttr(poolSize)) { in InitDatabases()
26 class SQLiteStorageEngine : public StorageEngine {
35 if (StorageEngine::CheckEngineAttr(poolSize)) { in InitSQLiteStorageEngine()
29 class RdSingleVerStorageEngine : public StorageEngine {
86 if (StorageEngine::CheckEngineAttr(poolSize)) { in InitRdStorageEngine()