| /ohos5.0/foundation/communication/dsoftbus/core/common/message_handler/ |
| H A D | message_handler.c | 250 if (looper == NULL) { in DumpLooper()
270 if (looper == NULL || looper->context == NULL) { in PostMessageAtTimeParamVerify()
348 if (looper == NULL) { in LooperPostMessage()
362 if (looper == NULL) { in LooperPostMessageDelay()
416 if (looper == NULL || looper->context == NULL) { in SetLooperDumpable()
437 if (looper == NULL) { in CreateNewLooper()
475 return looper; in CreateNewLooper()
505 g_loopConfig[i].looper = looper; in SetLooper()
514 if (g_loopConfig[i].looper == looper) { in ReleaseLooper()
566 SoftBusFree(looper); in DestroyLooper()
[all …]
|
| /ohos5.0/drivers/hdf_core/framework/utils/src/ |
| H A D | hdf_message_looper.c | 14 void HdfMessageLooperStart(struct HdfMessageLooper *looper) in HdfMessageLooperStart() argument
17 if (looper == NULL) { in HdfMessageLooperStart()
20 looper->isRunning = true; in HdfMessageLooperStart()
22 message = HdfMessageQueueNext(&looper->messageQueue); in HdfMessageLooperStart()
28 looper->isRunning = false; in HdfMessageLooperStart()
39 void HdfMessageLooperStop(struct HdfMessageLooper *looper) in HdfMessageLooperStop() argument
41 if (looper == NULL || !looper->isRunning) { in HdfMessageLooperStop()
54 if (looper != NULL) { in HdfMessageLooperConstruct()
55 OsalMessageQueueInit(&looper->messageQueue); in HdfMessageLooperConstruct()
56 looper->Start = HdfMessageLooperStart; in HdfMessageLooperConstruct()
[all …]
|
| H A D | hdf_message_task.c | 50 struct HdfMessageLooper *looper, struct IHdfMessageHandler *handler) in HdfMessageTaskConstruct() argument
52 if (inst != NULL && looper != NULL) { in HdfMessageTaskConstruct()
55 inst->messageQueue = &looper->messageQueue; in HdfMessageTaskConstruct()
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/utils/src/ |
| H A D | lnn_async_callback_utils.c | 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()
105 if (looper == NULL || callback == NULL) { in LnnAsyncCallbackHelper()
109 info = CreateAsyncCallbackInfo(looper, callback, para, LNN_ASYNC_CALLBACK_REG); in LnnAsyncCallbackHelper()
114 looper->PostMessage(looper, &info->msg); in LnnAsyncCallbackHelper()
118 int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, in LnnAsyncCallbackDelayHelper() argument
123 if (looper == NULL || callback == NULL) { in LnnAsyncCallbackDelayHelper()
127 info = CreateAsyncCallbackInfo(looper, callback, para, LNN_ASYNC_CALLBACK_REG); in LnnAsyncCallbackDelayHelper()
[all …]
|
| H A D | lnn_state_machine.c | 185 if (fsm->looper != NULL) { in ProcessDeinitMessage()
186 fsm->looper->RemoveMessageCustom(fsm->looper, &fsm->handler, RemoveAllMessageFunc, NULL); in ProcessDeinitMessage()
231 fsm->looper->PostMessage(fsm->looper, msg); in PostMessageToFsm()
260 fsm->looper = looper == NULL ? GetLooper(LOOP_TYPE_DEFAULT) : looper; in LnnFsmInit()
261 if (fsm->looper == NULL) { in LnnFsmInit()
267 fsm->handler.looper = fsm->looper; in LnnFsmInit()
274 if (fsm == NULL || fsm->looper == NULL) { in LnnFsmDeinit()
332 fsm->looper->PostMessageDelay(fsm->looper, msg, delayMillis); in LnnFsmPostMessageDelay()
341 fsm->looper->RemoveMessage(fsm->looper, &fsm->handler, what); in LnnFsmRemoveMessageByType()
350 fsm->looper->RemoveMessageCustom(fsm->looper, &fsm->handler, in LnnFsmRemoveMessage()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/include/ |
| H A D | message_handler.h | 34 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, bool dumpable);
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/common/message_handler/unittest/ |
| H A D | message_handler_test.c | 51 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_DELA… in TestMessageHandler()
88 …g_networkingHandler.looper->PostMessageDelay(g_networkingHandler.looper, msg3, CASE_THREE_POST_DEL… in TestMessageHandler()
89 …g_networkingHandler.looper->RemoveMessage(g_networkingHandler.looper, &g_networkingHandler, CASE_T… in TestMessageHandler()
99 g_networkingHandler.looper->PostMessage(g_networkingHandler.looper, msg2); in TestMessageHandler()
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/dfx/hisysevent_adapter/ |
| H A D | softbus_hisysevt_common.c | 90 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, message, delayMillis); in CreateAndPostMsgDelay()
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/manager/ |
| H A D | device_manager.c | 47 struct HdfMessageLooper *looper = &fullService->looper; in main() local
48 if ((looper != NULL) && (looper->Start != NULL)) { in main()
50 looper->Start(looper); in main()
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/host/src/ |
| H A D | hdf_device_thread.c | 73 struct HdfMessageLooper *looper = ¤tThread->looper; in DeviceThreadMain() local
74 if (looper->Start != NULL) { in DeviceThreadMain()
75 looper->Start(looper); in DeviceThreadMain()
86 HdfMessageLooperConstruct(&inst->looper); in DeviceThreadConstruct()
87 HdfMessageTaskConstruct(&inst->task, &inst->looper, &handler); in DeviceThreadConstruct()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/common/message_handler/fuzztest/messagehandler_fuzzer/ |
| H A D | messagehandler_fuzzer.cpp | 27 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()
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/service/src/ |
| H A D | bus_center_manager.c | 153 SoftBusLooper *looper = GetLooper(LOOP_TYPE_DEFAULT); in BusCenterServerDelayInit() local
154 …ret = LnnAsyncCallbackDelayHelper(looper, BusCenterServerDelayInit, NULL, g_lnnLocalConfigInit.del… in BusCenterServerDelayInit()
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 D | bus_center_event.c | 69 if (g_notifyHandler.looper == NULL) { in PostMessageToHandlerDelay()
74 …if (g_notifyHandler.looper->PostMessage == NULL || g_notifyHandler.looper->PostMessageDelay == NUL… 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()
97 g_notifyHandler.looper->RemoveMessage(g_notifyHandler.looper, &g_notifyHandler, what); in RemoveNotifyMessage()
779 if (looper == NULL) { in LnnInitBusCenterEvent()
783 g_notifyHandler.looper = looper; in LnnInitBusCenterEvent()
798 if (g_notifyHandler.looper != NULL) { in LnnDeinitBusCenterEvent()
799 DestroyLooper(g_notifyHandler.looper); in LnnDeinitBusCenterEvent()
[all …]
|
| /ohos5.0/base/hiviewdfx/hiview/base/test/unittest/common/ |
| H A D | plugin_example.cpp | 36 auto looper = std::make_shared<EventLoop>("PluginExample"); in OnLoad() local
37 if (looper != nullptr) { in OnLoad()
38 looper->StartLoop(); in OnLoad()
39 BindWorkLoop(looper); in OnLoad()
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/dfx/hidumper_adapter/ |
| H A D | softbus_hidumper_broadcast.c | 63 g_bcDumphandler.looper->PostMessageDelay(g_bcDumphandler.looper, msg, delayMillis); in ExecuteBroadcastTask()
86 g_bcDumphandler.looper->PostMessageDelay(g_bcDumphandler.looper, msg, delayMillis); in SoftbusRegBroadcastDumpTask()
153 if (g_bcDumphandler.looper != NULL) { in SoftbusBroadcastDumpLooperInit()
157 g_bcDumphandler.looper = GetLooper(LOOP_TYPE_DEFAULT); in SoftbusBroadcastDumpLooperInit()
158 if (g_bcDumphandler.looper == NULL) { in SoftbusBroadcastDumpLooperInit()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/src/ |
| H A D | lnn_async_callback_mock.cpp | 40 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()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/include/ |
| H A D | lnn_async_callback_mock.h | 28 …virtual int32_t LnnAsyncCallbackHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback, void …
29 … virtual int32_t LnnAsyncCallbackDelayHelper(SoftBusLooper *looper, LnnAsyncCallbackFunc callback,
38 …MOCK_METHOD3(LnnAsyncCallbackHelper, int32_t(SoftBusLooper *looper, LnnAsyncCallbackFunc callback,…
39 …MOCK_METHOD4(LnnAsyncCallbackDelayHelper, int32_t(SoftBusLooper *looper, LnnAsyncCallbackFunc call…
|
| /ohos5.0/drivers/hdf_core/framework/test/fuzztest/devicemanagerstart_fuzzer/ |
| H A D | devicemanagerstart_fuzzer.cpp | 48 struct HdfMessageLooper *looper = &fullService->looper; in DeviceManagerStartServiceFuzzTest() local
49 if ((looper != NULL) && (looper->Start != NULL)) { in DeviceManagerStartServiceFuzzTest()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/draw/ |
| H A D | core_canvas.cpp | 56 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(); \
87 impl_->Translate(looper->GetXOffset(), looper->GetYOffset()); \
99 std::shared_ptr looper = paint.GetLooper(); in GetLooperPaint() local
100 looperPaint.SetColor(looper->GetColor()); in GetLooperPaint()
[all …]
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/host/ |
| H A D | devhost.c | 192 struct HdfMessageLooper *looper = &fullService->looper; in main() local
193 if ((looper != NULL) && (looper->Start != NULL)) { in main()
195 looper->Start(looper); in main()
|
| /ohos5.0/foundation/communication/dsoftbus/core/authentication/src/ |
| H A D | auth_common.c | 55 if (g_authHandler.looper == NULL || g_authHandler.looper->PostMessage == NULL || in IsAuthHandlerInit()
56 …g_authHandler.looper->PostMessageDelay == NULL || g_authHandler.looper->RemoveMessageCustom == NUL… 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, &g_authHandler, CustomFunc, &info); in RemoveAuthEvent()
450 g_authHandler.looper = GetLooper(LOOP_TYPE_DEFAULT); in AuthCommonInit()
461 g_authHandler.looper = NULL; in AuthCommonDeinit()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/event_store/store/ |
| H A D | sys_event_db_mgr.cpp | 38 void SysEventDbMgr::StartCheckStoreTask(std::shared_ptr<EventLoop> looper) in StartCheckStoreTask() argument
40 if (looper == nullptr) { in StartCheckStoreTask()
47 looper->AddTimerEvent(nullptr, nullptr, statusTask, delay, true); in StartCheckStoreTask()
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/host/test/unittest/sample_driver/ |
| H A D | sample_hdi_service.cpp | 195 struct HdfMessageLooper *looper = &fullService->looper; in SampleServiceEndHost() local
197 if ((looper != nullptr) && (looper->Stop != nullptr)) { in SampleServiceEndHost()
198 looper->Stop(looper); in SampleServiceEndHost()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
| H A D | softbus_proxychannel_pipeline.c | 70 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, msg); in TransProxyPipelineOnChannelOpenFailed()
661 g_manager.looper = GetLooper(LOOP_TYPE_DEFAULT); in TransProxyPipelineInit()
662 if (g_manager.looper == NULL) { in TransProxyPipelineInit()
666 g_manager.handler.looper = g_manager.looper; in TransProxyPipelineInit()
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/ |
| H A D | lnn_lane_link_conflict.c | 61 if (g_linkConflictLoopHandler.looper == NULL) { in LinkConflictPostMsgToHandler()
72 g_linkConflictLoopHandler.looper->PostMessage(g_linkConflictLoopHandler.looper, msg); in LinkConflictPostMsgToHandler()
74 …g_linkConflictLoopHandler.looper->PostMessageDelay(g_linkConflictLoopHandler.looper, msg, delayMil… in LinkConflictPostMsgToHandler()
151 g_linkConflictLoopHandler.looper->RemoveMessageCustom(g_linkConflictLoopHandler.looper, in RemoveConflictInfoTimelinessMsg()
480 g_linkConflictLoopHandler.looper = GetLooper(LOOP_TYPE_LNN); in InitLinkConflictLooper()
481 if (g_linkConflictLoopHandler.looper == NULL) { in InitLinkConflictLooper()
513 g_linkConflictLoopHandler.looper = NULL; in DeinitLaneLinkConflict()
|