| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb_connection.cpp | 129 if (kvDB == nullptr) { in PragmaSyncAction()
165 if (kvDB == nullptr) { in EnableAutoSync()
195 if (kvDB == nullptr) { in GetQueuedSyncSize()
211 if (kvDB == nullptr) { in SetQueuedSyncLimit()
223 if (kvDB == nullptr) { in GetQueuedSyncLimit()
232 if (kvDB == nullptr) { in DisableManualSync()
241 if (kvDB == nullptr) { in EnableManualSync()
253 if (kvDB == nullptr) { in SetStaleDataWipePolicy()
266 if (kvDB == nullptr) { in SetRemotePushFinishedNotify()
298 if (kvDB == nullptr) { in SetSyncRetry()
[all …]
|
| H A D | kvdb_manager.cpp | 410 return kvDB; in CreateDataBase()
432 return kvDB; in CreateDataBase()
447 return kvDB; in GetDataBase()
483 return kvDB; in GetDataBase()
617 kvDB->OnClose([kvDB, this]() { in OpenNewDatabase()
627 return kvDB; in OpenNewDatabase()
730 kvDB->SetCorruptHandler([kvDB, this]() { in SaveKvDBToCache()
736 return kvDB; in SaveKvDBToCache()
762 kvDB->IncObjRef(kvDB); in FindAndGetKvDBFromCache()
771 kvDB->IncObjRef(kvDB); in FindAndGetKvDBFromCache()
[all …]
|
| H A D | sync_able_kvdb_connection.h | 31 explicit SyncAbleKvDBConnection(SyncAbleKvDB *kvDB);
|
| H A D | generic_kvdb_connection.cpp | 28 GenericKvDBConnection::GenericKvDBConnection(GenericKvDB *kvDB) in GenericKvDBConnection() argument
29 : kvDB_(kvDB), in GenericKvDBConnection()
|
| H A D | generic_kvdb_connection.h | 31 explicit GenericKvDBConnection(GenericKvDB *kvDB);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_forward_cursor.cpp | 22 SQLiteSingleVerForwardCursor::SQLiteSingleVerForwardCursor(SQLiteSingleVerNaturalStore *kvDB, const… in SQLiteSingleVerForwardCursor() argument
23 : kvDB_(kvDB), in SQLiteSingleVerForwardCursor()
31 SQLiteSingleVerForwardCursor::SQLiteSingleVerForwardCursor(SQLiteSingleVerNaturalStore *kvDB, in SQLiteSingleVerForwardCursor() argument
33 : kvDB_(kvDB), in SQLiteSingleVerForwardCursor()
|
| H A D | sqlite_single_ver_forward_cursor.h | 29 SQLiteSingleVerForwardCursor(SQLiteSingleVerNaturalStore *kvDB, const Key &keyPrefix);
30 SQLiteSingleVerForwardCursor(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj);
|
| H A D | sqlite_single_ver_result_set.h | 42 …SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const Key &keyPrefix, const Option& op…
43 …SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj, const Opt…
|
| H A D | sqlite_single_ver_result_set.cpp | 32 SQLiteSingleVerResultSet::SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const Key &ke… in SQLiteSingleVerResultSet() argument
33 …& option) : option_(option), type_(ResultSetType::KEYPREFIX), keyPrefix_(keyPrefix), kvDB_(kvDB) {} in SQLiteSingleVerResultSet()
35 SQLiteSingleVerResultSet::SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const QueryOb… in SQLiteSingleVerResultSet() argument
36 …Option& option) : option_(option), type_(ResultSetType::QUERY), queryObj_(queryObj), kvDB_(kvDB) {} in SQLiteSingleVerResultSet()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_storage_engine.cpp | 39 int MultiVerStorageEngine::InitDatabases(IKvDB *kvDB, IKvDBMultiVerDataStorage *dataStorage, in InitDatabases() argument
45 if (kvDB == nullptr || dataStorage == nullptr || in InitDatabases()
50 kvDB_ = kvDB; in InitDatabases()
|
| H A D | multi_ver_kvdata_storage.cpp | 45 IKvDB *kvDB = factory->CreateKvDb(LOCAL_KVDB_SQLITE, errCode); in OpenKvDB() local
46 if (kvDB == nullptr) { in OpenKvDB()
59 errCode = kvDB->Open(dbProperties); in OpenKvDB()
62 RefObject::KillAndDecObjRef(kvDB); in OpenKvDB()
63 kvDB = nullptr; in OpenKvDB()
69 errCode = static_cast<SQLiteLocalKvDB *>(kvDB)->SetVersion(dbProperties, version); in OpenKvDB()
72 RefObject::KillAndDecObjRef(kvDB); in OpenKvDB()
73 kvDB = nullptr; in OpenKvDB()
77 return kvDB; in OpenKvDB()
|
| H A D | multi_ver_storage_engine.h | 36 int InitDatabases(IKvDB *kvDB, IKvDBMultiVerDataStorage *dataStorage,
|
| H A D | multi_ver_natural_store_connection.h | 39 explicit MultiVerNaturalStoreConnection(MultiVerNaturalStore *kvDB);
|
| H A D | multi_ver_natural_store_connection.cpp | 30 MultiVerNaturalStoreConnection::MultiVerNaturalStoreConnection(MultiVerNaturalStore *kvDB) in MultiVerNaturalStoreConnection() argument
31 : SyncAbleKvDBConnection(kvDB), in MultiVerNaturalStoreConnection()
|
| H A D | multi_ver_storage_executor.h | 35 …MultiVerStorageExecutor(IKvDB *kvDB, IKvDBMultiVerDataStorage *dataStorage, IKvDBCommitStorage *co…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | kvdb_manager.h | 78 IKvDB *SaveKvDBToCache(IKvDB *kvDB);
84 void RemoveKvDBFromCache(const IKvDB *kvDB);
115 static int CheckSchema(const IKvDB *kvDB, const KvDBProperties &properties);
121 int CheckKvDBProperties(const IKvDB *kvDB, const KvDBProperties &properties,
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_result_set.h | 26 RdSingleVerResultSet(RdSingleVerNaturalStore *kvDB, const Key &key);
27 RdSingleVerResultSet(RdSingleVerNaturalStore *kvDB, const Key &beginKey,
|
| H A D | rd_single_ver_result_set.cpp | 24 RdSingleVerResultSet::RdSingleVerResultSet(RdSingleVerNaturalStore *kvDB, const Key &key) in RdSingleVerResultSet() argument
25 : key_(key), kvDB_(kvDB) in RdSingleVerResultSet()
30 RdSingleVerResultSet::RdSingleVerResultSet(RdSingleVerNaturalStore *kvDB, const Key &beginKey, in RdSingleVerResultSet() argument
32 : beginKey_(beginKey), endKey_(endKey), kvScanMode_(kvScanMode), kvDB_(kvDB) {} in RdSingleVerResultSet()
|
| H A D | rd_single_ver_natural_store_connection.h | 33 explicit RdSingleVerNaturalStoreConnection(RdSingleVerNaturalStore *kvDB);
|
| H A D | rd_single_ver_natural_store_connection.cpp | 33 RdSingleVerNaturalStoreConnection::RdSingleVerNaturalStoreConnection(RdSingleVerNaturalStore *kvDB) in RdSingleVerNaturalStoreConnection() argument
34 : SingleVerNaturalStoreConnection(kvDB), committedData_(nullptr), writeHandle_(nullptr) in RdSingleVerNaturalStoreConnection()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_multi_ver_sync_db_interface.cpp | 160 IKvDB *kvDB = KvDBManager::OpenDatabase(prop, errCode); in Initialize() local
165 kvStore_ = static_cast<MultiVerNaturalStore *>(kvDB); in Initialize()
166 IKvDBConnection *conn = kvDB->GetDBConnection(errCode); in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | single_ver_natural_store_connection.cpp | 23 …StoreConnection::SingleVerNaturalStoreConnection(SyncAbleKvDB *kvDB) : SyncAbleKvDBConnection(kvDB) in SingleVerNaturalStoreConnection() argument
|
| H A D | single_ver_natural_store_connection.h | 23 explicit SingleVerNaturalStoreConnection(SyncAbleKvDB *kvDB);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
| H A D | sqlite_local_kvdb_connection.h | 33 explicit SQLiteLocalKvDBConnection(SQLiteLocalKvDB *kvDB);
|
| H A D | sqlite_local_kvdb_connection.cpp | 30 SQLiteLocalKvDBConnection::SQLiteLocalKvDBConnection(SQLiteLocalKvDB *kvDB) in SQLiteLocalKvDBConnection() argument
31 : GenericKvDBConnection(kvDB), in SQLiteLocalKvDBConnection()
|