Home
last modified time | relevance | path

Searched refs:ObserverBridge (Results 1 - 4 of 4) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dobserver_bridge.cpp20 ObserverBridge::ObserverBridge(AppId appId, StoreId store, std::shared_ptr<Observer> observer, const Convertor &cvt) in ObserverBridge() function in OHOS::DistributedKv::ObserverBridge
25 ObserverBridge::~ObserverBridge() in ~ObserverBridge()
37 Status ObserverBridge::RegisterRemoteObserver(uint32_t realType) in RegisterRemoteObserver()
60 Status ObserverBridge::UnregisterRemoteObserver(uint32_t realType) in UnregisterRemoteObserver()
82 void ObserverBridge::OnChange(const DBChangedData &data) in OnChange()
92 ObserverBridge::ObserverClient::ObserverClient(std::shared_ptr<Observer> observer, const Convertor &cvt) in ObserverClient()
97 void ObserverBridge::ObserverClient::OnChange(const ChangeNotification &data) in OnChange()
103 auto inserted = ObserverBridge in OnChange()
[all...]
H A Dsingle_store_impl.cpp268 std::shared_ptr<ObserverBridge> bridge = PutIn(realType, observer); in SubscribeKvStore()
314 std::shared_ptr<ObserverBridge> bridge = TakeOut(realType, observer); in UnSubscribeKvStore()
802 std::function<void(ObserverBridge *)> SingleStoreImpl::BridgeReleaser() in BridgeReleaser()
804 return [this](ObserverBridge *obj) { in BridgeReleaser()
827 std::shared_ptr<ObserverBridge> SingleStoreImpl::PutIn(uint32_t &realType, std::shared_ptr<Observer> observer)
829 std::shared_ptr<ObserverBridge> bridge = nullptr;
831 [this, &realType, observer, &bridge](const auto &, std::pair<uint32_t, std::shared_ptr<ObserverBridge>> &pair) {
845 pair.second = { new ObserverBridge(appId, storeId, observer, convertor_), release };
855 std::shared_ptr<ObserverBridge> SingleStoreImpl::TakeOut(uint32_t &realType, std::shared_ptr<Observer> observer)
857 std::shared_ptr<ObserverBridge> bridg
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dobserver_bridge.h24 class ObserverBridge : public DistributedDB::KvStoreObserver { class
31 ObserverBridge(AppId appId, StoreId storeId, std::shared_ptr<Observer> observer, const Convertor &cvt);
32 ~ObserverBridge();
46 friend class ObserverBridge;
H A Dsingle_store_impl.h102 std::shared_ptr<ObserverBridge> PutIn(uint32_t &realType, std::shared_ptr<Observer> observer);
103 std::shared_ptr<ObserverBridge> TakeOut(uint32_t &realType, std::shared_ptr<Observer> observer);
128 std::function<void(ObserverBridge *)> BridgeReleaser();
160 ConcurrentMap<uintptr_t, std::pair<uint32_t, std::shared_ptr<ObserverBridge>>> observers_;

Completed in 4 milliseconds