Home
last modified time | relevance | path

Searched refs:looper (Results 1 - 25 of 88) sorted by relevance

1234

/foundation/communication/dsoftbus/core/common/message_handler/
H A Dmessage_handler.c44 volatile unsigned char stop; // destroys looper, stop =1, and running =0
92 SoftBusLooper *looper = arg; in LoopTask() local
93 SoftBusLooperContext *context = looper->context; in LoopTask()
142 if (looper->dumpable) { in LoopTask()
161 if (looper->dumpable) { in LoopTask()
173 if (looper->dumpable) { in LoopTask()
197 static int StartNewLooperThread(SoftBusLooper *looper) in StartNewLooperThread() argument
211 threadAttr.taskName = looper->context->name; in StartNewLooperThread()
213 int32_t ret = SoftBusThreadCreate(&tid, &threadAttr, LoopTask, looper); in StartNewLooperThread()
219 COMM_LOGI(COMM_UTILS, "loop thread creating. name=%{public}s, tid=%{public}d", looper in StartNewLooperThread()
248 DumpLooper(const SoftBusLooper *looper) DumpLooper() argument
263 PostMessageAtTimeParamVerify(const SoftBusLooper *looper, SoftBusMessage *msgPost) PostMessageAtTimeParamVerify() argument
289 PostMessageAtTime(const SoftBusLooper *looper, SoftBusMessage *msgPost) PostMessageAtTime() argument
342 LooperPostMessage(const SoftBusLooper *looper, SoftBusMessage *msg) LooperPostMessage() argument
356 LooperPostMessageDelay(const SoftBusLooper *looper, SoftBusMessage *msg, uint64_t delayMillis) LooperPostMessageDelay() argument
379 LoopRemoveMessageCustom(const SoftBusLooper *looper, const SoftBusHandler *handler, int (*customFunc)(const SoftBusMessage*, void*), void *args) LoopRemoveMessageCustom() argument
409 LooperRemoveMessage(const SoftBusLooper *looper, const SoftBusHandler *handler, int32_t what) LooperRemoveMessage() argument
414 SetLooperDumpable(SoftBusLooper *looper, bool dumpable) SetLooperDumpable() argument
436 SoftBusLooper *looper = (SoftBusLooper *)SoftBusCalloc(sizeof(SoftBusLooper)); CreateNewLooper() local
480 SoftBusLooper *looper; global() member
500 SetLooper(int type, SoftBusLooper *looper) SetLooper() argument
510 ReleaseLooper(const SoftBusLooper *looper) ReleaseLooper() argument
521 DestroyLooper(SoftBusLooper *looper) DestroyLooper() argument
574 SoftBusLooper *looper = CreateNewLooper("BusCenter_Lp"); LooperInit() local
[all...]
/foundation/communication/dsoftbus/core/common/include/
H A Dmessage_handler.h34 void (*PostMessage)(const SoftBusLooper *looper, SoftBusMessage *msg);
35 void (*PostMessageDelay)(const SoftBusLooper *looper, SoftBusMessage *msg, uint64_t delayMillis);
36 void (*RemoveMessage)(const SoftBusLooper *looper, const SoftBusHandler *handler, int32_t what);
38 void (*RemoveMessageCustom)(const SoftBusLooper *looper, const SoftBusHandler *handler,
44 SoftBusLooper *looper; member
68 SoftBusLooper *GetLooper(int looper);
72 void SetLooper(int type, SoftBusLooper *looper);
76 void DumpLooper(const SoftBusLooper *looper);
80 void DestroyLooper(SoftBusLooper *looper);
82 void SetLooperDumpable(SoftBusLooper *looper, boo
[all...]
/foundation/communication/dsoftbus/core/bus_center/utils/src/
H A Dlnn_async_callback_utils.c62 LNN_LOGE(LNN_STATE, "fail: looper or callback is null"); in FreeAsyncCallbackMessage()
77 static void InitAsyncCallbackHandler(SoftBusHandler *handler, SoftBusLooper *looper) in InitAsyncCallbackHandler() argument
80 handler->looper = looper; in InitAsyncCallbackHandler()
84 static AsyncCallbackInfo *CreateAsyncCallbackInfo(SoftBusLooper *looper, in CreateAsyncCallbackInfo() argument
96 InitAsyncCallbackHandler(&info->handler, looper); in CreateAsyncCallbackInfo()
101 int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) in LnnAsyncCallbackHelper() argument
105 if (looper == NULL || callback == NULL) { in LnnAsyncCallbackHelper()
106 LNN_LOGE(LNN_STATE, "fail: looper or callback is null"); in LnnAsyncCallbackHelper()
109 info = CreateAsyncCallbackInfo(looper, callbac in LnnAsyncCallbackHelper()
118 LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para, uint64_t delayMillis) LnnAsyncCallbackDelayHelper() argument
[all...]
H A Dlnn_state_machine.c185 if (fsm->looper != NULL && fsm->looper->RemoveMessageCustom != NULL) { in ProcessDeinitMessage()
186 fsm->looper->RemoveMessageCustom(fsm->looper, &fsm->handler, RemoveAllMessageFunc, NULL); in ProcessDeinitMessage()
231 if (fsm->looper->PostMessage == NULL) { in PostMessageToFsm()
235 fsm->looper->PostMessage(fsm->looper, msg); in PostMessageToFsm()
256 int32_t LnnFsmInit(FsmStateMachine *fsm, SoftBusLooper *looper, char *name, FsmDeinitCallback cb) in LnnFsmInit() argument
264 fsm->looper = looper in LnnFsmInit()
[all...]
/foundation/communication/dsoftbus/tests/core/common/message_handler/unittest/
H A Dmessage_handler_test.c51 g_networkingHandler.looper = GetLooper(LOOP_TYPE_DEFAULT); in TestMessageHandler()
62 g_networkingHandler.looper->PostMessage(g_networkingHandler.looper, msg); in TestMessageHandler()
78 g_networkingHandler.looper->PostMessageDelay(g_networkingHandler.looper, msg4, CASE_FOUR_POST_DELAY); in TestMessageHandler()
88 g_networkingHandler.looper->PostMessageDelay(g_networkingHandler.looper, msg3, CASE_THREE_POST_DELAY); in TestMessageHandler()
89 g_networkingHandler.looper->RemoveMessage(g_networkingHandler.looper, &g_networkingHandler, CASE_THREE_WHAT); in TestMessageHandler()
99 g_networkingHandler.looper in TestMessageHandler()
[all...]
/foundation/communication/dsoftbus/tests/core/common/message_handler/fuzztest/messagehandler_fuzzer/
H A Dmessagehandler_fuzzer.cpp27 SoftBusLooper *looper = GetLooper(LOOP_TYPE_DEFAULT); in DoMessageHandlerFuzz() local
28 SetLooper(LOOP_TYPE_DEFAULT, looper); in DoMessageHandlerFuzz()
29 SetLooperDumpable(looper, true); in DoMessageHandlerFuzz()
30 DumpLooper(looper); in DoMessageHandlerFuzz()
31 DestroyLooper(looper); in DoMessageHandlerFuzz()
/foundation/communication/dsoftbus/tests/adapter/common/src/
H A Dlnn_wifiservice_monitor_mock.cpp41 SoftBusLooper *GetLooper(int32_t looper) in GetLooper() argument
43 return GetLnnWifiServiceMonitorInterface()->GetLooper(looper); in GetLooper()
51 int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) in LnnAsyncCallbackHelper() argument
53 return GetLnnWifiServiceMonitorInterface()->LnnAsyncCallbackHelper(looper, callback, para); in LnnAsyncCallbackHelper()
66 int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, in LnnAsyncCallbackDelayHelper() argument
69 return GetLnnWifiServiceMonitorInterface()->LnnAsyncCallbackDelayHelper(looper, callback, para, delayMillis); in LnnAsyncCallbackDelayHelper()
/foundation/communication/dsoftbus/core/common/dfx/hisysevent_adapter/
H A Dsoftbus_hisysevt_common.c90 static inline SoftBusHandler* CreateHandler(SoftBusLooper *looper, HandleMessageFunc callback) in CreateHandler() argument
97 handler->looper = looper; in CreateHandler()
104 static SoftBusMessage* CreateMessage(SoftBusLooper *looper, HandleMessageFunc callback) in CreateMessage() argument
111 SoftBusHandler *handler = CreateHandler(looper, callback); in CreateMessage()
121 static int32_t CreateAndPostMsgDelay(SoftBusLooper *looper, HandleMessageFunc callback, in CreateAndPostMsgDelay() argument
124 if ((looper == NULL) || (callback == NULL)) { in CreateAndPostMsgDelay()
129 SoftBusMessage *message = CreateMessage(looper, callback); in CreateAndPostMsgDelay()
135 looper->PostMessageDelay(looper, messag in CreateAndPostMsgDelay()
[all...]
/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/include/
H A Dlnn_async_callback_mock.h28 virtual int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) = 0;
29 virtual int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback,
38 MOCK_METHOD3(LnnAsyncCallbackHelper, int32_t(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para));
39 MOCK_METHOD4(LnnAsyncCallbackDelayHelper, int32_t(SoftBusLooper *looper, LnnAsyncCallbackFunc callback,
/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/src/
H A Dlnn_async_callback_mock.cpp40 int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) in LnnAsyncCallbackHelper() argument
42 return GetAsyncInterface()->LnnAsyncCallbackHelper(looper, callback, para); in LnnAsyncCallbackHelper()
45 int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, in LnnAsyncCallbackDelayHelper() argument
48 return GetAsyncInterface()->LnnAsyncCallbackDelayHelper(looper, callback, para, delayMillis); in LnnAsyncCallbackDelayHelper()
/foundation/communication/dsoftbus/tests/core/adapter/unittest/
H A Dlnn_settingdata_event_monitor_deps_mock.cpp40 SoftBusLooper *GetLooper(int32_t looper) in GetLooper() argument
42 return GetSettingDataEventMonitorDepsInterface()->GetLooper(looper); in GetLooper()
45 int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) in LnnAsyncCallbackHelper() argument
47 return GetSettingDataEventMonitorDepsInterface()->LnnAsyncCallbackHelper(looper, callback, para); in LnnAsyncCallbackHelper()
H A Dlnn_settingdata_event_monitor_deps_mock.h32 virtual SoftBusLooper *GetLooper(int32_t looper) = 0;
33 virtual int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) = 0;
/foundation/communication/dsoftbus/core/bus_center/service/src/
H A Dbus_center_manager.c153 SoftBusLooper *looper = GetLooper(LOOP_TYPE_DEFAULT); in BusCenterServerDelayInit() local
154 ret = LnnAsyncCallbackDelayHelper(looper, BusCenterServerDelayInit, NULL, g_lnnLocalConfigInit.delayLen); in BusCenterServerDelayInit()
175 LNN_LOGE(LNN_INIT, "init lnn looper fail"); in BusCenterServerInitFirstStep()
240 SoftBusLooper *looper = CreateNewLooper("Lnn_Lp"); in LnnInitLnnLooper() local
241 if (!looper) { in LnnInitLnnLooper()
245 SetLooper(LOOP_TYPE_LNN, looper); in LnnInitLnnLooper()
252 SoftBusLooper *looper = GetLooper(LOOP_TYPE_LNN); in LnnDeinitLnnLooper() local
253 if (looper != NULL) { in LnnDeinitLnnLooper()
254 DestroyLooper(looper); in LnnDeinitLnnLooper()
H A Dbus_center_event.c69 if (g_notifyHandler.looper == NULL) { in PostMessageToHandlerDelay()
74 if (g_notifyHandler.looper->PostMessage == NULL || g_notifyHandler.looper->PostMessageDelay == NULL) { in PostMessageToHandlerDelay()
75 LNN_LOGE(LNN_EVENT, "invalid looper"); in PostMessageToHandlerDelay()
80 g_notifyHandler.looper->PostMessage(g_notifyHandler.looper, msg); in PostMessageToHandlerDelay()
82 g_notifyHandler.looper->PostMessageDelay(g_notifyHandler.looper, msg, delayMillis); in PostMessageToHandlerDelay()
89 if (g_notifyHandler.looper == NULL) { in RemoveNotifyMessage()
90 LNN_LOGE(LNN_EVENT, "looper no in RemoveNotifyMessage()
781 SoftBusLooper *looper = CreateNewLooper("Notify_Lp"); LnnInitBusCenterEvent() local
[all...]
/foundation/communication/dsoftbus/core/common/dfx/hidumper_adapter/
H A Dsoftbus_hidumper_broadcast.c63 g_bcDumphandler.looper->PostMessageDelay(g_bcDumphandler.looper, msg, delayMillis); in ExecuteBroadcastTask()
76 COMM_LOGE(COMM_DFX, "init looper fail"); in SoftbusRegBroadcastDumpTask()
86 g_bcDumphandler.looper->PostMessageDelay(g_bcDumphandler.looper, msg, delayMillis); in SoftbusRegBroadcastDumpTask()
153 if (g_bcDumphandler.looper != NULL) { in SoftbusBroadcastDumpLooperInit()
154 COMM_LOGI(COMM_DFX, "looper already inited"); in SoftbusBroadcastDumpLooperInit()
157 g_bcDumphandler.looper = GetLooper(LOOP_TYPE_DEFAULT); in SoftbusBroadcastDumpLooperInit()
158 if (g_bcDumphandler.looper == NULL) { in SoftbusBroadcastDumpLooperInit()
159 COMM_LOGE(COMM_DFX, "get looper fai in SoftbusBroadcastDumpLooperInit()
[all...]
/foundation/communication/dsoftbus/tests/adapter/common/include/
H A Dlnn_wifiservice_monitor_mock.h32 virtual SoftBusLooper *GetLooper(int32_t looper) = 0;
34 virtual int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para) = 0;
37 virtual int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback,
/foundation/communication/dsoftbus/tests/core/bus_center/service/unittest/
H A Dbus_center_manager_deps_mock.cpp45 SoftBusLooper *GetLooper(int32_t looper) in GetLooper() argument
47 return GetBusCenterManagerDepsInterface()->GetLooper(looper); in GetLooper()
120 int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, in LnnAsyncCallbackDelayHelper() argument
123 return GetBusCenterManagerDepsInterface()->LnnAsyncCallbackDelayHelper(looper, callback, para, delayMillis); in LnnAsyncCallbackDelayHelper()
/foundation/communication/dsoftbus/core/bus_center/utils/include/
H A Dlnn_async_callback_utils.h29 int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void *para);
30 int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback,
/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_common.c55 if (g_authHandler.looper == NULL || g_authHandler.looper->PostMessage == NULL || in IsAuthHandlerInit()
56 g_authHandler.looper->PostMessageDelay == NULL || g_authHandler.looper->RemoveMessageCustom == NULL) { in IsAuthHandlerInit()
118 g_authHandler.looper->PostMessage(g_authHandler.looper, msg); in PostAuthEvent()
120 g_authHandler.looper->PostMessageDelay(g_authHandler.looper, msg, delayMs); in PostAuthEvent()
151 g_authHandler.looper->RemoveMessageCustom(g_authHandler.looper, in RemoveAuthEvent()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/draw/
H A Dcore_canvas.cpp56 std::shared_ptr looper = paintPen_.GetLooper(); \
57 if (looper != nullptr) { \
61 impl_->Translate(looper->GetXOffset(), looper->GetYOffset()); \
70 std::shared_ptr looper = paintBrush_.GetLooper(); \
71 if (looper != nullptr) { \
75 impl_->Translate(looper->GetXOffset(), looper->GetYOffset()); \
82 std::shared_ptr looper = paintPen_.GetLooper(); \
83 if (looper !
99 std::shared_ptr looper = paint.GetLooper(); GetLooperPaint() local
[all...]
/foundation/communication/dsoftbus/adapter/common/bus_center/common_event/
H A Dlnn_common_event_monitor.cpp148 SoftBusLooper *looper = GetLooper(LOOP_TYPE_DEFAULT); in LnnSubscribeCommonEvent() local
149 if (LnnAsyncCallbackDelayHelper(looper, LnnSubscribeCommonEvent, NULL, DELAY_LEN) != SOFTBUS_OK) { in LnnSubscribeCommonEvent()
159 SoftBusLooper *looper = GetLooper(LOOP_TYPE_DEFAULT); in LnnInitCommonEventMonitorImpl() local
160 int32_t ret = LnnAsyncCallbackHelper(looper, LnnSubscribeCommonEvent, NULL); in LnnInitCommonEventMonitorImpl()
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/
H A Dlnn_lane_link_conflict.c61 if (g_linkConflictLoopHandler.looper == NULL) { in LinkConflictPostMsgToHandler()
62 LNN_LOGE(LNN_LANE, "linkConflictLoopHandler looper not init"); in LinkConflictPostMsgToHandler()
72 g_linkConflictLoopHandler.looper->PostMessage(g_linkConflictLoopHandler.looper, msg); in LinkConflictPostMsgToHandler()
74 g_linkConflictLoopHandler.looper->PostMessageDelay(g_linkConflictLoopHandler.looper, msg, delayMillis); in LinkConflictPostMsgToHandler()
151 g_linkConflictLoopHandler.looper->RemoveMessageCustom(g_linkConflictLoopHandler.looper, in RemoveConflictInfoTimelinessMsg()
457 g_linkConflictLoopHandler.looper = GetLooper(LOOP_TYPE_LNN); in InitLinkConflictLooper()
458 if (g_linkConflictLoopHandler.looper in InitLinkConflictLooper()
[all...]
/foundation/communication/dsoftbus/tests/core/connection/ble/mock/
H A Dconnection_ble_manager_mock.cpp190 int32_t ConnGattInitClientModule(SoftBusLooper *looper, const ConnBleClientEventListener *listener) in ConnGattInitClientModule() argument
192 return GetConnectionBleInterface()->ConnGattInitClientModule(looper, listener); in ConnGattInitClientModule()
195 int32_t ConnGattInitServerModule(SoftBusLooper *looper, const ConnBleServerEventListener *listener) in ConnGattInitServerModule() argument
197 return GetConnectionBleInterface()->ConnGattInitServerModule(looper, listener); in ConnGattInitServerModule()
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_pipeline.c70 SoftBusLooper *looper; member
77 .looper = NULL,
226 g_manager.looper->PostMessage(g_manager.looper, msg); in TransProxyPipelineOpenChannel()
339 g_manager.looper->PostMessageDelay(g_manager.looper, msg, DELAY_CLOSE_CHANNEL_MS); in TransProxyPipelineCloseChannelDelay()
395 g_manager.looper->PostMessage(g_manager.looper, msg); in TransProxyPipelineOnChannelOpened()
461 g_manager.looper->PostMessage(g_manager.looper, ms in TransProxyPipelineOnChannelOpenFailed()
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/time_sync/src/
H A Dlnn_time_sync_manager.c60 SoftBusLooper *looper; member
464 g_timeSyncCtrl.looper->PostMessage(g_timeSyncCtrl.looper, msg); in PostMessageToHandler()
508 g_timeSyncCtrl.looper = GetLooper(LOOP_TYPE_DEFAULT); in LnnInitTimeSync()
509 if (g_timeSyncCtrl.looper == NULL) { in LnnInitTimeSync()
510 LNN_LOGE(LNN_INIT, "time sync get default looper fail"); in LnnInitTimeSync()
514 g_timeSyncCtrl.handler.looper = g_timeSyncCtrl.looper; in LnnInitTimeSync()
526 if (g_timeSyncCtrl.looper == NULL) { in LnnDeinitTimeSync()
546 if (g_timeSyncCtrl.looper in LnnStartTimeSync()
[all...]

Completed in 12 milliseconds

1234