Home
last modified time | relevance | path

Searched refs:work (Results 1 – 25 of 372) sorted by relevance

12345678910>>...15

/foundation/bundlemanager/bundle_framework/interfaces/kits/js/launchermgr/
Dbundle_status_callback.cpp31 uv_work_t* work = new uv_work_t; in ~BundleStatusCallback() local
38 if (work == nullptr || delRefCallbackInfo == nullptr) { in ~BundleStatusCallback()
41 work->data = reinterpret_cast<void*>(delRefCallbackInfo); in ~BundleStatusCallback()
43 loop, work, [](uv_work_t* work) {}, in ~BundleStatusCallback() argument
44 [](uv_work_t* work, int status) { in ~BundleStatusCallback() argument
46 … DelRefCallbackInfo* delRefCallbackInfo = reinterpret_cast<DelRefCallbackInfo*>(work->data); in ~BundleStatusCallback()
55 delete work; in ~BundleStatusCallback()
56 work = nullptr; in ~BundleStatusCallback()
60 delete work; in ~BundleStatusCallback()
68 uv_work_t* work = new uv_work_t; in OnBundleAdded() local
[all …]
/foundation/communication/dsoftbus/core/connection/wifi_direct/utils/
Dwifi_direct_work_queue.c26 WorkFunction work; member
35 static SoftBusMessage* NewMessage(struct WifiDirectWork *work) in NewMessage() argument
43 msg->obj = work; in NewMessage()
48 static void ScheduleWork(struct WifiDirectWork *work) in ScheduleWork() argument
51 SoftBusMessage *msg = NewMessage(work); in ScheduleWork()
58 static void ScheduleDelayWork(struct WifiDirectWork *work, int64_t timeMs) in ScheduleDelayWork() argument
61 SoftBusMessage *msg = NewMessage(work); in ScheduleDelayWork()
76 static void RemoveWork(struct WifiDirectWork *work) in RemoveWork() argument
80 handler->looper->RemoveMessageCustom(handler->looper, handler, CompareMessage, work); in RemoveWork()
85 struct WifiDirectWork *work = msg->obj; in MessageHandler() local
[all …]
/foundation/distributeddatamgr/data_share/frameworks/native/provider/src/
Ddatashare_uv_queue.cpp33 uv_work_t* work = new (std::nothrow) uv_work_t; in SyncCall() local
34 if (work == nullptr) { in SyncCall()
38 work->data = new UvEntry {env_, std::move(func), false, false, {}, {}, std::move(retFunc)}; in SyncCall()
40 loop_, work, [](uv_work_t* work) {}, in SyncCall() argument
41 [](uv_work_t* work, int uvstatus) { in SyncCall() argument
42 if (work == nullptr || work->data == nullptr) { in SyncCall()
46 auto *entry = static_cast<UvEntry*>(work->data); in SyncCall()
53 DataShareUvQueue::Purge(work); in SyncCall()
60 DataShareUvQueue::Purge(work); in SyncCall()
65 auto *uvEntry = static_cast<UvEntry*>(work->data); in SyncCall()
[all …]
/foundation/barrierfree/accessibility/interfaces/kits/napi/src/
Dnapi_accessibility_config_observer.cpp68 int NAccessibilityConfigObserver::NotifyStateChanged(uv_work_t *work) in NotifyStateChanged() argument
72 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in NotifyStateChanged() argument
73 [](uv_work_t *work, int status) { in NotifyStateChanged() argument
74 StateCallbackInfo *callbackInfo = static_cast<StateCallbackInfo*>(work->data); in NotifyStateChanged()
97 delete work; in NotifyStateChanged()
98 work = nullptr; in NotifyStateChanged()
104 int NAccessibilityConfigObserver::NotifyPropertyChanged(uv_work_t *work) in NotifyPropertyChanged() argument
108 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in NotifyPropertyChanged() argument
109 [](uv_work_t *work, int status) { in NotifyPropertyChanged() argument
110 CaptionCallbackInfo *callbackInfo = static_cast<CaptionCallbackInfo*>(work->data); in NotifyPropertyChanged()
[all …]
/foundation/communication/bluetooth/frameworks/js/napi/src/ble/
Dnapi_bluetooth_gatt_server_callback.cpp43 uv_work_t *work = new uv_work_t; in OnCharacteristicReadRequest() local
44 work->data = static_cast<void *>(callbackInfo.get()); in OnCharacteristicReadRequest()
48 work, in OnCharacteristicReadRequest()
49 [](uv_work_t *work) {}, in OnCharacteristicReadRequest() argument
50 [](uv_work_t *work, int status) { in OnCharacteristicReadRequest() argument
51 …aracteristicCallbackInfo *callbackInfo = static_cast<GattCharacteristicCallbackInfo *>(work->data); in OnCharacteristicReadRequest()
63 delete work; in OnCharacteristicReadRequest()
64 work = nullptr; in OnCharacteristicReadRequest()
88 uv_work_t *work = new uv_work_t; in OnCharacteristicWriteRequest() local
89 work->data = static_cast<void *>(callbackInfo.get()); in OnCharacteristicWriteRequest()
[all …]
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/
Duv_queue.cpp36 uv_work_t *work = new (std::nothrow) uv_work_t; in CallFunction() local
37 if (work == nullptr) { in CallFunction()
41 work->data = new (std::nothrow)UvEntry { weak_from_this() }; in CallFunction()
42 if (work->data == nullptr) { in CallFunction()
60 loop_, work, [](uv_work_t *work) {}, in CallFunction() argument
61 [](uv_work_t *work, int uvstatus) { in CallFunction() argument
62 UvEntry *entry = static_cast<UvEntry *>(work->data); in CallFunction()
73 delete work; in CallFunction()
74 work = nullptr; in CallFunction()
77 if (work->data != nullptr) { in CallFunction()
[all …]
/foundation/multimodalinput/input/frameworks/napi/input_device/include/
Djs_event_target.h51 static void CallIdsPromiseWork(uv_work_t *work, int32_t status);
52 static void CallIdsAsyncWork(uv_work_t *work, int32_t status);
53 static void CallDevAsyncWork(uv_work_t *work, int32_t status);
54 static void CallDevPromiseWork(uv_work_t *work, int32_t status);
55 static void CallKeystrokeAbilityPromise(uv_work_t *work, int32_t status);
56 static void CallKeystrokeAbilityAsync(uv_work_t *work, int32_t status);
57 static void CallKeyboardTypeAsync(uv_work_t *work, int32_t status);
58 static void CallKeyboardTypePromise(uv_work_t *work, int32_t status);
59 static void CallDevListPromiseWork(uv_work_t *work, int32_t status);
60 static void CallDevListAsyncWork(uv_work_t *work, int32_t status);
[all …]
/foundation/communication/bluetooth/frameworks/js/napi/src/
Dnapi_bluetooth_opp_observer.cpp37 uv_work_t *work = new uv_work_t; in OnReceiveIncomingFileChanged() local
38 work->data = static_cast<void *>(callbackInfo.get()); in OnReceiveIncomingFileChanged()
42 work, in OnReceiveIncomingFileChanged()
43 [](uv_work_t *work) {}, in OnReceiveIncomingFileChanged() argument
44 [](uv_work_t *work, int status) { in OnReceiveIncomingFileChanged() argument
45 …InformationCallbackInfo *callbackInfo = static_cast<TransforInformationCallbackInfo *>(work->data); in OnReceiveIncomingFileChanged()
56 delete work; in OnReceiveIncomingFileChanged()
57 work = nullptr; in OnReceiveIncomingFileChanged()
79 uv_work_t *work = new uv_work_t; in OnTransferStateChanged() local
80 work->data = (void*)callbackInfo.get(); in OnTransferStateChanged()
[all …]
Dnapi_bluetooth_pbap_pse_observer.cpp35 uv_work_t *work = new uv_work_t; in OnServiceConnectionStateChanged() local
36 work->data = (void*)callbackInfo.get(); in OnServiceConnectionStateChanged()
40 work, in OnServiceConnectionStateChanged()
41 [](uv_work_t *work) {}, in OnServiceConnectionStateChanged() argument
42 [](uv_work_t *work, int status) { in OnServiceConnectionStateChanged() argument
43 BluetoothCallbackInfo *callbackInfo = (BluetoothCallbackInfo *)work->data; in OnServiceConnectionStateChanged()
53 delete work; in OnServiceConnectionStateChanged()
54 work = nullptr; in OnServiceConnectionStateChanged()
Dnapi_bluetooth_pbap_pce_observer.cpp36 uv_work_t *work = new uv_work_t; in OnServiceConnectionStateChanged() local
37 work->data = static_cast<void *>(callbackInfo.get()); in OnServiceConnectionStateChanged()
41 work, in OnServiceConnectionStateChanged()
42 [](uv_work_t *work) {}, in OnServiceConnectionStateChanged() argument
43 [](uv_work_t *work, int status) { in OnServiceConnectionStateChanged() argument
44 BluetoothCallbackInfo *callbackInfo = static_cast<BluetoothCallbackInfo *>(work->data); in OnServiceConnectionStateChanged()
55 delete work; in OnServiceConnectionStateChanged()
56 work = nullptr; in OnServiceConnectionStateChanged()
/foundation/multimodalinput/input/frameworks/napi/input_device/src/
Djs_event_target.cpp40 void JsEventTarget::EmitAddedDeviceEvent(uv_work_t *work, int32_t status) in EmitAddedDeviceEvent() argument
44 CHKPV(work); in EmitAddedDeviceEvent()
45 if (work->data == nullptr) { in EmitAddedDeviceEvent()
46 JsUtil::DeletePtr<uv_work_t *>(work); in EmitAddedDeviceEvent()
50 auto temp = static_cast<std::unique_ptr<JsUtil::CallbackInfo> *>(work->data); in EmitAddedDeviceEvent()
51 JsUtil::DeletePtr<uv_work_t *>(work); in EmitAddedDeviceEvent()
92 void JsEventTarget::EmitRemoveDeviceEvent(uv_work_t *work, int32_t status) in EmitRemoveDeviceEvent() argument
96 CHKPV(work); in EmitRemoveDeviceEvent()
97 if (work->data == nullptr) { in EmitRemoveDeviceEvent()
98 JsUtil::DeletePtr<uv_work_t *>(work); in EmitRemoveDeviceEvent()
[all …]
/foundation/barrierfree/accessibility/interfaces/kits/napi/accessibility_extension_module_loader/src/
Dnapi_accessibility_extension.cpp163 uv_work_t *work = new(std::nothrow) uv_work_t; in OnAbilityConnected() local
164 if (!work) { in OnAbilityConnected()
170 work->data = static_cast<void*>(callbackInfo); in OnAbilityConnected()
174 work, in OnAbilityConnected()
175 [](uv_work_t *work) {}, in OnAbilityConnected() argument
176 [](uv_work_t *work, int status) { in OnAbilityConnected() argument
177 ExtensionCallbackInfo *data = static_cast<ExtensionCallbackInfo*>(work->data); in OnAbilityConnected()
181 delete work; in OnAbilityConnected()
182 work = nullptr; in OnAbilityConnected()
189 delete work; in OnAbilityConnected()
[all …]
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
Dnapi_observer.cpp29 void NapiObserver::CallbackFunc(uv_work_t *work, int status) in CallbackFunc() argument
32 std::shared_ptr<ObserverWorker> innerWorker(reinterpret_cast<ObserverWorker *>(work->data)); in CallbackFunc()
35 delete work; in CallbackFunc()
42 delete work; in CallbackFunc()
58 delete work; in CallbackFunc()
107 uv_work_t *work = new (std::nothrow) uv_work_t(); in OnChange() local
108 if (work == nullptr) { in OnChange()
113 work->data = observerWorker; in OnChange()
115 loop_, work, [](uv_work_t *work) {}, CallbackFunc); in OnChange() argument
119 delete work; in OnChange()
[all …]
/foundation/resourceschedule/device_usage_statistics/frameworks/src/
Dapp_group_observer_napi.cpp80 void UvQueueWorkOnAppGroupChanged(uv_work_t *work, int status) in UvQueueWorkOnAppGroupChanged() argument
83 if (!work) { in UvQueueWorkOnAppGroupChanged()
86 …CallbackReceiveDataWorker *callbackReceiveDataWorkerData = (CallbackReceiveDataWorker *)work->data; in UvQueueWorkOnAppGroupChanged()
89 delete work; in UvQueueWorkOnAppGroupChanged()
90 work = nullptr; in UvQueueWorkOnAppGroupChanged()
102 delete work; in UvQueueWorkOnAppGroupChanged()
103 work = nullptr; in UvQueueWorkOnAppGroupChanged()
125 delete work; in UvQueueWorkOnAppGroupChanged()
126 work = nullptr; in UvQueueWorkOnAppGroupChanged()
141 uv_work_t* work = new (std::nothrow) uv_work_t; in OnAppGroupChanged() local
[all …]
/foundation/resourceschedule/background_task_mgr/interfaces/kits/napi/src/
Drequest_suspend_delay.cpp50 void UvQueueWorkDeleteRef(uv_work_t *work, int32_t status) in UvQueueWorkDeleteRef() argument
52 if (work == nullptr) { in UvQueueWorkDeleteRef()
55 … CallbackReceiveDataWorker *dataWorkerData = static_cast<CallbackReceiveDataWorker *>(work->data); in UvQueueWorkDeleteRef()
57 delete work; in UvQueueWorkDeleteRef()
58 work = nullptr; in UvQueueWorkDeleteRef()
64 delete work; in UvQueueWorkDeleteRef()
81 uv_work_t *work = new (std::nothrow) uv_work_t; in DeleteNapiRef() local
82 if (work == nullptr) { in DeleteNapiRef()
88 work->data = static_cast<void *>(dataWorker); in DeleteNapiRef()
90 int32_t ret = uv_queue_work(loop, work, [](uv_work_t *work) {}, UvQueueWorkDeleteRef); in DeleteNapiRef() argument
[all …]
/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/
Dnapi_datashare_inner_observer.cpp30 void NAPIInnerObserver::OnComplete(uv_work_t *work, int status) in OnComplete() argument
33 std::shared_ptr<ObserverWorker> innerWorker(reinterpret_cast<ObserverWorker *>(work->data)); in OnComplete()
36 delete work; in OnComplete()
43 delete work; in OnComplete()
57 delete work; in OnComplete()
72 uv_work_t *work = new (std::nothrow)uv_work_t(); in OnChange() local
73 if (work == nullptr) { in OnChange()
78 work->data = observerWorker; in OnChange()
79 int ret = uv_queue_work(loop_, work, [](uv_work_t *work) {}, NAPIInnerObserver::OnComplete); in OnChange() argument
83 delete work; in OnChange()
/foundation/multimedia/player_framework/frameworks/js/soundpool/src/
Dsoundpool_callback_napi.cpp141 uv_work_t *work = new(std::nothrow) uv_work_t; in OnJsErrorCallBack() local
142 CHECK_AND_RETURN_LOG(work != nullptr, "fail to new uv_work_t"); in OnJsErrorCallBack()
144 delete work; in OnJsErrorCallBack()
146 work->data = reinterpret_cast<void *>(jsCb); in OnJsErrorCallBack()
148 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsErrorCallBack() argument
150 CHECK_AND_RETURN_LOG(work != nullptr, "work is nullptr"); in OnJsErrorCallBack()
151 CHECK_AND_RETURN_LOG(work->data != nullptr, "workdata is nullptr"); in OnJsErrorCallBack()
152 SoundPoolJsCallBack *event = reinterpret_cast<SoundPoolJsCallBack *>(work->data); in OnJsErrorCallBack()
184 delete work; in OnJsErrorCallBack()
200 uv_work_t *work = new(std::nothrow) uv_work_t; in OnJsloadCompletedCallBack() local
[all …]
/foundation/multimedia/player_framework/frameworks/js/player/
Dplayer_callback_napi.cpp285 uv_work_t *work = new(std::nothrow) uv_work_t; in OnJsCallBack() local
286 if (work == nullptr) { in OnJsCallBack()
291 work->data = reinterpret_cast<void *>(jsCb); in OnJsCallBack()
293 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallBack() argument
295 CHECK_AND_RETURN_LOG(work != nullptr, "work is nullptr"); in OnJsCallBack()
296 PlayerJsCallback *event = reinterpret_cast<PlayerJsCallback *>(work->data); in OnJsCallBack()
320 delete work; in OnJsCallBack()
325 delete work; in OnJsCallBack()
338 uv_work_t *work = new(std::nothrow) uv_work_t; in OnJsCallBackError() local
339 if (work == nullptr) { in OnJsCallBackError()
[all …]
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/zip/napi/
Dzlib_callback_info.cpp34 int32_t ZlibCallbackInfo::ExcuteWork(uv_loop_s* loop, uv_work_t* work) in ExcuteWork() argument
37 loop, work, [](uv_work_t* work) {}, in ExcuteWork() argument
38 [](uv_work_t* work, int status) { in ExcuteWork() argument
39 if (work == nullptr) { in ExcuteWork()
42 AsyncCallbackInfo* asyncCallbackInfo = reinterpret_cast<AsyncCallbackInfo*>(work->data); in ExcuteWork()
81 if (work != nullptr) { in ExcuteWork()
82 delete work; in ExcuteWork()
83 work = nullptr; in ExcuteWork()
105 uv_work_t* work = new (std::nothrow) uv_work_t; in OnZipUnZipFinish() local
106 if (work == nullptr) { in OnZipUnZipFinish()
[all …]
/foundation/multimedia/camera_framework/frameworks/js/camera_napi/src/input/
Dcamera_mute_listener_napi.cpp40 uv_work_t* work = new(std::nothrow) uv_work_t; in OnCameraMuteCallbackAsync() local
41 if (!work) { in OnCameraMuteCallbackAsync()
47 work->data = callbackInfo.get(); in OnCameraMuteCallbackAsync()
48 int ret = uv_queue_work(loop, work, [] (uv_work_t* work) {}, [] (uv_work_t* work, int status) { in OnCameraMuteCallbackAsync() argument
49 … CameraMuteCallbackInfo* callbackInfo = reinterpret_cast<CameraMuteCallbackInfo *>(work->data); in OnCameraMuteCallbackAsync()
54 delete work; in OnCameraMuteCallbackAsync()
58 delete work; in OnCameraMuteCallbackAsync()
/foundation/communication/netmanager_base/frameworks/js/napi/netpolicy/include/
Dnet_policy_callback_observer.h44 …i_value (*MakeJsValue)(napi_env, void *)> static void CallbackTemplate(uv_work_t *work, int status) in CallbackTemplate() argument
47 if (work == nullptr) { in CallbackTemplate()
50 auto workWrapper = static_cast<UvWorkWrapper *>(work->data); in CallbackTemplate()
52 delete work; in CallbackTemplate() local
62 delete work; in CallbackTemplate() local
71 static void NetUidPolicyChangeCallback(uv_work_t *work, int status);
72 static void NetUidRuleChangeCallback(uv_work_t *work, int status);
73 static void NetQuotaPolicyChangeCallback(uv_work_t *work, int status);
74 static void NetMeteredIfacesChangeCallback(uv_work_t *work, int status);
75 static void NetBackgroundPolicyChangeCallback(uv_work_t *work, int status);
/foundation/multimedia/av_session/frameworks/js/napi/session/src/
Dnapi_async_callback.cpp41 void NapiAsyncCallback::AfterWorkCallback(uv_work_t* work, int aStatus) in AfterWorkCallback() argument
44 …std::shared_ptr<DataContext> context(static_cast<DataContext*>(work->data), [work](DataContext* pt… in AfterWorkCallback()
46 delete work; in AfterWorkCallback()
77 auto* work = new (std::nothrow) uv_work_t; in Call() local
78 CHECK_RETURN_VOID(work != nullptr, "no memory for uv_work_t"); in Call()
80 work->data = new DataContext{env_, method, std::move(getter)}; in Call()
81 int res = uv_queue_work(loop_, work, [](uv_work_t* work) {}, AfterWorkCallback); in Call() argument
/foundation/communication/netmanager_base/frameworks/js/napi/connection/observer/include/
Dnet_conn_callback_observer.h46 …i_value (*MakeJsValue)(napi_env, void *)> static void CallbackTemplate(uv_work_t *work, int status) in CallbackTemplate() argument
49 if (work == nullptr) { in CallbackTemplate()
52 auto workWrapper = static_cast<UvWorkWrapper *>(work->data); in CallbackTemplate()
54 delete work; in CallbackTemplate() local
67 delete work; in CallbackTemplate() local
82 static void NetAvailableCallback(uv_work_t *work, int status);
84 static void NetCapabilitiesChangeCallback(uv_work_t *work, int status);
86 static void NetConnectionPropertiesChangeCallback(uv_work_t *work, int status);
88 static void NetLostCallback(uv_work_t *work, int status);
90 static void NetUnavailableCallback(uv_work_t *work, int status);
[all …]
/foundation/distributeddatamgr/preferences/frameworks/js/napi/common/src/
Duv_queue.cpp44 uv_work_t* work = new (std::nothrow) uv_work_t; in AsyncCall() local
45 if (work == nullptr) { in AsyncCall()
49 work->data = new UvEntry{ env_, getter, std::move(genArgs) }; in AsyncCall()
51 loop_, work, [](uv_work_t* work) {}, in AsyncCall() argument
52 [](uv_work_t* work, int uvstatus) { in AsyncCall() argument
53 … std::shared_ptr<UvEntry> entry(static_cast<UvEntry *>(work->data), [work](UvEntry *data) { in AsyncCall()
55 delete work; in AsyncCall()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/
Duv_queue.cpp43 uv_work_t* work = new (std::nothrow) uv_work_t; in AsyncCall() local
44 if (work == nullptr) { in AsyncCall()
48 work->data = new UvEntry{ env_, getter, std::move(genArgs) }; in AsyncCall()
50 loop_, work, [](uv_work_t* work) {}, in AsyncCall() argument
51 [](uv_work_t* work, int uvstatus) { in AsyncCall() argument
52 … std::shared_ptr<UvEntry> entry(static_cast<UvEntry *>(work->data), [work](UvEntry *data) { in AsyncCall()
54 delete work; in AsyncCall()

12345678910>>...15