Searched refs:syncObservers_ (Results 1 – 8 of 8) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_kv_store.cpp | 84 for (auto &syncObserver : syncObservers_) { in ~JsKVStore()
87 syncObservers_.clear(); in ~JsKVStore()
560 auto it = proxy->syncObservers_.begin(); in OffSyncComplete()
561 while (it != proxy->syncObservers_.end()) { in OffSyncComplete()
564 proxy->syncObservers_.erase(it); in OffSyncComplete()
571 if (argc == 0 || proxy->syncObservers_.empty()) { in OffSyncComplete()
588 syncObservers_.push_back(callback); in RegisterSyncCallback()
599 for (auto &syncObserver : syncObservers_) { in UnRegisterSyncCallback()
602 syncObservers_.clear(); in UnRegisterSyncCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
| H A D | js_single_kv_store.cpp | 124 for (auto &syncObserver : syncObservers_) { in ~JsSingleKVStore()
127 syncObservers_.clear(); in ~JsSingleKVStore()
779 auto it = proxy->syncObservers_.begin(); in OffSyncComplete()
780 while (it != proxy->syncObservers_.end()) { in OffSyncComplete()
783 proxy->syncObservers_.erase(it); in OffSyncComplete()
790 if (argc == 0 || proxy->syncObservers_.empty()) { in OffSyncComplete()
808 syncObservers_.push_back(callback); in RegisterSyncCallback()
819 for (auto &syncObserver : syncObservers_) { in UnRegisterSyncCallback()
822 syncObservers_.clear(); in UnRegisterSyncCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/include/ |
| H A D | js_kv_store.h | 107 std::list<std::shared_ptr<SyncObserver>> syncObservers_; variable
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_service_proxy.cpp | 392 …syncObservers_.Compute(name, [this, ¶m, &status, observer](const auto &store, auto &observers)… in RegisterAutoSyncCallback()
430 …syncObservers_.ComputeIfPresent(name, [this, ¶m, &status, observer](const auto &storeName, aut… in UnregisterAutoSyncCallback()
490 syncObservers_.ComputeIfPresent(storeName, [&result](const auto &key, const auto &observers) { in OnSyncComplete()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | rdb_service_proxy.h | 128 SyncObservers syncObservers_; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/include/ |
| H A D | js_single_kv_store.h | 120 std::list<std::shared_ptr<SyncObserver>> syncObservers_; variable
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/ |
| H A D | napi_rdb_store.h | 170 std::list<std::shared_ptr<SyncObserver>> syncObservers_; variable
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_store.cpp | 104 for (const auto &obs : syncObservers_) { in ~RdbStoreProxy()
1857 …syncObservers_.begin(), syncObservers_.end(), [argv](const auto &observer) { return *observer == a… in RegisterSyncCallback()
1865 syncObservers_.push_back(std::move(observer)); in RegisterSyncCallback()
1879 for (auto it = syncObservers_.begin(); it != syncObservers_.end();) { in UnregisterSyncCallback()
1881 it = syncObservers_.erase(it); in UnregisterSyncCallback()
1892 it = syncObservers_.erase(it); in UnregisterSyncCallback()
|