Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h124 virtual int RemoveSubscribe(const std::string &subscribeId) in RemoveSubscribe() function
129 virtual int RemoveSubscribe(const std::vector<std::string> &subscribeIds) in RemoveSubscribe() function
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.h126 int RemoveSubscribe(const std::string &subscribeId) override;
128 int RemoveSubscribe(const std::vector<std::string> &subscribeIds) override;
H A Dvirtual_single_ver_sync_db_Interface.cpp520 int VirtualSingleVerSyncDBInterface::RemoveSubscribe(const std::string &subscribeId) in RemoveSubscribe() function in DistributedDB::VirtualSingleVerSyncDBInterface
525 int VirtualSingleVerSyncDBInterface::RemoveSubscribe(const std::vector<std::string> &subscribeIds) in RemoveSubscribe() function in DistributedDB::VirtualSingleVerSyncDBInterface
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store.h187 int RemoveSubscribe(const std::string &subscribeId) override;
189 int RemoveSubscribe(const std::vector<std::string> &subscribeIds) override;
H A Dsqlite_single_ver_natural_store.cpp1877 int SQLiteSingleVerNaturalStore::RemoveSubscribe(const std::vector<std::string> &subscribeIds) in RemoveSubscribe() function in DistributedDB::SQLiteSingleVerNaturalStore
1909 int SQLiteSingleVerNaturalStore::RemoveSubscribe(const std::string &subscribeId) in RemoveSubscribe() function in DistributedDB::SQLiteSingleVerNaturalStore
1911 return RemoveSubscribe(std::vector<std::string> {subscribeId}); in RemoveSubscribe()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_subscribe_query_test.cpp628 EXPECT_EQ(store->RemoveSubscribe(SUBSCRIBE_ID), E_OK);
667 EXPECT_EQ(store->RemoveSubscribe(SUBSCRIBE_ID), E_OK);
691 EXPECT_EQ(store->RemoveSubscribe(SUBSCRIBE_ID), -E_INVALID_DB);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_engine.cpp833 static_cast<SingleVerKvDBSyncInterface *>(storage)->RemoveSubscribe(queryId); in OfflineHandleByDevice()
1234 (void)storage->RemoveSubscribe(query.GetIdentify()); in AddQuerySubscribe()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_device_identifier_test.cpp763 EXPECT_EQ(g_store->RemoveSubscribe(subs), -1);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp2071 errCode = storage_->RemoveSubscribe(packet->GetQuery().GetIdentify()); in UnsubscribeRequestRecv()
2140 storage_->RemoveSubscribe(queryId); in RemoveSubscribeIfNeed()