Home
last modified time | relevance | path

Searched refs:loop (Results 1 - 25 of 311) sorted by relevance

12345678910>>...13

/foundation/communication/wifi/wifi/base/cRPC/src/
H A Devloop.c30 int flag = 0; /* flag here is used to indicate whether a failure occurs when create event loop struct, 0:success in CreateEventLoop()
76 void DestroyEventLoop(EventLoop *loop) in DestroyEventLoop() argument
78 if (loop == NULL) { in DestroyEventLoop()
82 if (loop->epfd != -1) { in DestroyEventLoop()
83 close(loop->epfd); in DestroyEventLoop()
85 if (loop->fdMasks != NULL) { in DestroyEventLoop()
86 free(loop->fdMasks); in DestroyEventLoop()
88 if (loop->epEvents != NULL) { in DestroyEventLoop()
89 free(loop->epEvents); in DestroyEventLoop()
91 free(loop); in DestroyEventLoop()
96 StopEventLoop(EventLoop *loop) StopEventLoop() argument
106 AddFdEvent(EventLoop *loop, int fd, unsigned int addMask) AddFdEvent() argument
139 DelFdEvent(EventLoop *loop, int fd, unsigned int delMask) DelFdEvent() argument
[all...]
H A Dserver.c66 AddFdEvent(server->loop, fd, READ_EVENT | WRIT_EVENT); in OnAccept()
92 server->loop = CreateEventLoop(MAX_SUPPORT_CLIENT_FD_SIZE); in CreateRpcServer()
93 if (server->loop == NULL) { in CreateRpcServer()
100 if (AddFdEvent(server->loop, server->listenFd, READ_EVENT) < 0) { in CreateRpcServer()
128 AddFdEvent(server->loop, client->fd, WRIT_EVENT); in DealReadMessage()
160 DelFdEvent(server->loop, client->fd, READ_EVENT | WRIT_EVENT); in DealFdReadEvent()
163 DelFdEvent(server->loop, client->fd, READ_EVENT); in DealFdReadEvent()
183 DelFdEvent(server->loop, client->fd, READ_EVENT | WRIT_EVENT); in DealFdWriteEvent()
187 DelFdEvent(server->loop, client->fd, WRIT_EVENT); in DealFdWriteEvent()
208 if (server->loop in DealFdEvents()
223 EventLoop *loop = server->loop; RunRpcLoop() local
[all...]
/foundation/communication/wifi/wifi/test/wifi_standard/ipc_framework/cRPC/unittest/
H A Dserver_test.cpp45 EventLoop *loop = nullptr; in HWTEST_F() local
46 loop = CreateEventLoop(1); in HWTEST_F()
47 EXPECT_TRUE(loop->setSize == 1); in HWTEST_F()
55 EventLoop loop; in HWTEST_F() local
57 StopEventLoop(&loop); in HWTEST_F()
65 EventLoop loop; in HWTEST_F() local
66 loop.setSize = -1; in HWTEST_F()
67 EXPECT_TRUE(AddFdEvent(&loop, fd, addMas) == -1); in HWTEST_F()
76 EventLoop loop; in HWTEST_F() local
77 loop in HWTEST_F()
88 EventLoop loop; HWTEST_F() local
101 EventLoop loop; HWTEST_F() local
117 EventLoop loop; HWTEST_F() local
130 EventLoop loop; HWTEST_F() local
142 EventLoop loop; HWTEST_F() local
154 EventLoop loop; HWTEST_F() local
172 EventLoop loop; HWTEST_F() local
184 EventLoop loop; HWTEST_F() local
[all...]
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_base/
H A Dserver_test.cpp45 EventLoop *loop = nullptr; in HWTEST_F() local
46 loop = CreateEventLoop(1); in HWTEST_F()
47 EXPECT_TRUE(loop->setSize == 1); in HWTEST_F()
55 EventLoop loop; in HWTEST_F() local
57 StopEventLoop(&loop); in HWTEST_F()
65 EventLoop loop; in HWTEST_F() local
66 loop.setSize = -1; in HWTEST_F()
67 EXPECT_TRUE(AddFdEvent(&loop, fd, addMas) == -1); in HWTEST_F()
76 EventLoop loop; in HWTEST_F() local
77 loop in HWTEST_F()
88 EventLoop loop; HWTEST_F() local
101 EventLoop loop; HWTEST_F() local
117 EventLoop loop; HWTEST_F() local
130 EventLoop loop; HWTEST_F() local
142 EventLoop loop; HWTEST_F() local
154 EventLoop loop; HWTEST_F() local
172 EventLoop loop; HWTEST_F() local
184 EventLoop loop; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Devent_impl.cpp113 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 in RemoveEvents()
169 EventLoopImpl *loop = nullptr; SetTimeout() local
190 EventLoopImpl *loop = nullptr; Detach() local
255 SetLoop(EventLoopImpl *loop) SetLoop() argument
280 Attached(const EventLoopImpl *loop, bool &isLoopConfused) const Attached() argument
[all...]
H A Dievent_loop.cpp30 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/resourceschedule/ffrt/src/eu/
H A Dloop_api.cpp16 #include "c/loop.h"
17 #include "loop.h"
29 FFRT_COND_DO_ERR((!handler->IsValidForLoop()), return nullptr, "queue invalid for loop"); in ffrt_loop_create()
32 FFRT_COND_DO_ERR((innerLoop == nullptr), return nullptr, "failed to construct loop"); in ffrt_loop_create()
42 int ffrt_loop_destroy(ffrt_loop_t loop) in ffrt_loop_destroy() argument
44 FFRT_COND_DO_ERR((loop == nullptr), return -1, "input invalid, loop is nullptr"); in ffrt_loop_destroy()
45 Loop* innerLoop = static_cast<Loop*>(loop); in ffrt_loop_destroy()
51 int ffrt_loop_run(ffrt_loop_t loop) in ffrt_loop_run() argument
53 FFRT_COND_DO_ERR((loop in ffrt_loop_run()
61 ffrt_loop_stop(ffrt_loop_t loop) ffrt_loop_stop() argument
69 ffrt_loop_epoll_ctl(ffrt_loop_t loop, int op, int fd, uint32_t events, void *data, ffrt_poller_cb cb) ffrt_loop_epoll_ctl() argument
77 ffrt_loop_timer_start(ffrt_loop_t loop, uint64_t timeout, void* data, ffrt_timer_cb cb, bool repeat) ffrt_loop_timer_start() argument
85 ffrt_loop_timer_stop(ffrt_loop_t loop, ffrt_timer_t handle) ffrt_loop_timer_stop() argument
[all...]
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_loop.cpp25 #include "c/loop.h"
64 * 测试用例描述：非法队列创建loop失败
66 * 操作步骤 ：1、创建loop失败
72 auto loop = ffrt_loop_create(nullptr); in HWTEST_F() local
73 EXPECT_EQ(loop, nullptr); in HWTEST_F()
78 * 测试用例描述：serial队列创建loop失败
80 * 操作步骤 ：1、创建loop
90 auto loop = ffrt_loop_create(queue_handle); in HWTEST_F() local
91 EXPECT_EQ(loop, nullptr); in HWTEST_F()
99 * 测试用例描述：无任务concurrent队列创建loop成功
111 auto loop = ffrt_loop_create(queue_handle); HWTEST_F() local
140 auto loop = ffrt_loop_create(queue_handle); HWTEST_F() local
189 auto loop = ffrt_loop_create(queue_handle); HWTEST_F() local
242 auto loop = ffrt_loop_create(mainQueue); HWTEST_F() local
[all...]
/foundation/arkui/napi/test/unittest/common/
H A Dtest_common.h37 uv_loop_t* loop = nullptr; \
38 ASSERT_CHECK_CALL(napi_get_uv_event_loop((env), &loop)); \
39 ASSERT_NE(loop, nullptr); \
40 uv_run(loop, (mode)); \
47 uv_loop_t* loop = nullptr; \
48 ASSERT_CHECK_CALL(napi_get_uv_event_loop((env), &loop)); \
49 ASSERT_NE(loop, nullptr); \
50 uv_stop(loop); \
/foundation/graphic/graphic_2d/graphic_test/graphic_test_framework/src/
H A Drs_graphic_test_main.cpp56 for (uint32_t loop = 0; loop < curlayerInfo.size(); loop++) { in DisplayCaseLayer()
57 if (loop >= layerInfo.size()) { in DisplayCaseLayer()
58 layerInfo.push_back(curlayerInfo[loop]); in DisplayCaseLayer()
59 } else if (curlayerInfo[loop] == layerInfo[loop]) { in DisplayCaseLayer()
62 layerInfo[loop] = curlayerInfo[loop]; in DisplayCaseLayer()
66 for (uint32_t idx = 0; idx < loop; id in DisplayCaseLayer()
[all...]
/foundation/resourceschedule/ffrt/interfaces/kits/c/
H A Dloop.h25 * @brief Creates a loop.
28 * @return Returns a non-null loop handle if the loop is created;
36 * @brief Destroys a loop.
38 * @param loop Indicates a loop handle.
39 * @return returns 0 if the loop is destroyed;
44 FFRT_C_API int ffrt_loop_destroy(ffrt_loop_t loop);
47 * @brief start loop run.
49 * @param loop Indicate
[all...]
/foundation/communication/wifi/wifi/base/cRPC/include/
H A Devloop.h43 * @return EventLoop* - pointer to the event loop object or NULL if failed
48 * @Description Destroy Events loop
50 * @param loop - EventLoop object's pointer
52 void DestroyEventLoop(EventLoop *loop);
57 * @param loop - EventLoop object's pointer
59 void StopEventLoop(EventLoop *loop);
64 * @param loop - EventLoop object's pointer
69 int AddFdEvent(EventLoop *loop, int fd, unsigned int addMask);
74 * @param loop - EventLoop object's pointer
79 int DelFdEvent(EventLoop *loop, in
[all...]
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/launchermgr/
H A Dbundle_status_callback.cpp30 uv_loop_s* loop = nullptr; in ~BundleStatusCallback() local
31 napi_get_uv_event_loop(env_, &loop); in ~BundleStatusCallback()
48 loop, work, [](uv_work_t* work) { APP_LOGI("~BundleStatusCallback asyn work done"); }, in ~BundleStatusCallback()
71 uv_loop_s* loop = nullptr; in OnBundleAdded() local
72 napi_get_uv_event_loop(env_, &loop); in OnBundleAdded()
91 if (loop == nullptr) { in OnBundleAdded()
92 APP_LOGW("BundleStatusCallback OnBundleAdded loop is nullptr bundleName : %{public}s", bundleName.c_str()); in OnBundleAdded()
97 loop, work, [](uv_work_t* work) { APP_LOGI("BundleStatusCallback OnBundleAdded asyn work done"); }, in OnBundleAdded()
137 uv_loop_s* loop = nullptr; in OnBundleUpdated() local
138 napi_get_uv_event_loop(env_, &loop); in OnBundleUpdated()
206 uv_loop_s* loop = nullptr; OnBundleRemoved() local
[all...]
/foundation/arkui/ace_engine_lite/test/moduletest/common/test_app/ui_auto_test/src/main/js/default/pages/chart/24/
H A Dindex.js36 loop: {
45 loop: {
54 loop: {
63 loop: {}
/foundation/ability/ability_runtime/frameworks/js/napi/featureAbility/
H A Dnapi_data_ability_observer.cpp46 uv_loop_s* loop = nullptr; in SafeReleaseJSCallback() local
47 napi_get_uv_event_loop(env_, &loop); in SafeReleaseJSCallback()
48 if (loop == nullptr) { in SafeReleaseJSCallback()
49 TAG_LOGE(AAFwkTag::FA, "null loop"); in SafeReleaseJSCallback()
66 loop, work, [](uv_work_t* work) {}, in SafeReleaseJSCallback()
175 uv_loop_s *loop = nullptr; in OnChange() local
176 napi_get_uv_event_loop(env_, &loop); in OnChange()
177 if (loop == nullptr) { in OnChange()
178 TAG_LOGE(AAFwkTag::FA, "null loop"); in OnChange()
187 loop, in OnChange()
[all...]
/foundation/multimedia/player_framework/frameworks/js/avtranscoder/
H A Davtranscoder_callback.cpp140 uv_loop_s *loop = nullptr; in OnJsCompleteCallBack() local
141 napi_get_uv_event_loop(env_, &loop); in OnJsCompleteCallBack()
142 CHECK_AND_RETURN_LOG(loop != nullptr, "Fail to get uv event loop"); in OnJsCompleteCallBack()
151 int ret = QueueCompleteWork(loop, work); in OnJsCompleteCallBack()
158 int32_t AVTransCoderCallback::QueueCompleteWork(uv_loop_s *loop, uv_work_t *work) const in QueueCompleteWork() argument
160 int ret = uv_queue_work_with_qos(loop, work, [] (uv_work_t *work) {}, [] (uv_work_t *work, int status) { in QueueCompleteWork()
202 uv_loop_s *loop = nullptr; in OnJsProgressUpdateCallback() local
203 napi_get_uv_event_loop(env_, &loop); in OnJsProgressUpdateCallback()
204 CHECK_AND_RETURN_LOG(loop ! in OnJsProgressUpdateCallback()
220 QueueProgressUpdateWork(uv_loop_s *loop, uv_work_t *work) const QueueProgressUpdateWork() argument
277 uv_loop_s *loop = nullptr; OnJsErrorCallBack() local
296 QueueErrorWork(uv_loop_s *loop, uv_work_t *work) const QueueErrorWork() argument
[all...]
/foundation/ability/idl_tool/test/hdi_unittest/hdi_gen_test/
H A Dbig_d_2000_file_test.py31 def get_fool_content(self, loop):
34 content += f"import ohos.hdi.foo.v1_0.Types_{loop};\n" namespace
36 content += f"interface IFoo_{loop} "
40 content += f" GetData([out] struct FooInfo_{loop} info);\n"
42 content += f" InfoTest([in] struct FooInfo_{loop} inParam, [out] struct FooInfo_{loop} outParam);\n"
46 def get_types_content(self, loop):
49 content += f"enum FooType_{loop} "
55 content += f"struct FooInfo_{loop} "
59 content += f" enum FooType_{loop} typ
[all...]
/foundation/barrierfree/accessibility/interfaces/kits/napi/src/
H A Dnapi_accessibility_config_observer.cpp108 uv_loop_s *loop = nullptr; in NotifyStateChanged() local
109 napi_get_uv_event_loop(env_, &loop); in NotifyStateChanged()
110 if (loop == nullptr || work == nullptr) { in NotifyStateChanged()
111 HILOG_ERROR("loop or work is nullptr."); in NotifyStateChanged()
114 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in NotifyStateChanged()
151 uv_loop_s *loop = nullptr; in NotifyPropertyChanged() local
152 napi_get_uv_event_loop(env_, &loop); in NotifyPropertyChanged()
153 if (loop == nullptr || work == nullptr) { in NotifyPropertyChanged()
154 HILOG_ERROR("loop or work is nullptr."); in NotifyPropertyChanged()
157 int ret = uv_queue_work_with_qos(loop, wor in NotifyPropertyChanged()
194 uv_loop_s *loop = nullptr; NotifyStringChanged() local
234 uv_loop_s *loop = nullptr; NotifyStringVectorChanged() local
275 uv_loop_s *loop = nullptr; NotifyIntChanged() local
316 uv_loop_s *loop = nullptr; NotifyUintChanged() local
357 uv_loop_s *loop = nullptr; NotifyFloatChanged() local
[all...]
/foundation/multimedia/av_codec/test/moduletest/vcodec/encoder/src/
H A Dreli_test.cpp201 int loop = 0; in HWTEST_F() local
202 while (loop < 1) { in HWTEST_F()
203 loop++; in HWTEST_F()
204 cout << "loop: "<<loop<<endl; in HWTEST_F()
247 int loop = 0; in HWTEST_F() local
248 while (loop < 1) { in HWTEST_F()
249 loop++; in HWTEST_F()
250 cout << "loop: "<<loop<<end in HWTEST_F()
293 int loop = 0; HWTEST_F() local
331 int loop = 0; HWTEST_F() local
[all...]
/foundation/multimedia/media_library/frameworks/services/media_backup_extension/include/
H A Dmedialibrary_backup_napi.h42 static void UvQueueWork(uv_loop_s *loop, uv_work_t *work);
43 static void UvQueueWorkEx(uv_loop_s *loop, uv_work_t *work);
44 static void UvBackupWork(uv_loop_s *loop, uv_work_t *work);
/foundation/multimedia/player_framework/test/fuzztest/soundpool_fuzztest/soundpoolsetloop_fuzzer/
H A Dsoundpoolsetloop_fuzzer.cpp68 playParameters.loop = *reinterpret_cast<int32_t *>(data); in FuzzSoundPoolSetLoop()
69 int32_t loop = *reinterpret_cast<int32_t *>(data); in FuzzSoundPoolSetLoop() local
74 TestSoundPool::SetLoop(streamID, loop); in FuzzSoundPoolSetLoop()
78 TestSoundPool::SetLoop(streamId, loop); in FuzzSoundPoolSetLoop()
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/class_tasksignal/
H A Dtask_signal_entity.cpp24 uv_loop_s *loop = nullptr; in OnCancel() local
30 napi_get_uv_event_loop(env, &loop); in OnCancel()
31 if (loop == nullptr) { in OnCancel()
39 int ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, in OnCancel()
/foundation/multimedia/media_library/frameworks/services/media_backup_extension/src/
H A Dmedialibrary_backup_napi.cpp112 void MediaLibraryBackupNapi::UvQueueWork(uv_loop_s *loop, uv_work_t *work)
114 uv_queue_work(loop, work, [](uv_work_t *work) {
191 uv_loop_s *loop = nullptr;
192 napi_get_uv_event_loop(env, &loop);
207 UvQueueWork(loop, work);
211 void MediaLibraryBackupNapi::UvQueueWorkEx(uv_loop_s *loop, uv_work_t *work)
213 uv_queue_work(loop, work, [](uv_work_t *work) {
269 uv_loop_s *loop = nullptr;
270 napi_get_uv_event_loop(env, &loop);
286 UvQueueWorkEx(loop, wor
[all...]
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/zip/napi/
H A Dzlib_callback_info.cpp48 int32_t ZlibCallbackInfo::ExcuteWork(uv_loop_s* loop, uv_work_t* work) in ExcuteWork() argument
51 loop, work, [](uv_work_t* work) { in ExcuteWork()
119 uv_loop_s* loop = nullptr; in OnZipUnZipFinish() local
120 napi_get_uv_event_loop(env_, &loop); in OnZipUnZipFinish()
121 if (loop == nullptr) { in OnZipUnZipFinish()
122 APP_LOGE("loop is nullptr"); in OnZipUnZipFinish()
152 int32_t ret = ExcuteWork(loop, work); in OnZipUnZipFinish()
/foundation/resourceschedule/ffrt/benchmarks/
H A Dcommon.h101 uint32_t loop = count; in completely_paralle() local
103 while (loop--) { in completely_paralle()
113 uint32_t loop = count; in completely_serial() local
115 while (loop--) { in completely_serial()
123 uint32_t loop = count; in single_thread() local
125 while (loop--) { in single_thread()

Completed in 9 milliseconds

12345678910>>...13