Home
last modified time | relevance | path

Searched refs:RdSingleVerStorageExecutor (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.cpp50 RdSingleVerStorageExecutor::RdSingleVerStorageExecutor(GRD_DB *db, bool isWrite) : RDStorageExecuto… in RdSingleVerStorageExecutor() function in DistributedDB::RdSingleVerStorageExecutor
55 RdSingleVerStorageExecutor::~RdSingleVerStorageExecutor() in ~RdSingleVerStorageExecutor()
371 int RdSingleVerStorageExecutor::ForceCheckPoint() const in ForceCheckPoint()
387 int RdSingleVerStorageExecutor::DelKvData(const Key &key) in DelKvData()
501 void RdSingleVerStorageExecutor::ReleaseContinueStatement() in ReleaseContinueStatement()
533 int RdSingleVerStorageExecutor::Commit() in Commit()
538 int RdSingleVerStorageExecutor::Rollback() in Rollback()
585 int RdSingleVerStorageExecutor::MigrateLocalData() in MigrateLocalData()
614 void RdSingleVerStorageExecutor::ClearMigrateData() in ClearMigrateData()
642 int RdSingleVerStorageExecutor::CheckIntegrity() const in CheckIntegrity()
[all …]
H A Drd_single_ver_storage_executor.h44 class RdSingleVerStorageExecutor : public RDStorageExecutor {
46 RdSingleVerStorageExecutor(GRD_DB *db, bool isWrite);
47 ~RdSingleVerStorageExecutor() override;
50 DISABLE_COPY_ASSIGN_MOVE(RdSingleVerStorageExecutor);
H A Drd_single_ver_natural_store_connection.h139 RdSingleVerStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
141 void ReleaseExecutor(RdSingleVerStorageExecutor *&executor) const;
173 RdSingleVerStorageExecutor *writeHandle_; // only existed while in transaction.
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()
631 void RdSingleVerNaturalStoreConnection::ReleaseExecutor(RdSingleVerStorageExecutor *&executor) const in ReleaseExecutor()
660 RdSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in StartTransactionNormally()
H A Drd_single_ver_natural_store.h83 RdSingleVerStorageExecutor *GetHandle(bool isWrite, int &errCode,
88 void ReleaseHandle(RdSingleVerStorageExecutor *&handle) const;
H A Drd_single_ver_natural_store.cpp84 void RdSingleVerNaturalStore::ReleaseHandle(RdSingleVerStorageExecutor *&handle) const in ReleaseHandle()
255 RdSingleVerStorageExecutor *handle = GetHandle(true, errCode); in Export()
373 RdSingleVerStorageExecutor *RdSingleVerNaturalStore::GetHandle(bool isWrite, int &errCode, in GetHandle()
387 return static_cast<RdSingleVerStorageExecutor *>(handle); in GetHandle()
H A Drd_single_ver_result_set.h95 RdSingleVerStorageExecutor *handle_ = nullptr;
H A Drd_single_ver_storage_engine.cpp68 handle = new (std::nothrow) RdSingleVerStorageExecutor(db, isWrite); in CreateNewExecutor()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_rd_single_ver_natural_executor_test.cpp40 RdSingleVerStorageExecutor *g_handle = nullptr;
41 RdSingleVerStorageExecutor *g_nullHandle = nullptr;
87 g_handle = static_cast<RdSingleVerStorageExecutor *>( in SetUp()
92 g_nullHandle = new (nothrow) RdSingleVerStorageExecutor(nullptr, false); in SetUp()