| /foundation/distributeddatamgr/preferences/frameworks/js/napi/common/src/ |
| H A D | js_observer.cpp | 19 JSObserver::JSObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback, bool sendable) in JSObserver() argument
20 : uvQueue_(uvQueue), sendabel_(sendable) in JSObserver()
22 napi_create_reference(uvQueue->GetEnv(), callback, 1, &callback_); in JSObserver()
39 auto uvQueue = uvQueue_.lock(); in ClearCallback() local
40 if (uvQueue != nullptr) { in ClearCallback()
41 napi_delete_reference(uvQueue->GetEnv(), callback_); in ClearCallback()
49 auto uvQueue = uvQueue_.lock(); in GetEnv() local
50 if (uvQueue != nullptr) { in GetEnv()
51 return uvQueue->GetEnv(); in GetEnv()
62 auto uvQueue in AsyncCall() local
[all...] |
| H A D | napi_preferences_observer.cpp | 24 JSPreferencesObserver::JSPreferencesObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback, bool sendabel) in JSPreferencesObserver() argument
25 : JSObserver(uvQueue, callback, sendabel) in JSPreferencesObserver()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_store_observer.cpp | 28 NapiRdbStoreObserver::NapiRdbStoreObserver(napi_value callback, std::shared_ptr<UvQueue> uvQueue, int32_t mode) in NapiRdbStoreObserver() argument
29 : mode_(mode), uvQueue_(uvQueue) in NapiRdbStoreObserver()
41 auto uvQueue = uvQueue_; in OnChange() local
42 if (uvQueue == nullptr) { in OnChange()
45 uvQueue->AsyncCall({ [observer = shared_from_this()](napi_env env) -> napi_value { in OnChange()
70 auto uvQueue = uvQueue_; in OnChange() local
71 if (uvQueue == nullptr) { in OnChange()
75 uvQueue->AsyncCall({ [observer = shared_from_this()](napi_env env) -> napi_value { in OnChange()
91 auto uvQueue = uvQueue_; in OnChange() local
92 if (uvQueue in OnChange()
[all...] |
| H A D | napi_rdb_store.cpp | 1604 auto uvQueue = std::make_shared<UvQueue>(env); in OnRemote() local
1605 auto observer = std::make_shared<NapiRdbStoreObserver>(argv[1], uvQueue, mode); in OnRemote()
1630 auto uvQueue = std::make_shared<UvQueue>(env); in RegisteredObserver() local
1631 auto localObserver = std::make_shared<NapiRdbStoreObserver>(callback, uvQueue); in RegisteredObserver()
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/include/ |
| H A D | js_kv_store.h | 44 void SetUvQueue(std::shared_ptr<UvQueue> uvQueue);
67 DataObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback, bool schema) in DataObserver() argument
68 : JSObserver(uvQueue, callback), isSchema_(schema){}; in DataObserver()
78 SyncObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback) : JSObserver(uvQueue, callback) {}; in SyncObserver() argument
|
| H A D | js_kv_manager.h | 52 DeathRecipient(std::shared_ptr<UvQueue> uvQueue, napi_value callback) : JSObserver(uvQueue, callback) {}; in DeathRecipient() argument
|
| H A D | js_observer.h | 23 JSObserver(std::shared_ptr <UvQueue> uvQueue, napi_value callback);
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_observer.cpp | 29 JSObserver::JSObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback) in JSObserver() argument
30 : uvQueue_(uvQueue) in JSObserver()
|
| H A D | js_kv_store.cpp | 631 void JsKVStore::SetUvQueue(std::shared_ptr<UvQueue> uvQueue) in SetUvQueue() argument
633 uvQueue_ = uvQueue; in SetUvQueue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
| H A D | js_observer.cpp | 29 JSObserver::JSObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback) in JSObserver() argument
30 : uvQueue_(uvQueue) in JSObserver()
|
| H A D | js_single_kv_store.cpp | 86 void JsSingleKVStore::SetUvQueue(std::shared_ptr<UvQueue> uvQueue) in SetUvQueue() argument
88 uvQueue_ = uvQueue; in SetUvQueue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/include/ |
| H A D | js_single_kv_store.h | 45 void SetUvQueue(std::shared_ptr<UvQueue> uvQueue);
79 DataObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback, bool schema) in DataObserver() argument
80 : JSObserver(uvQueue, callback), isSchema_(schema){}; in DataObserver()
90 SyncObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback) : JSObserver(uvQueue, callback) {}; in SyncObserver() argument
|
| H A D | js_kv_manager.h | 53 DeathRecipient(std::shared_ptr<UvQueue> uvQueue, napi_value callback) : JSObserver(uvQueue, callback) {}; in DeathRecipient() argument
|
| H A D | js_observer.h | 23 JSObserver(std::shared_ptr <UvQueue> uvQueue, napi_value callback);
|
| /foundation/distributeddatamgr/preferences/frameworks/js/napi/common/include/ |
| H A D | napi_preferences_observer.h | 29 JSPreferencesObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback, bool sendable = false);
|
| H A D | js_observer.h | 25 JSObserver(std::shared_ptr<UvQueue> uvQueue, napi_value callback, bool sendable);
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/ |
| H A D | napi_rdb_store_observer.h | 37 explicit NapiRdbStoreObserver(napi_value callback, std::shared_ptr<UvQueue> uvQueue,
|
| H A D | napi_rdb_store.h | 116 SyncObserver(napi_env env, napi_value callback, std::shared_ptr<AppDataMgrJsKit::UvQueue> uvQueue);
131 NapiStatisticsObserver(napi_env env, napi_value callback, std::shared_ptr<AppDataMgrJsKit::UvQueue> uvQueue);
|