| /foundation/communication/wifi/wifi/test/wifi_standard/ipc_framework/cRPC/unittest/ |
| D | server_test.cpp | 45 EventLoop *loop = nullptr; variable
46 loop = CreateEventLoop(1);
47 EXPECT_TRUE(loop->setSize == 1);
55 EventLoop loop; variable
57 StopEventLoop(&loop);
65 EventLoop loop; variable
66 loop.setSize = -1;
67 EXPECT_TRUE(AddFdEvent(&loop, fd, addMas) == -1);
76 EventLoop loop; variable
77 loop.setSize = 1;
[all …]
|
| /foundation/communication/wifi/wifi/services/wifi_standard/ipc_framework/cRPC/src/ |
| D | evloop.c | 74 void DestroyEventLoop(EventLoop *loop) in DestroyEventLoop() argument
76 if (loop == NULL) { in DestroyEventLoop()
80 if (loop->epfd != -1) { in DestroyEventLoop()
81 close(loop->epfd); in DestroyEventLoop()
83 if (loop->fdMasks != NULL) { in DestroyEventLoop()
84 free(loop->fdMasks); in DestroyEventLoop()
86 if (loop->epEvents != NULL) { in DestroyEventLoop()
87 free(loop->epEvents); in DestroyEventLoop()
89 free(loop); in DestroyEventLoop()
90 loop = NULL; in DestroyEventLoop()
[all …]
|
| D | server.c | 58 AddFdEvent(server->loop, fd, READ_EVENT | WRIT_EVENT); in OnAccept()
84 server->loop = CreateEventLoop(MAX_SUPPORT_CLIENT_FD_SIZE); in CreateRpcServer()
85 if (server->loop == NULL) { in CreateRpcServer()
92 if (AddFdEvent(server->loop, server->listenFd, READ_EVENT) < 0) { in CreateRpcServer()
120 AddFdEvent(server->loop, client->fd, WRIT_EVENT); in DealReadMessage()
151 DelFdEvent(server->loop, client->fd, READ_EVENT | WRIT_EVENT); in DealFdReadEvent()
153 DelFdEvent(server->loop, client->fd, READ_EVENT); in DealFdReadEvent()
172 DelFdEvent(server->loop, client->fd, READ_EVENT | WRIT_EVENT); in DealFdWriteEvent()
175 DelFdEvent(server->loop, client->fd, WRIT_EVENT); in DealFdWriteEvent()
196 if (server->loop->fdMasks[fd].mask == NONE_EVENT) { in DealFdEvents()
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| D | event_impl.cpp | 113 EventLoopImpl *loop = nullptr; in AddEvents() local
120 loop = loop_; in AddEvents()
121 loop->IncObjRef(loop); in AddEvents()
124 int errCode = loop->Modify(this, true, events); in AddEvents()
125 loop->DecObjRef(loop); in AddEvents()
144 EventLoopImpl *loop = nullptr; in RemoveEvents() local
151 loop = loop_; in RemoveEvents()
152 loop->IncObjRef(loop); in RemoveEvents()
155 int errCode = loop->Modify(this, false, events); in RemoveEvents()
156 loop->DecObjRef(loop); in RemoveEvents()
[all …]
|
| D | ievent_loop.cpp | 30 EventLoopImpl *loop = new (std::nothrow) EventLoop; in CreateEventLoop() local
31 if (loop == nullptr) { in CreateEventLoop()
36 errCode = loop->Initialize(); in CreateEventLoop()
38 delete loop; in CreateEventLoop()
39 loop = nullptr; in CreateEventLoop()
41 return loop; in CreateEventLoop()
|
| /foundation/communication/wifi/wifi/services/wifi_standard/ipc_framework/cRPC/include/ |
| D | evloop.h | 52 void DestroyEventLoop(EventLoop *loop);
59 void StopEventLoop(EventLoop *loop);
69 int AddFdEvent(EventLoop *loop, int fd, unsigned int addMask);
79 int DelFdEvent(EventLoop *loop, int fd, unsigned int delMask);
|
| /foundation/communication/bluetooth/frameworks/js/napi/src/ble/ |
| D | napi_bluetooth_gatt_server_callback.cpp | 41 uv_loop_s *loop = nullptr; in OnCharacteristicReadRequest() local
42 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnCharacteristicReadRequest()
47 loop, in OnCharacteristicReadRequest()
86 uv_loop_s *loop = nullptr; in OnCharacteristicWriteRequest() local
87 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnCharacteristicWriteRequest()
92 loop, in OnCharacteristicWriteRequest()
149 uv_loop_s *loop = nullptr; in OnConnectionStateUpdate() local
150 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnConnectionStateUpdate()
155 loop, in OnConnectionStateUpdate()
191 uv_loop_s *loop = nullptr; in OnDescriptorWriteRequest() local
[all …]
|
| D | napi_bluetooth_ble_central_manager_callback.cpp | 144 uv_loop_s *loop = nullptr; in SysOnScanCallBack() local
145 napi_get_uv_event_loop(callbackInfos[PARAM0]->env_, &loop); in SysOnScanCallBack()
146 if (loop == nullptr) { in SysOnScanCallBack()
169 loop, work, [](uv_work_t *work) {}, AfterWorkCallbackToSysBLEDeviceFound); in SysOnScanCallBack()
253 uv_loop_s *loop = nullptr; in OnBleBatchScanResultsEvent() local
254 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnBleBatchScanResultsEvent()
255 if (loop == nullptr) { in OnBleBatchScanResultsEvent()
285 loop, work, [](uv_work_t *work) {}, AfterWorkCallback<decltype(callbackData)>); in OnBleBatchScanResultsEvent()
312 uv_loop_s *loop = nullptr; in OnStartOrStopScanEvent() local
313 napi_get_uv_event_loop(callbackInfos[PARAM0]->env_, &loop); in OnStartOrStopScanEvent()
[all …]
|
| /foundation/bundlemanager/bundle_framework/interfaces/kits/js/launchermgr/ |
| D | bundle_status_callback.cpp | 29 uv_loop_s* loop = nullptr; in ~BundleStatusCallback() local
30 napi_get_uv_event_loop(env_, &loop); in ~BundleStatusCallback()
43 loop, work, [](uv_work_t* work) {}, in ~BundleStatusCallback()
66 uv_loop_s* loop = nullptr; in OnBundleAdded() local
67 napi_get_uv_event_loop(env_, &loop); in OnBundleAdded()
80 loop, work, [](uv_work_t* work) {}, in OnBundleAdded()
116 uv_loop_s* loop = nullptr; in OnBundleUpdated() local
117 napi_get_uv_event_loop(env_, &loop); in OnBundleUpdated()
130 loop, work, [](uv_work_t* work) {}, in OnBundleUpdated()
169 uv_loop_s* loop = nullptr; in OnBundleRemoved() local
[all …]
|
| /foundation/arkui/ace_engine_lite/test/moduletest/common/test_app/ui_auto_test/src/main/js/default/pages/chart/24/ |
| D | index.js | 36 loop: {
45 loop: {
54 loop: {
63 loop: {}
|
| /foundation/communication/bluetooth/frameworks/js/napi/src/ |
| D | napi_bluetooth_opp_observer.cpp | 35 uv_loop_s *loop = nullptr; in OnReceiveIncomingFileChanged() local
36 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnReceiveIncomingFileChanged()
41 loop, in OnReceiveIncomingFileChanged()
77 uv_loop_s *loop = nullptr; in OnTransferStateChanged() local
78 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnTransferStateChanged()
83 loop, in OnTransferStateChanged()
|
| D | napi_bluetooth_pbap_pse_observer.cpp | 33 uv_loop_s *loop = nullptr; in OnServiceConnectionStateChanged() local
34 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnServiceConnectionStateChanged()
39 loop, in OnServiceConnectionStateChanged()
|
| D | napi_bluetooth_pbap_pce_observer.cpp | 34 uv_loop_s *loop = nullptr; in OnServiceConnectionStateChanged() local
35 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnServiceConnectionStateChanged()
40 loop, in OnServiceConnectionStateChanged()
|
| /foundation/multimedia/camera_framework/frameworks/js/camera_napi/src/input/ |
| D | camera_mute_listener_napi.cpp | 34 uv_loop_s* loop = nullptr; in OnCameraMuteCallbackAsync() local
35 napi_get_uv_event_loop(env_, &loop); in OnCameraMuteCallbackAsync()
36 if (!loop) { in OnCameraMuteCallbackAsync()
48 int ret = uv_queue_work(loop, work, [] (uv_work_t* work) {}, [] (uv_work_t* work, int status) { in OnCameraMuteCallbackAsync()
|
| /foundation/multimedia/player_framework/frameworks/js/player/ |
| D | player_callback_napi.cpp | 278 uv_loop_s *loop = nullptr; in OnJsCallBack() local
279 napi_get_uv_event_loop(env_, &loop); in OnJsCallBack()
280 if (loop == nullptr) { in OnJsCallBack()
293 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallBack()
331 uv_loop_s *loop = nullptr; in OnJsCallBackError() local
332 napi_get_uv_event_loop(env_, &loop); in OnJsCallBackError()
333 if (loop == nullptr) { in OnJsCallBackError()
346 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallBackError()
395 uv_loop_s *loop = nullptr; in OnJsCallBackInt() local
396 napi_get_uv_event_loop(env_, &loop); in OnJsCallBackInt()
[all …]
|
| /foundation/barrierfree/accessibility/interfaces/kits/napi/src/ |
| D | napi_accessibility_config_observer.cpp | 70 uv_loop_s *loop = nullptr; in NotifyStateChanged() local
71 napi_get_uv_event_loop(env_, &loop); in NotifyStateChanged()
72 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in NotifyStateChanged()
106 uv_loop_s *loop = nullptr; in NotifyPropertyChanged() local
107 napi_get_uv_event_loop(env_, &loop); in NotifyPropertyChanged()
108 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in NotifyPropertyChanged()
141 uv_loop_s *loop = nullptr; in NotifyStringChanged() local
142 napi_get_uv_event_loop(env_, &loop); in NotifyStringChanged()
143 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in NotifyStringChanged()
178 uv_loop_s *loop = nullptr; in NotifyIntChanged() local
[all …]
|
| /foundation/multimedia/player_framework/frameworks/js/soundpool/src/ |
| D | soundpool_callback_napi.cpp | 137 uv_loop_s *loop = nullptr; in OnJsErrorCallBack() local
138 napi_get_uv_event_loop(env_, &loop); in OnJsErrorCallBack()
139 CHECK_AND_RETURN_LOG(loop != nullptr, "Fail to get uv event loop"); in OnJsErrorCallBack()
148 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsErrorCallBack()
196 uv_loop_s *loop = nullptr; in OnJsloadCompletedCallBack() local
197 napi_get_uv_event_loop(env_, &loop); in OnJsloadCompletedCallBack()
198 CHECK_AND_RETURN_LOG(loop != nullptr, "Fail to get uv event loop"); in OnJsloadCompletedCallBack()
207 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsloadCompletedCallBack()
248 uv_loop_s *loop = nullptr; in OnJsplayCompletedCallBack() local
249 napi_get_uv_event_loop(env_, &loop); in OnJsplayCompletedCallBack()
[all …]
|
| /foundation/arkui/ui_lite/test/unittest/dfx/ |
| D | event_injector_unit_test.cpp | 246 uint8_t loop = 0; variable
247 while ((loop < MAX_LOOP) && !CLICK_FLAG) {
248 loop++;
275 uint8_t loop = 0; variable
276 while ((loop < MAX_LOOP) && !DRAG_FLAG) {
277 loop++;
346 uint8_t loop = 0; variable
347 while ((loop < MAX_LOOP) && !LONG_PRESS_FLAG) {
348 loop++;
388 uint8_t loop = 0; variable
[all …]
|
| /foundation/resourceschedule/ffrt/benchmarks/ |
| D | common.h | 100 uint32_t loop = count; in completely_paralle() local
102 while (loop--) { in completely_paralle()
112 uint32_t loop = count; in completely_serial() local
114 while (loop--) { in completely_serial()
122 uint32_t loop = count; in single_thread() local
124 while (loop--) { in single_thread()
|
| /foundation/bundlemanager/bundle_framework/interfaces/kits/js/zip/napi/ |
| D | zlib_callback_info.cpp | 34 int32_t ZlibCallbackInfo::ExcuteWork(uv_loop_s* loop, uv_work_t* work) in ExcuteWork() argument
37 loop, work, [](uv_work_t* work) {}, in ExcuteWork()
99 uv_loop_s* loop = nullptr; in OnZipUnZipFinish() local
100 napi_get_uv_event_loop(env_, &loop); in OnZipUnZipFinish()
101 if (loop == nullptr) { in OnZipUnZipFinish()
131 int32_t ret = ExcuteWork(loop, work); in OnZipUnZipFinish()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | runtime_context_impl.cpp | 159 IEventLoop *loop = nullptr; in SetTimer() local
160 errCode = PrepareLoop(loop); in SetTimer()
168 loop->DecObjRef(loop); in SetTimer()
169 loop = nullptr; in SetTimer()
177 loop->DecObjRef(loop); in SetTimer()
178 loop = nullptr; in SetTimer()
191 errCode = loop->Add(evTimer); in SetTimer()
198 loop->DecObjRef(loop); in SetTimer()
199 loop = nullptr; in SetTimer()
304 int RuntimeContextImpl::PrepareLoop(IEventLoop *&loop) in PrepareLoop() argument
[all …]
|
| /foundation/multimedia/audio_framework/frameworks/js/napi/audio_renderer/src/ |
| D | audio_renderer_callback_napi.cpp | 101 uv_loop_s *loop = nullptr; in OnJsCallbackInterrupt() local
102 napi_get_uv_event_loop(env_, &loop); in OnJsCallbackInterrupt()
103 if (loop == nullptr) { in OnJsCallbackInterrupt()
119 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallbackInterrupt()
174 uv_loop_s *loop = nullptr; in OnJsCallbackStateChange() local
175 napi_get_uv_event_loop(env_, &loop); in OnJsCallbackStateChange()
176 if (loop == nullptr) { in OnJsCallbackStateChange()
192 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallbackStateChange()
|
| /foundation/multimedia/audio_framework/frameworks/js/napi/audio_capturer/src/ |
| D | audio_capturer_callback_napi.cpp | 100 uv_loop_s *loop = nullptr; in OnJsCallbackInterrupt() local
101 napi_get_uv_event_loop(env_, &loop); in OnJsCallbackInterrupt()
102 if (loop == nullptr) { in OnJsCallbackInterrupt()
118 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallbackInterrupt()
172 uv_loop_s *loop = nullptr; in OnJsCallbackStateChange() local
173 napi_get_uv_event_loop(env_, &loop); in OnJsCallbackStateChange()
174 if (loop == nullptr) { in OnJsCallbackStateChange()
192 int ret = uv_queue_work(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in OnJsCallbackStateChange()
|
| /foundation/communication/bluetooth/frameworks/js/napi/src/hid/ |
| D | napi_bluetooth_hid_host_observer.cpp | 39 uv_loop_s *loop = nullptr; in OnConnectionStateChanged() local
40 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnConnectionStateChanged()
45 loop, in OnConnectionStateChanged()
|
| /foundation/communication/bluetooth/frameworks/js/napi/src/pan/ |
| D | napi_bluetooth_pan_observer.cpp | 37 uv_loop_s *loop = nullptr; in OnConnectionStateChanged() local
38 napi_get_uv_event_loop(callbackInfo->env_, &loop); in OnConnectionStateChanged()
43 loop, in OnConnectionStateChanged()
|