| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_engine.h | 53 void Recycle(StorageExecutor *&handle, bool isExternal = false);
100 virtual int CreateNewExecutor(bool isWrite, StorageExecutor *&handle) = 0;
133 StorageExecutor *FetchStorageExecutor(bool isWrite, std::list<StorageExecutor *> &idleList,
155 std::list<StorageExecutor *> writeUsingList_;
156 std::list<StorageExecutor *> writeIdleList_;
157 std::list<StorageExecutor *> readUsingList_;
158 std::list<StorageExecutor *> readIdleList_;
159 std::list<StorageExecutor *> externalWriteUsingList_;
160 std::list<StorageExecutor *> externalWriteIdleList_;
161 std::list<StorageExecutor *> externalReadUsingList_;
[all …]
|
| H A D | storage_executor.cpp | 21 StorageExecutor::StorageExecutor(bool writable) in StorageExecutor() function in DistributedDB::StorageExecutor
26 StorageExecutor::~StorageExecutor() in ~StorageExecutor()
29 bool StorageExecutor::GetWritable() const in GetWritable()
34 bool StorageExecutor::GetCorruptedStatus() const in GetCorruptedStatus()
39 void StorageExecutor::SetCorruptedStatus() const in SetCorruptedStatus()
44 int StorageExecutor::CheckCorruptedStatus(int errCode) const in CheckCorruptedStatus()
|
| H A D | storage_engine.cpp | 67 StorageExecutor *handle = nullptr; in InitReadWriteExecutors()
207 …std::list<StorageExecutor *> &readUsingList = isExternal ? externalReadUsingList_ : readUsingList_; in FindReadExecutor()
208 … std::list<StorageExecutor *> &readIdleList = isExternal ? externalReadIdleList_ : readIdleList_; in FindReadExecutor()
238 void StorageEngine::Recycle(StorageExecutor *&handle, bool isExternal) in Recycle()
247 … std::list<StorageExecutor *> &readIdleList = isExternal ? externalReadIdleList_ : readIdleList_; in Recycle()
407 void StorageEngine::AddStorageExecutor(StorageExecutor *handle, bool isExternal) in AddStorageExecutor()
414 … std::list<StorageExecutor *> &readIdleList = isExternal ? externalReadIdleList_ : readIdleList_; in AddStorageExecutor()
422 void ClearHandleList(std::list<StorageExecutor *> &handleList) in ClearHandleList()
448 StorageExecutor *StorageEngine::FetchStorageExecutor(bool isWrite, std::list<StorageExecutor *> &id… in FetchStorageExecutor()
449 std::list<StorageExecutor *> &usingList, int &errCode, bool isExternal) in FetchStorageExecutor()
[all …]
|
| H A D | storage_executor.h | 103 class StorageExecutor {
105 explicit StorageExecutor(bool writable);
106 virtual ~StorageExecutor();
109 DISABLE_COPY_ASSIGN_MOVE(StorageExecutor);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_natural_store_snapshot.h | 26 explicit MultiVerNaturalStoreSnapshot(StorageExecutor *handle);
40 StorageExecutor *databaseHandle_;
|
| H A D | multi_ver_storage_engine.h | 40 int CreateNewExecutor(bool isWrite, StorageExecutor *&handle) override;
|
| H A D | multi_ver_natural_store_snapshot.cpp | 25 MultiVerNaturalStoreSnapshot::MultiVerNaturalStoreSnapshot(StorageExecutor *handle) in MultiVerNaturalStoreSnapshot()
|
| H A D | multi_ver_storage_engine.cpp | 57 int MultiVerStorageEngine::CreateNewExecutor(bool isWrite, StorageExecutor *&handle) in CreateNewExecutor()
|
| H A D | multi_ver_storage_executor.h | 33 class MultiVerStorageExecutor : public StorageExecutor {
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_storage_engine.h | 45 …virtual StorageExecutor *NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite, bool isMemDb) =…
47 int CreateNewExecutor(bool isWrite, StorageExecutor *&handle) override;
|
| H A D | sqlite_storage_engine.cpp | 54 StorageExecutor *SQLiteStorageEngine::NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite, boo… in NewSQLiteStorageExecutor()
72 int SQLiteStorageEngine::CreateNewExecutor(bool isWrite, StorageExecutor *&handle) in CreateNewExecutor()
|
| H A D | sqlite_single_ver_storage_engine.h | 66 …virtual StorageExecutor *NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite, bool isMemDb) o…
70 int CreateNewExecutor(bool isWrite, StorageExecutor *&handle) override;
|
| H A D | sqlite_local_storage_engine.cpp | 26 StorageExecutor *SQLiteLocalStorageEngine::NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite… in NewSQLiteStorageExecutor()
|
| H A D | sqlite_local_storage_engine.h | 32 … StorageExecutor *NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite, bool isMemDb) override;
|
| H A D | sqlite_storage_executor.h | 24 class SQLiteStorageExecutor : public StorageExecutor {
|
| H A D | sqlite_storage_executor.cpp | 24 : StorageExecutor(writable), in SQLiteStorageExecutor()
|
| H A D | sqlite_single_ver_storage_engine.cpp | 357 StorageExecutor *databaseHandle = handle; in ReleaseExecutor()
552 StorageExecutor *SQLiteSingleVerStorageEngine::NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isW… in NewSQLiteStorageExecutor()
824 int SQLiteSingleVerStorageEngine::CreateNewExecutor(bool isWrite, StorageExecutor *&handle) in CreateNewExecutor()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_relational_storage_engine.h | 64 … StorageExecutor *NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite, bool isMemDb) override;
66 int CreateNewExecutor(bool isWrite, StorageExecutor *&handle) override;
|
| H A D | sqlite_single_relational_storage_engine.cpp | 34 StorageExecutor *SQLiteSingleRelationalStorageEngine::NewSQLiteStorageExecutor(sqlite3 *dbHandle, b… in NewSQLiteStorageExecutor()
93 int SQLiteSingleRelationalStorageEngine::CreateNewExecutor(bool isWrite, StorageExecutor *&handle) in CreateNewExecutor()
131 StorageExecutor *databaseHandle = handle; in ReleaseExecutor()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_storage_engine.h | 38 int CreateNewExecutor(bool isWrite, StorageExecutor *&handle) override;
|
| H A D | rd_single_ver_storage_engine.cpp | 40 int RdSingleVerStorageEngine::CreateNewExecutor(bool isWrite, StorageExecutor *&handle) in CreateNewExecutor()
|
| H A D | rd_single_ver_storage_executor.h | 28 class RDStorageExecutor : public StorageExecutor {
|
| H A D | rd_single_ver_natural_store.cpp | 90 StorageExecutor *databaseHandle = handle; in ReleaseHandle()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 135 void SetReusedHandle(StorageExecutor *handle);
307 StorageExecutor *reusedHandle_;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
| H A D | sqlite_local_kvdb.cpp | 252 StorageExecutor *databaseHandle = handle; in ReleaseHandle()
|