Home
last modified time | relevance | path

Searched refs:GetExecutor (Results 1 – 13 of 13) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_natural_store_connection.cpp87 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 Drd_single_ver_natural_store_connection.h139 RdSingleVerStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store_connection.cpp114 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 Dsqlite_single_ver_natural_store_connection.h183 SQLiteSingleVerStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/src/
H A Dtask_executor.cpp34 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 Dtask_executor.cpp35 std::shared_ptr<ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor() function in OHOS::NativeRdb::TaskExecutor
H A Drdb_sql_statistic.cpp125 auto executor = TaskExecutor::GetInstance().GetExecutor(); in Release()
H A Drdb_store_impl.cpp130 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 Dsqlite_connection.cpp404 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 Dtask_executor.h27 std::shared_ptr<ExecutorPool> GetExecutor();
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A Dtask_executor.h74 std::shared_ptr<ExecutorPool> GetExecutor();
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store_connection.h76 SQLiteSingleVerRelationalStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
H A Dsqlite_relational_store_connection.cpp70 SQLiteSingleVerRelationalStorageExecutor *SQLiteRelationalStoreConnection::GetExecutor(bool isWrite… in GetExecutor() function in DistributedDB::SQLiteRelationalStoreConnection
99 auto *handle = GetExecutor(true, errCode); in StartTransaction()