Home
last modified time | relevance | path

Searched refs:loop (Results 1 – 25 of 699) sorted by relevance

12345678910>>...28

/ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/ipc_framework/cRPC/unittest/
H A Dserver_test.cpp55 EventLoop loop; variable
65 EventLoop loop; variable
76 EventLoop loop; variable
88 EventLoop loop; variable
101 EventLoop loop; variable
117 EventLoop loop; variable
130 EventLoop loop; variable
173 loop.stop = 0;
175 server.loop = &loop;
185 loop.stop = 0;
[all …]
/ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/wifi_base/
H A Dserver_test.cpp55 EventLoop loop; variable
65 EventLoop loop; variable
76 EventLoop loop; variable
88 EventLoop loop; variable
101 EventLoop loop; variable
117 EventLoop loop; variable
130 EventLoop loop; variable
173 loop.stop = 0;
175 server.loop = &loop;
185 loop.stop = 0;
[all …]
/ohos5.0/base/startup/init/services/loopevent/loop/
H A Dle_loop.c60 (*loop)->timeout = timeout; in CreateLoop_()
61 (*loop)->stop = 0; in CreateLoop_()
82 if (!loop->stop) { in CloseLoop()
85 OH_HashMapDestory(loop->taskMap, loop); in CloseLoop()
86 if (loop->close) { in CloseLoop()
87 loop->close(loop); in CloseLoop()
98 loop->delEvent(loop, fd, EVENT_READ | EVENT_WRITE); in ProcessEvent()
131 loop->delEvent(loop, task->taskId.fd, in DelTask()
150 EventLoop *loop = NULL; in LE_CreateLoop() local
160 loop->runLoop(loop); in LE_RunLoop()
[all …]
H A Dle_epoll.c22 static int IsValid_(const EventEpoll *loop) in IsValid_() argument
24 return loop->epollFd >= 0; in IsValid_()
135 if (loop->stop) { in RunLoop_()
151 *loop = (EventLoop *)epoll; in CreateEpollLoop()
152 epoll->loop.maxevents = maxevents; in CreateEpollLoop()
153 epoll->loop.timeout = timeout; in CreateEpollLoop()
154 epoll->loop.close = Close_; in CreateEpollLoop()
155 epoll->loop.runLoop = RunLoop_; in CreateEpollLoop()
156 epoll->loop.delEvent = DelEvent_; in CreateEpollLoop()
157 epoll->loop.addEvent = AddEvent_; in CreateEpollLoop()
[all …]
H A Dle_loop.h32 LE_STATUS (*close)(const struct EventLoop_ *loop);
33 LE_STATUS (*runLoop)(const struct EventLoop_ *loop);
34 LE_STATUS (*addEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
35 LE_STATUS (*modEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
36 LE_STATUS (*delEvent)(const struct EventLoop_ *loop, int fd, int op);
52 LE_STATUS CloseLoop(EventLoop *loop);
53 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
54 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
55 void DelTask(EventLoop *loop, BaseTask *task);
56 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper);
/ohos5.0/foundation/communication/wifi/wifi/base/cRPC/src/
H A Devloop.c78 if (loop == NULL) { in DestroyEventLoop()
83 close(loop->epfd); in DestroyEventLoop()
91 free(loop); in DestroyEventLoop()
92 loop = NULL; in DestroyEventLoop()
98 if (loop == NULL) { in StopEventLoop()
102 loop->stop = 1; in StopEventLoop()
108 if (loop == NULL) { in AddFdEvent()
134 loop->maxFd = fd; in AddFdEvent()
141 if (loop == NULL) { in DelFdEvent()
169 if (fd == loop->maxFd && loop->fdMasks[fd].mask == NONE_EVENT) { in DelFdEvent()
[all …]
H A Dserver.c93 if (server->loop == NULL) { in CreateRpcServer()
128 AddFdEvent(server->loop, client->fd, WRIT_EVENT); in DealReadMessage()
163 DelFdEvent(server->loop, client->fd, READ_EVENT); in DealFdReadEvent()
187 DelFdEvent(server->loop, client->fd, WRIT_EVENT); in DealFdWriteEvent()
208 if (server->loop->fdMasks[fd].mask == NONE_EVENT) { in DealFdEvents()
223 EventLoop *loop = server->loop; in RunRpcLoop() local
224 while (!loop->stop) { in RunRpcLoop()
227 int retval = epoll_wait(loop->epfd, loop->epEvents, loop->setSize, -1); in RunRpcLoop()
230 struct epoll_event *e = loop->epEvents + i; in RunRpcLoop()
249 if (server->loop != NULL) { in ReleaseRpcServer()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Devent_impl.cpp121 loop->IncObjRef(loop); in AddEvents()
125 loop->DecObjRef(loop); in AddEvents()
152 loop->IncObjRef(loop); in RemoveEvents()
156 loop->DecObjRef(loop); in RemoveEvents()
177 loop->IncObjRef(loop); in SetTimeout()
181 loop->DecObjRef(loop); in SetTimeout()
197 loop->IncObjRef(loop); in Detach()
210 loop->DecObjRef(loop); in Detach()
214 loop->DecObjRef(loop); in Detach()
267 loop->IncObjRef(loop); in SetLoop()
[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()
/ohos5.0/docs/zh-cn/application-dev/reference/native-lib/
H A Dlibuv.md464 根据loop来源的不同，可分为两种情况，即开发者创建loop和从env获取loop。
468 …w`创建loop或者`uv_loop_init`接口初始化loop，loop的生命周期由开发者自行维护。在这种情况下，如前文所述，需要保证`uv_run`执行在与创建/初始化loop操作相同的线程…
484 auto loop = handle->loop;
503 // 开发者自己创建loop，请注意维护loop的生命周期
611 对loop进行初始化。
617 关闭loop，该函数只有在loop中所有的句柄和请求都关闭后才能成功返回，否则将返回UV_EBUSY。
623 …loop，该接口会先调用`uv_loop_close`，然后再将loop释放掉。在OpenHarmony平台上，由于assert函数不生效，因此不论`uv_loop_close`函数是否成功清理l…
629 …该函数创建一个进程级的loop。在OpenHarmony中，由于目前的应用主循环及其他js工作线程还存在着libuv的loop。因此我们不建议开发者使用该函数来创建loop并实现业务功能。在系统的…
726 > 2. 所有的handle操作都不能通过获取其他线程loop的方式，在非loop线程上调用。
946 auto loop = handle->loop;
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dloop_api.cpp42 int ffrt_loop_destroy(ffrt_loop_t loop)
45 Loop* innerLoop = static_cast<Loop*>(loop);
51 int ffrt_loop_run(ffrt_loop_t loop)
54 Loop* innerLoop = static_cast<Loop*>(loop);
61 void ffrt_loop_stop(ffrt_loop_t loop)
63 FFRT_COND_DO_ERR((loop == nullptr), return, "input invalid, loop is nullptr");
64 Loop* innerLoop = static_cast<Loop*>(loop);
72 Loop* innerLoop = static_cast<Loop*>(loop);
80 Loop* innerLoop = static_cast<Loop*>(loop);
85 int ffrt_loop_timer_stop(ffrt_loop_t loop, ffrt_timer_t handle)
[all …]
/ohos5.0/docs/en/application-dev/reference/apis-ffrt-kit/
H A Dloop_8h.md1 # loop.h
6 The **loop.h** file declares the FFRT loop interfaces in C.
29 …loop_create](_f_f_r_t.md#ffrt_loop_create) ([ffrt_queue_t](_f_f_r_t.md) queue) | Creates a loop. |
30 …API int [ffrt_loop_destroy](_f_f_r_t.md#ffrt_loop_destroy) (ffrt_loop_t loop) | Destroys a loop. |
31 | FFRT_C_API int [ffrt_loop_run](_f_f_r_t.md#ffrt_loop_run) (ffrt_loop_t loop) | Runs a loop. |
32 | FFRT_C_API void [ffrt_loop_stop](_f_f_r_t.md#ffrt_loop_stop) (ffrt_loop_t loop) | Stops a loop. |
33 …_loop_t loop, int op, int fd, uint32_t events, void\* data, [ffrt_poller_cb](_f_f_r_t.md#ffrt_poll…
34 … (ffrt_loop_t loop, uint64_t timeout, void\* data, [ffrt_timer_cb](_f_f_r_t.md#ffrt_timer_cb) cb, …
35 …ffrt_loop_timer_stop) (ffrt_loop_t loop, [ffrt_timer_t](_f_f_r_t.md#ffrt_timer_t) handle) | Stops …
/ohos5.0/docs/zh-cn/application-dev/reference/apis-ffrt-kit/
H A Dloop_8h.md1 # loop.h
29 …ffrt_loop_create](_f_f_r_t.md#ffrt_loop_create) ([ffrt_queue_t](_f_f_r_t.md) queue) | 创建loop队列。 |
30 | FFRT_C_API int [ffrt_loop_destroy](_f_f_r_t.md#ffrt_loop_destroy) (ffrt_loop_t loop) | 销毁loop队对象。…
31 | FFRT_C_API int [ffrt_loop_run](_f_f_r_t.md#ffrt_loop_run) (ffrt_loop_t loop) | 开启loop循环。 |
32 | FFRT_C_API void [ffrt_loop_stop](_f_f_r_t.md#ffrt_loop_stop) (ffrt_loop_t loop) | 停止loop循环。 |
33 …oll_ctl) (ffrt_loop_t loop, int op, int fd, uint32_t events, void\* data, [ffrt_poller_cb](_f_f_r_…
34 …r_start) (ffrt_loop_t loop, uint64_t timeout, void\* data, [ffrt_timer_cb](_f_f_r_t.md#ffrt_timer_…
35 …r_t.md#ffrt_loop_timer_stop) (ffrt_loop_t loop, [ffrt_timer_t](_f_f_r_t.md#ffrt_timer_t) handle) |…
H A D_f_f_r_t.md530 创建loop队列。
553 销毁loop队对象。
561 | loop | loop对象。 |
576 管理loop上的监听事件。
584 | loop | loop对象。 |
604 开启loop循环。
612 | loop | loop对象。 |
627 停止loop循环。
635 | loop | loop对象。 |
654 | loop | loop对象。 |
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_loop.cpp66 auto loop = ffrt_loop_create(nullptr); variable
67 EXPECT_EQ(loop, nullptr);
84 auto loop = ffrt_loop_create(queue_handle); variable
85 EXPECT_EQ(loop, nullptr);
105 auto loop = ffrt_loop_create(queue_handle); variable
106 EXPECT_NE(loop, nullptr);
108 int ret = ffrt_loop_destroy(loop);
135 EXPECT_EQ(loop, nullptr);
183 EXPECT_NE(loop, nullptr);
188 ffrt_loop_stop(loop);
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/
H A Devent_logger_plugin_test.cpp67 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); variable
68 loop->StartLoop();
69 eventLogger.BindWorkLoop(loop);
82 loop->StartLoop();
83 eventLogger.BindWorkLoop(loop);
98 loop->StartLoop();
99 eventLogger.BindWorkLoop(loop);
115 loop->StartLoop();
116 eventLogger.BindWorkLoop(loop);
134 loop->StartLoop();
[all …]
/ohos5.0/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() local
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; idx++) { in DisplayCaseLayer()
69 out.append("|--").append(curlayerInfo[loop]); in DisplayCaseLayer()
86 for (uint32_t loop = 0; loop < info.size(); loop++) { in DisplayAllCaseInfo() local
87 string filePath = info[loop]->filePath; in DisplayAllCaseInfo()
98 curlayerInfo.push_back(info[loop]->testCaseName); in DisplayAllCaseInfo()
[all …]
/ohos5.0/docs/zh-cn/third-party-cases/
H A Dapp_quality_improvement_cases_about_crash.md11 1.打印提示Crash，每次Crash的进程一致，均是Process name:com.chinasoftinc.launcher， 线程却不确定，mosquitto loop、jsThread-1…
15 mosquitto loop、jsThread-1 二者crash随机出现
19 mosquitto loop crash：
37 虽然每次crash的线程不一样，但范围是确定的，jsThread-1 或者 mosquitto loop，可以确定是两个线程交互的问题。
41 mosquitto loop是用来监听mosquitto服务器是否有消息上来，有则触发JS Function回调函数；
47 1. jsThread-1线程运行时，mosquitto loop消息上来直接触发回调，会导致jsThread-1异常退出；
49 2. mosquitto loop处理回调时，jsThread-1可能直接抢占处理，导致mosquitto loop异常退出。
55 …pi_get_uv_event_loop，但只能在JS主线程中使用，uv_queue_work只能处理napi_get_uv_event_loop创建的线程，不支持mosquitto loop方式；
57 若要监听消息，只能用mosquitto loop起新线程监听。
69 修改方案为：保留mosquitto loop获取消息，触发C处理消息上来事件，将原有消息事件处理中 直接调用napi_call_function 的方式改为 napi_get_uv_event_lo…
/ohos5.0/base/startup/init/services/loopevent/timer/
H A Dle_timer.c63 void CheckTimeoutOfTimer(EventLoop *loop, uint64_t currTime) in CheckTimeoutOfTimer() argument
68 ListNode *node = loop->timerList.next; in CheckTimeoutOfTimer()
69 while (node != &loop->timerList) { in CheckTimeoutOfTimer()
83 node = loop->timerList.next; in CheckTimeoutOfTimer()
99 InsertTimerNode(loop, timer); in CheckTimeoutOfTimer()
137 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartTimer() local
143 InsertTimerNode(loop, timerNode); in LE_StartTimer()
147 uint64_t GetMinTimeoutPeriod(const EventLoop *loop) in GetMinTimeoutPeriod() argument
149 LE_CHECK(loop != NULL, return 0, "Invalid loop"); in GetMinTimeoutPeriod()
150 LE_ONLY_CHECK(loop->timerList.next != &(loop->timerList), return 0); in GetMinTimeoutPeriod()
[all …]
/ohos5.0/docs/en/application-dev/reference/native-lib/
H A Dlibuv.md484 auto loop = handle->loop;
503 // Create a loop and manage the loop lifecycle.
978 auto loop = handle->loop;
1045 - **loop**: pointer to the event loop.
1197 * @param loop indicates the pointer to the event loop.
1225 * @param loop indicates the pointer to the event loop.
1246 * @param loop indicates the pointer to the event loop.
1265 * @param loop indicates the pointer to the event loop.
1284 * @param loop indicates the pointer to the event loop.
1305 * @param loop indicates the pointer to the event loop.
[all …]
/ohos5.0/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); \
/ohos5.0/base/print/print_fwk/frameworks/kits/extension/src/
H A Djs_print_callback.cpp42 uv_loop_s* loop = nullptr; in GetJsLoop() local
43 napi_get_uv_event_loop(env, &loop); in GetJsLoop()
44 if (loop == nullptr) { in GetJsLoop()
47 return loop; in GetJsLoop()
52 uv_loop_s *loop = nullptr; in Call() local
53 napi_get_uv_event_loop(env, &loop); in Call()
54 if (loop == nullptr) { in Call()
114 uv_loop_s *loop = GetJsLoop(jsRuntime_); in Exec() local
115 if (loop == nullptr) { in Exec()
125 if (UvQueueWork(loop, worker) != 0) { in Exec()
[all …]
/ohos5.0/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()
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()
137 uv_loop_s* loop = nullptr; in OnBundleUpdated() local
138 napi_get_uv_event_loop(env_, &loop); in OnBundleUpdated()
157 if (loop == nullptr) { in OnBundleUpdated()
206 uv_loop_s* loop = nullptr; in OnBundleRemoved() local
207 napi_get_uv_event_loop(env_, &loop); in OnBundleRemoved()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/interfaces/kits/c/
H A Dloop.h44 FFRT_C_API int ffrt_loop_destroy(ffrt_loop_t loop);
55 FFRT_C_API int ffrt_loop_run(ffrt_loop_t loop);
64 FFRT_C_API void ffrt_loop_stop(ffrt_loop_t loop);
80 FFRT_C_API int ffrt_loop_epoll_ctl(ffrt_loop_t loop, int op, int fd, uint32_t events, void *data, f…
95 ffrt_loop_t loop, uint64_t timeout, void* data, ffrt_timer_cb cb, bool repeat);
107 FFRT_C_API int ffrt_loop_timer_stop(ffrt_loop_t loop, ffrt_timer_t handle);
/ohos5.0/drivers/hdf_core/framework/core/manager/test/unittest/common/
H A Dhdf_sbuf_test.cpp333 int loop = DEFAULT_LOOP_COUNT; variable
366 int loop = DEFAULT_LOOP_COUNT; variable
399 int loop = DEFAULT_LOOP_COUNT; variable
432 int loop = DEFAULT_LOOP_COUNT; variable
465 int loop = DEFAULT_LOOP_COUNT; variable
498 int loop = DEFAULT_LOOP_COUNT; variable
531 int loop = DEFAULT_LOOP_COUNT; variable
564 int loop = DEFAULT_LOOP_COUNT; variable
621 int loop = 1; variable
749 int loop = 1; variable
[all …]

12345678910>>...28