| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_subscribe_query_test.cpp | 627 EXPECT_EQ(store->AddSubscribe(SUBSCRIBE_ID, queryObj, false), E_OK);
663 int errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false);
665 errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false);
690 EXPECT_EQ(store->AddSubscribe(SUBSCRIBE_ID, queryObj, false), -E_INVALID_DB);
787 int errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false);
843 int errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | isync_engine.h | 99 virtual void AddSubscribe(SyncGenericInterface *storage,
|
| H A D | sync_engine.h | 123 void AddSubscribe(SyncGenericInterface *storage,
|
| H A D | sync_engine.cpp | 1212 void SyncEngine::AddSubscribe(SyncGenericInterface *storage, in AddSubscribe() function in DistributedDB::SyncEngine
1225 int errCode = storage->AddSubscribe(query.GetIdentify(), query, true); in AddQuerySubscribe()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | sync_generic_interface.h | 119 …virtual int AddSubscribe(const std::string &subscribeId, const QueryObject &query, bool needCacheS… in AddSubscribe() function
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_single_ver_sync_db_Interface.h | 124 …int AddSubscribe(const std::string &subscribeId, const QueryObject &query, bool needCacheSubscribe…
|
| H A D | virtual_single_ver_sync_db_Interface.cpp | 514 int VirtualSingleVerSyncDBInterface::AddSubscribe(const std::string &subscribeId, const QueryObject… in AddSubscribe() function in DistributedDB::VirtualSingleVerSyncDBInterface
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_kv_syncer.cpp | 329 engine->AddSubscribe(storage, subscribeQuery); in TriggerAddSubscribeAsync()
|
| H A D | single_ver_data_sync.cpp | 2025 …errCode = storage_->AddSubscribe(packet->GetQuery().GetIdentify(), packet->GetQuery(), packet->IsA… in SubscribeRequestRecv()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store.h | 185 …int AddSubscribe(const std::string &subscribeId, const QueryObject &query, bool needCacheSubscribe…
|
| H A D | sqlite_single_ver_natural_store_extend.cpp | 390 int SQLiteSingleVerNaturalStore::AddSubscribe(const std::string &subscribeId, const QueryObject &qu… in AddSubscribe() function in DistributedDB::SQLiteSingleVerNaturalStore
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_device_identifier_test.cpp | 755 EXPECT_EQ(g_store->AddSubscribe(sub, queryObj, true), E_OK);
|