/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_natural_store_connection.cpp | 87 RdSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetEntriesInner() 239 RdSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in ForceCheckPoint() 296 RdSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in Get() 337 RdSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetEntriesInner() 619 RdSingleVerStorageExecutor *RdSingleVerNaturalStoreConnection::GetExecutor(bool isWrite, int &errCo… in GetExecutor() function in DistributedDB::RdSingleVerNaturalStoreConnection 660 RdSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in StartTransactionNormally()
|
H A D | rd_single_ver_natural_store_connection.h | 139 RdSingleVerStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_natural_store_connection.cpp | 114 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in Get() 176 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetEntries() 225 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetCount() 687 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in CheckIntegrity() 717 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in ForceCheckPoint() 793 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetDeviceIdentifier() 1230 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in StartTransactionInCacheMode() 1253 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in StartTransactionNormally() 1825 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetEntriesInner() 1854 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in UpdateKey() [all …]
|
H A D | sqlite_single_ver_natural_store_connection.h | 183 SQLiteSingleVerStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/src/ |
H A D | task_executor.cpp | 34 std::shared_ptr<TaskExecutor::ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor() function in OHOS::NativeRdb::TaskExecutor
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
H A D | task_executor.cpp | 35 std::shared_ptr<ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor() function in OHOS::NativeRdb::TaskExecutor
|
H A D | rdb_sql_statistic.cpp | 125 auto executor = TaskExecutor::GetInstance().GetExecutor(); in Release()
|
H A D | rdb_store_impl.cpp | 130 auto pool = TaskExecutor::GetInstance().GetExecutor(); in AfterOpen() 725 delayNotifier_->SetExecutorPool(TaskExecutor::GetInstance().GetExecutor()); in InitDelayNotifier() 2112 auto pool = TaskExecutor::GetInstance().GetExecutor(); in DoCloudSync()
|
H A D | sqlite_connection.cpp | 404 auto pool = TaskExecutor::GetInstance().GetExecutor(); in ~SqliteConnection() 1245 auto pool = TaskExecutor::GetInstance().GetExecutor(); in Backup()
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
H A D | task_executor.h | 27 std::shared_ptr<ExecutorPool> GetExecutor();
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
H A D | task_executor.h | 74 std::shared_ptr<ExecutorPool> GetExecutor();
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_relational_store_connection.h | 76 SQLiteSingleVerRelationalStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
|
H A D | sqlite_relational_store_connection.cpp | 70 SQLiteSingleVerRelationalStorageExecutor *SQLiteRelationalStoreConnection::GetExecutor(bool isWrite… in GetExecutor() function in DistributedDB::SQLiteRelationalStoreConnection 99 auto *handle = GetExecutor(true, errCode); in StartTransaction()
|