Home
last modified time | relevance | path

Searched refs:uvQueue_ (Results 1 – 25 of 26) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/
H A Dnapi_rdb_store_observer.cpp29 : mode_(mode), uvQueue_(uvQueue) in NapiRdbStoreObserver()
31 napi_create_reference(uvQueue_->GetEnv(), callback, 1, &callback_); in NapiRdbStoreObserver()
41 auto uvQueue = uvQueue_; in OnChange()
70 auto uvQueue = uvQueue_; in OnChange()
91 auto uvQueue = uvQueue_; in OnChange()
119 napi_status status = napi_get_reference_value(uvQueue_->GetEnv(), callback_, &callback); in operator ==()
125 status = napi_strict_equals(uvQueue_->GetEnv(), value, callback, &isEquals); in operator ==()
137 napi_delete_reference(uvQueue_->GetEnv(), callback_); in Clear()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Djs_observer.cpp25 napi_delete_reference(uvQueue_->GetEnv(), callback_); in Clear()
30 : uvQueue_(uvQueue) in JSObserver()
32 napi_create_reference(uvQueue_->GetEnv(), callback, 1, &callback_); in JSObserver()
50 uvQueue_->AsyncCall([observer = shared_from_this()](napi_env env) -> napi_value { in AsyncCall()
H A Djs_kv_manager.cpp34 : bundleName_(bundleName), uvQueue_(std::make_shared<UvQueue>(env)), in JsKVManager()
151 ctxt->kvStore->SetUvQueue(kvm->uvQueue_); in GetKVStore()
305 auto deathRecipient = std::make_shared<DeathRecipient>(proxy->uvQueue_, argv[1]); in On()
H A Djs_kv_store.cpp471 …proxy->Subscribe(type, std::make_shared<DataObserver>(proxy->uvQueue_, argv[1], proxy->IsSchemaSto… in OnDataChange()
539 …ctxt->status = proxy->RegisterSyncCallback(std::make_shared<SyncObserver>(proxy->uvQueue_, argv[0]… in OnSyncComplete()
633 uvQueue_ = uvQueue; in SetUvQueue()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/
H A Djs_observer.cpp25 napi_delete_reference(uvQueue_->GetEnv(), callback_); in Clear()
30 : uvQueue_(uvQueue) in JSObserver()
32 napi_create_reference(uvQueue_->GetEnv(), callback, 1, &callback_); in JSObserver()
50 uvQueue_->AsyncCall([observer = shared_from_this()](napi_env env) -> napi_value { in AsyncCall()
H A Djs_kv_manager.cpp35 : bundleName_(bundleName), uvQueue_(std::make_shared<UvQueue>(env)), in JsKVManager()
160 ctxt->kvStore->SetUvQueue(kvm->uvQueue_); in GetKVStore()
325 auto deathRecipient = std::make_shared<DeathRecipient>(proxy->uvQueue_, argv[1]); in On()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/provider/src/
H A Ddatashare_stub_impl.cpp69 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in GetFileTypes()
95 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in OpenFile()
115 uvQueue_->SyncCall(syncTaskFunc); in OpenRawFile()
148 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in Insert()
182 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in Update()
213 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in BatchUpdate()
246 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in Delete()
279 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in InsertEx()
313 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in UpdateEx()
346 uvQueue_->SyncCall(syncTaskFunc, getRetFunc); in DeleteEx()
[all …]
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/common/src/
H A Djs_observer.cpp20 : uvQueue_(uvQueue), sendabel_(sendable) in JSObserver()
39 auto uvQueue = uvQueue_.lock(); in ClearCallback()
49 auto uvQueue = uvQueue_.lock(); in GetEnv()
62 auto uvQueue = uvQueue_.lock(); in AsyncCall()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/provider/include/
H A Ddatashare_stub_impl.h33 uvQueue_ = std::make_shared<DataShare::DataShareUvQueue>(env); in DataShareStubImpl()
82 std::shared_ptr<DataShare::DataShareUvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/include/
H A Djs_observer.h30 std::shared_ptr<UvQueue> uvQueue_;
H A Djs_kv_manager.h61 std::shared_ptr<UvQueue> uvQueue_; variable
H A Djs_kv_store.h110 std::shared_ptr<UvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/include/
H A Djs_observer.h30 std::shared_ptr<UvQueue> uvQueue_;
H A Djs_kv_manager.h62 std::shared_ptr<UvQueue> uvQueue_; variable
H A Djs_single_kv_store.h123 std::shared_ptr<UvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/common/include/
H A Djs_observer.h34 std::weak_ptr<UvQueue> uvQueue_;
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/include/common/
H A Duv_queue.h37 std::weak_ptr<UvQueue> uvQueue_; member
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/
H A Dnapi_rdb_store_observer.h53 std::shared_ptr<UvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/
H A Duv_queue.cpp33 auto queue = entry->uvQueue_.lock(); in ExecUvWork()
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/storage/include/
H A Dnapi_storage.h66 std::shared_ptr<PreferencesJsKit::UvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/preferences/include/
H A Dnapi_preferences.h80 std::shared_ptr<UvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/sendable_preferences/include/
H A Dnapi_preferences.h84 std::shared_ptr<UvQueue> uvQueue_; variable
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/preferences/src/
H A Dnapi_preferences.cpp54 : env_(nullptr), uvQueue_(nullptr) in PreferencesProxy()
125 obj->uvQueue_ = std::make_shared<UvQueue>(env); in NewInstance()
520 auto observer = std::make_shared<JSPreferencesObserver>(uvQueue_, callback); in RegisteredObserver()
626 auto observer = std::make_shared<JSPreferencesObserver>(uvQueue_, callback); in RegisteredDataObserver()
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/sendable_preferences/src/
H A Dnapi_preferences.cpp531 uvQueue_ = nullptr; in ~JSObservers()
538 uvQueue_ = std::make_shared<UvQueue>(env); in JSObservers()
573 auto jsObserver = std::make_shared<JSObserverImpl>(uvQueue_, callback); in Subscribe()
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/storage/src/
H A Dnapi_storage.cpp53 : value_(value), env_(nullptr), uvQueue_(nullptr) in StorageProxy()
156 obj->uvQueue_ = std::make_shared<UvQueue>(env); in New()
703 auto observer = std::make_shared<JSPreferencesObserver>(uvQueue_, callback); in RegisterObserver()

12