| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/relational/ |
| H A D | relational_store_client.h | 40 DB_API DistributedDB::DBStatus RegisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserver> &storeObserver);
43 const std::shared_ptr<StoreObserver> &storeObserver);
|
| /foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
| H A D | relational_store_client.h | 40 const std::shared_ptr<DistributedDB::StoreObserver> &storeObserver);
43 const std::shared_ptr<DistributedDB::StoreObserver> &storeObserver);
|
| H A D | mock.cpp | 75 const std::shared_ptr<StoreObserver> &storeObserver) in RegisterStoreObserver()
81 const std::shared_ptr<StoreObserver> &storeObserver) in UnregisterStoreObserver()
74 RegisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserver> &storeObserver) RegisterStoreObserver() argument
80 UnregisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserver> &storeObserver) UnregisterStoreObserver() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/ |
| H A D | auto_launch_export.h | 42 StoreObserver *storeObserver = nullptr; member
|
| /foundation/distributeddatamgr/relational_store/test/js/rdb/unittest/src/ |
| H A D | RdbStoreDistributedJsunit.test.js | 23 function storeObserver(devices) { function
321 rdbStore.on("dataChange", dataRdb.SubscribeType.SUBSCRIBE_TYPE_REMOTE, storeObserver);
338 rdbStore.off("dataChange", dataRdb.SubscribeType.SUBSCRIBE_TYPE_REMOTE, storeObserver);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_sqlite_ext.cpp | 929 for (const auto &storeObserver : storeObservers) { in TriggerObserver()
933 storeObserver->OnChange(std::move(storeChangedData)); in TriggerObserver()
941 std::vector<std::shared_ptr<StoreObserver>> storeObserver; in StoreObserverCallback() local
946 std::copy(it->second.begin(), it->second.end(), std::back_inserter(storeObserver)); in StoreObserverCallback()
951 TriggerObserver(storeObserver, hashFileName); in StoreObserverCallback()
1634 DB_API DistributedDB::DBStatus RegisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserver> &storeObserver) in RegisterStoreObserver() argument
1636 if (storeObserver == nullptr) { in RegisterStoreObserver()
1661 if (std::find(g_storeObserverMap[hashFileName].begin(), g_storeObserverMap[hashFileName].end(), storeObserver) != in RegisterStoreObserver()
1666 g_storeObserverMap[hashFileName].push_back(storeObserver); in RegisterStoreObserver()
1670 DB_API DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserver> &storeObserver) in UnregisterStoreObserver() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/kvdelegatemanager_fuzzer/ |
| H A D | kvdelegatemanager_fuzzer.cpp | 58 option.storeObserver = nullptr; in GetRandomAutoLaunchOption()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | auto_launch.cpp | 780 autoLaunchItem.storeObserver = param.option.storeObserver; in AutoLaunchExt()
1287 if (autoLaunchItem.storeObserver == nullptr) { in RegisterRelationalObserver()
1291 (void)conn->RegisterObserverAction(autoLaunchItem.storeObserver, [this, autoLaunchItem, identifier]( in RegisterRelationalObserver()
1293 if (isChangedData && autoLaunchItem.storeObserver) { in RegisterRelationalObserver()
1295 autoLaunchItem.storeObserver->OnChange( in RegisterRelationalObserver()
1463 if (autoLaunchItem.storeObserver) { in AutoLaunchOnChange()
1465 autoLaunchItem.storeObserver->OnChange(data); in AutoLaunchOnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/ |
| H A D | storage_fuzzer.cpp | 327 auto storeObserver = std::make_shared<ClientStoreObserver>(); in StoreObserverFuzz() local
328 RegisterStoreObserver(db, storeObserver); in StoreObserverFuzz()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | auto_launch.h | 63 StoreObserver *storeObserver = nullptr; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_ext_test.cpp | 1561 auto storeObserver = std::make_shared<MockStoreObserver>(); in HWTEST_F() local
1562 EXPECT_EQ(RegisterStoreObserver(db, storeObserver), OK); in HWTEST_F()
1608 auto storeObserver = std::make_shared<MockStoreObserver>(); in HWTEST_F() local
1609 EXPECT_EQ(RegisterStoreObserver(db, storeObserver), OK); in HWTEST_F()
1719 auto storeObserver = std::make_shared<MockStoreObserver>(); in HWTEST_F() local
1720 EXPECT_EQ(RegisterStoreObserver(db, storeObserver), OK); in HWTEST_F()
1721 EXPECT_EQ(RegisterStoreObserver(db, storeObserver), INVALID_ARGS); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 1639 param.option.storeObserver = observer; in HWTEST_F()
1870 param.option.storeObserver = observer; in HWTEST_F()
1999 param.option.storeObserver = autoObserver; in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_impl.cpp | 173 param.option.storeObserver = nullptr; in ResolveAutoLaunch()
|