Home
last modified time | relevance | path

Searched refs:SoftBusMessage (Results 1 - 25 of 38) sorted by relevance

12

/foundation/communication/dsoftbus/core/common/include/
H A Dmessage_handler.h26 typedef struct SoftBusMessage SoftBusMessage; typedef
34 void (*PostMessage)(const SoftBusLooper *looper, SoftBusMessage *msg);
35 void (*PostMessageDelay)(const SoftBusLooper *looper, SoftBusMessage *msg, uint64_t delayMillis);
39 int32_t (*)(const SoftBusMessage*, void*), void *args);
45 void (*HandleMessage)(SoftBusMessage *msg);
48 struct SoftBusMessage { struct
55 void (*FreeMessage)(SoftBusMessage *msg);
58 SoftBusMessage *MallocMessage(void);
60 void FreeMessage(SoftBusMessage *ms
[all...]
/foundation/communication/dsoftbus/tests/core/common/message_handler/unittest/
H A Dmessage_handler_test.c31 static void NetworkingHandleMessage(const SoftBusMessage* msg) in NetworkingHandleMessage()
40 static void CustomfreeMessage(SoftBusMessage* msg) in CustomfreeMessage()
54 SoftBusMessage* msg = SoftBusCalloc(sizeof(SoftBusMessage)); in TestMessageHandler()
64 SoftBusMessage* msg4 = SoftBusCalloc(sizeof(SoftBusMessage)); in TestMessageHandler()
80 SoftBusMessage* msg3 = SoftBusCalloc(sizeof(SoftBusMessage)); in TestMessageHandler()
91 SoftBusMessage* msg2 = SoftBusCalloc(sizeof(SoftBusMessage)); in TestMessageHandler()
[all...]
/foundation/communication/dsoftbus/core/common/dfx/hisysevent_adapter/
H A Dsoftbus_hisysevt_common.c65 static void ReportStatisticEvent(SoftBusMessage* param) in ReportStatisticEvent()
76 static void FreeMessageFunc(SoftBusMessage* msg) in FreeMessageFunc()
88 typedef void (*HandleMessageFunc)(SoftBusMessage *msg);
104 static SoftBusMessage* CreateMessage(SoftBusLooper *looper, HandleMessageFunc callback) in CreateMessage()
106 SoftBusMessage* msg = SoftBusMalloc(sizeof(SoftBusMessage)); in CreateMessage()
129 SoftBusMessage *message = CreateMessage(looper, callback); in CreateAndPostMsgDelay()
139 static void ReportStatisticEvtPeriod(SoftBusMessage* msg) in ReportStatisticEvtPeriod()
/foundation/communication/dsoftbus/core/common/dfx/hidumper_adapter/
H A Dsoftbus_hidumper_broadcast.c37 static SoftBusMessage *CreateBroadcastHandlerMsg(int32_t what, uint64_t arg1, uint64_t arg2, void *obj) in CreateBroadcastHandlerMsg()
39 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in CreateBroadcastHandlerMsg()
57 SoftBusMessage *msg = CreateBroadcastHandlerMsg(EVENT_BROADCAT_DUMP, delayMillis, 0, (void *)cb); in ExecuteBroadcastTask()
80 SoftBusMessage *msg = CreateBroadcastHandlerMsg(EVENT_BROADCAT_DUMP, delayMillis, 0, (void *)cb); in SoftbusRegBroadcastDumpTask()
138 static void BroadcastMsgHandler(SoftBusMessage *msg) in BroadcastMsgHandler()
/foundation/communication/dsoftbus/core/common/message_handler/
H A Dmessage_handler.c37 SoftBusMessage *msg;
46 SoftBusMessage *currentMsg;
64 NO_SANITIZE("cfi") static void FreeSoftBusMsg(SoftBusMessage *msg) in FreeSoftBusMsg()
73 SoftBusMessage *MallocMessage(void) in MallocMessage()
75 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in MallocMessage()
77 COMM_LOGE(COMM_UTILS, "malloc SoftBusMessage failed"); in MallocMessage()
83 void FreeMessage(SoftBusMessage *msg) in FreeMessage()
134 SoftBusMessage *ms in LoopTask()
379 LoopRemoveMessageCustom(const SoftBusLooper *looper, const SoftBusHandler *handler, int (*customFunc)(const SoftBusMessage*, void*), void *args) LoopRemoveMessageCustom() argument
[all...]
/foundation/communication/dsoftbus/core/bus_center/utils/src/
H A Dlnn_state_machine.c39 static void FreeFsmHandleMsg(SoftBusMessage *msg) in FreeFsmHandleMsg()
60 static SoftBusMessage *CreateFsmHandleMsg(FsmStateMachine *fsm, in CreateFsmHandleMsg()
63 SoftBusMessage *msg = NULL; in CreateFsmHandleMsg()
89 static void ProcessStartMessage(SoftBusMessage *msg) in ProcessStartMessage()
117 static void ProcessDataMessage(SoftBusMessage *msg) in ProcessDataMessage()
141 static void ProcessStopMessage(SoftBusMessage *msg) in ProcessStopMessage()
163 static int32_t RemoveAllMessageFunc(const SoftBusMessage *msg, void *para) in RemoveAllMessageFunc()
171 static void ProcessDeinitMessage(SoftBusMessage *msg) in ProcessDeinitMessage()
193 static void FsmStateMsgHandler(SoftBusMessage *msg) in FsmStateMsgHandler()
224 SoftBusMessage *ms in PostMessageToFsm()
363 LnnFsmRemoveMessageSpecific(FsmStateMachine *fsm, int32_t (*customFunc)(const SoftBusMessage*, void*), void *args) LnnFsmRemoveMessageSpecific() argument
[all...]
H A Dlnn_async_callback_utils.c29 SoftBusMessage msg;
37 static void AsyncCallbackHandler(SoftBusMessage *msg) in AsyncCallbackHandler()
57 static void FreeAsyncCallbackMessage(SoftBusMessage *msg) in FreeAsyncCallbackMessage()
69 static void InitAsyncCallbackMessage(SoftBusMessage *msg, int32_t what, void *obj, SoftBusHandler *handler) in InitAsyncCallbackMessage()
/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_conn_common.c87 static void ConnFreeMessage(SoftBusMessage *msg) in ConnFreeMessage()
100 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in ConnPostMsgToLooper()
116 SoftBusMessage ctx = { in ConnRemoveMsgFromLooper()
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_pipeline.c109 static void TransProxyPipelineFreeMessage(SoftBusMessage *msg) in TransProxyPipelineFreeMessage()
203 struct SoftBusMessage *msg = (struct SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in TransProxyPipelineOpenChannel()
330 struct SoftBusMessage *msg = (struct SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in TransProxyPipelineCloseChannelDelay()
383 struct SoftBusMessage *msg = (struct SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in TransProxyPipelineOnChannelOpened()
[all...]
H A Dsoftbus_proxychannel_transceiver.c175 static void TransProxyLoopMsgHandler(SoftBusMessage *msg) in TransProxyLoopMsgHandler()
225 void TransProxyFreeLoopMsg(SoftBusMessage *msg) in TransProxyFreeLoopMsg()
235 static SoftBusMessage *TransProxyCreateLoopMsg(int32_t what, uint64_t arg1, uint64_t arg2, char *data) in TransProxyCreateLoopMsg()
237 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in TransProxyCreateLoopMsg()
253 SoftBusMessage *msg = TransProxyCreateLoopMsg(LOOP_AUTHSTATECHECK_MSG, authRequestId, channelId, NULL); in TransProxyPostAuthNegoMsgToLooperDelay()
261 SoftBusMessage *msg = TransProxyCreateLoopMsg(LOOP_RESETPEER_MSG, 0, 0, (char *)chan); in TransProxyPostResetPeerMsgToLoop()
283 SoftBusMessage *msg = TransProxyCreateLoopMsg(LOOP_HANDSHAKE_MSG, 0, 0, (char *)chanIdMsg); in TransProxyPostHandshakeMsgToLoop()
293 SoftBusMessage *ms in TransProxyPostDisConnectMsgToLoop()
[all...]
/foundation/communication/dsoftbus/core/common/dfx/statistics/instant/
H A Dinstant_statistics_virtual.cpp18 void InstRegister(SoftBusMessage *msg) in InstRegister()
/foundation/communication/dsoftbus/core/common/dfx/interface/include/
H A Dinstant_statistics.h25 void InstRegister(SoftBusMessage *msg);
/foundation/communication/dsoftbus/core/bus_center/service/src/
H A Dbus_center_event.c67 static int32_t PostMessageToHandlerDelay(SoftBusMessage *msg, uint64_t delayMillis) in PostMessageToHandlerDelay()
100 static void HandleOnlineStateChangedMessage(SoftBusMessage *msg) in HandleOnlineStateChangedMessage()
111 static void HandleNodeBasicInfoChangedMessage(SoftBusMessage *msg) in HandleNodeBasicInfoChangedMessage()
121 static void HandleNodeStatusChangedMessage(SoftBusMessage *msg) in HandleNodeStatusChangedMessage()
136 static void HandleNetworkUpdateMessage(SoftBusMessage *msg) in HandleNetworkUpdateMessage()
151 static void HandleNotifyMessage(SoftBusMessage *msg) in HandleNotifyMessage()
180 static void FreeNotifyMessage(SoftBusMessage *msg) in FreeNotifyMessage()
232 SoftBusMessage *msg = SoftBusCalloc(sizeof(SoftBusMessage)); in PostNotifyMessage()
252 SoftBusMessage *ms in PostNotifyNodeStatusMessage()
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/include/
H A Dlnn_net_builder_process.h34 void NetBuilderMessageHandler(SoftBusMessage *msg);
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/
H A Dlnn_lane_link_conflict.c56 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in LinkConflictPostMsgToHandler()
112 static int32_t RemoveConflictInfoTimeliness(const SoftBusMessage *msg, void *data) in RemoveConflictInfoTimeliness()
422 static void HandleConflictInfoTimeliness(SoftBusMessage *msg) in HandleConflictInfoTimeliness()
436 static void MsgHandler(SoftBusMessage *msg) in MsgHandler()
H A Dlnn_trans_lane.c138 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in LnnLanePostMsgToHandler()
156 static int32_t RemoveLinkTimeout(const SoftBusMessage *msg, void *data) in RemoveLinkTimeout()
1140 static void LaneTriggerLink(SoftBusMessage *msg) in LaneTriggerLink()
1372 static void LaneLinkSuccess(SoftBusMessage *msg) in LaneLinkSuccess()
1469 static void LaneLinkFail(SoftBusMessage *msg) in LaneLinkFail()
1499 static void LaneStateChange(SoftBusMessage *msg) in LaneStateChange()
1571 static void HandleDelayDestroyLink(SoftBusMessage *msg) in HandleDelayDestroyLink()
1587 static void HandleDetectTimeout(SoftBusMessage *ms
[all...]
/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_common.c63 static void DelAuthMessage(SoftBusMessage *msg) in DelAuthMessage()
73 static SoftBusMessage *NewAuthMessage(const uint8_t *obj, uint32_t size) in NewAuthMessage()
75 SoftBusMessage *msg = MallocMessage(); in NewAuthMessage()
94 static void HandleAuthMessage(SoftBusMessage *msg) in HandleAuthMessage()
110 SoftBusMessage *msg = NewAuthMessage(obj, size); in PostAuthEvent()
125 static int32_t CustomFunc(const SoftBusMessage *msg, void *param) in CustomFunc()
/foundation/communication/dsoftbus/tests/core/bus_center/test/heartbeat/
H A Dhb_fsm_test.cpp117 SoftBusMessage ctrlMsgObj = { in HWTEST_F()
120 SoftBusMessage delMsg = { in HWTEST_F()
123 bool ret = CheckRemoveHbMsgParams(const_cast<const SoftBusMessage *>(&ctrlMsgObj), nullptr); in HWTEST_F()
125 ret = CheckRemoveHbMsgParams(const_cast<const SoftBusMessage *>(&ctrlMsgObj), reinterpret_cast<void *>(&delMsg)); in HWTEST_F()
212 SoftBusMessage delMsg = { in HWTEST_F()
258 SoftBusMessage delMsg = { in HWTEST_F()
581 SoftBusMessage delMsg; in HWTEST_F()
610 SoftBusMessage delMsg; in HWTEST_F()
645 SoftBusMessage delMsg; in HWTEST_F()
686 SoftBusMessage delMs in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_manager.c77 static void BrManagerMsgHandler(SoftBusMessage *msg);
78 static int BrCompareManagerLooperEventFunc(const SoftBusMessage *msg, void *args);
1083 void (*func)(SoftBusMessage *msg);
1086 static void HandlePendingRequestFunc(SoftBusMessage *msg) in HandlePendingRequestFunc()
1095 static void ConnectRequestFunc(SoftBusMessage *msg) in ConnectRequestFunc()
1105 static void ClientConnectedFunc(SoftBusMessage *msg) in ClientConnectedFunc()
1113 static void ClientConnectTimeoutFunc(SoftBusMessage *msg) in ClientConnectTimeoutFunc()
1122 static void ClientConnectFailedFunc(SoftBusMessage *msg) in ClientConnectFailedFunc()
1132 static void ServerAcceptedFunc(SoftBusMessage *msg) in ServerAcceptedFunc()
1140 static void DataReceivedFunc(SoftBusMessage *ms
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/time_sync/src/
H A Dlnn_time_sync_manager.c419 static void TimeSyncMessageHandler(SoftBusMessage *msg) in TimeSyncMessageHandler()
444 static SoftBusMessage *CreateTimeSyncMessage(int32_t msgType, void *para) in CreateTimeSyncMessage()
446 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in CreateTimeSyncMessage()
459 SoftBusMessage *msg = CreateTimeSyncMessage(msgType, para); in PostMessageToHandler()
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/src/
H A Dlnn_heartbeat_fsm.c207 static bool CheckRemoveHbMsgParams(const SoftBusMessage *msg, void *args) in CheckRemoveHbMsgParams()
218 SoftBusMessage *delMsg = (SoftBusMessage *)args; in CheckRemoveHbMsgParams()
226 static int32_t RemoveCheckDevStatusMsg(FsmCtrlMsgObj *ctrlMsgObj, SoftBusMessage *delMsg) in RemoveCheckDevStatusMsg()
248 static int32_t RemoveSendOnceMsg(FsmCtrlMsgObj *ctrlMsgObj, SoftBusMessage *delMsg) in RemoveSendOnceMsg()
262 static int32_t RemoveSendOneEndMsg(FsmCtrlMsgObj *ctrlMsgObj, SoftBusMessage *delMsg) in RemoveSendOneEndMsg()
311 static int32_t RemoveScreenOffCheckStatus(FsmCtrlMsgObj *ctrlMsgObj, SoftBusMessage *delMsg) in RemoveScreenOffCheckStatus()
333 static int32_t CustomFuncRemoveHbMsg(const SoftBusMessage *msg, void *args) in CustomFuncRemoveHbMsg()
339 SoftBusMessage *delMsg = (SoftBusMessage *)arg in CustomFuncRemoveHbMsg()
[all...]
/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_manager.c122 static void BleManagerMsgHandler(SoftBusMessage *msg);
123 static int BleCompareManagerLooperEventFunc(const SoftBusMessage *msg, void *args);
1537 void (*func)(SoftBusMessage *msg);
1540 static void HandlePendingRequestFunc(SoftBusMessage *msg) in HandlePendingRequestFunc()
1549 static void ConnectRequestFunc(SoftBusMessage *msg) in ConnectRequestFunc()
1559 static void ClientConnectedFunc(SoftBusMessage *msg) in ClientConnectedFunc()
1567 static void ClientConnectTimeoutFunc(SoftBusMessage *msg) in ClientConnectTimeoutFunc()
1575 static void ClientConnectFailedFunc(SoftBusMessage *msg) in ClientConnectFailedFunc()
1585 static void ServerAcceptedFunc(SoftBusMessage *msg) in ServerAcceptedFunc()
1593 static void DataReceivedFunc(SoftBusMessage *ms
[all...]
/foundation/communication/dsoftbus/core/discovery/ble/softbus_ble/src/
H A Ddisc_ble.c202 static SoftBusMessage *CreateBleHandlerMsg(int32_t what, uint64_t arg1, uint64_t arg2, void *obj);
603 SoftBusMessage *msg = NULL; in BtOnStateChanged()
1274 static SoftBusMessage *CreateBleHandlerMsg(int32_t what, uint64_t arg1, uint64_t arg2, void *obj) in CreateBleHandlerMsg()
1276 SoftBusMessage *msg = (SoftBusMessage *)SoftBusCalloc(sizeof(SoftBusMessage)); in CreateBleHandlerMsg()
1333 SoftBusMessage *msg = CreateBleHandlerMsg(funcCode, 0, 0, NULL); in ProcessBleDiscFunc()
1493 static void StartActivePublish(SoftBusMessage *msg) in StartActivePublish()
1502 static void StartPassivePublish(SoftBusMessage *msg) in StartPassivePublish()
1513 static void StartActiveDiscovery(SoftBusMessage *ms
[all...]
/foundation/communication/dsoftbus/core/bus_center/utils/include/
H A Dlnn_state_machine.h82 int32_t (*customFunc)(const SoftBusMessage*, void*), void *args);
/foundation/communication/dsoftbus/core/connection/common/include/
H A Dsoftbus_conn_common.h43 int (*eventCompareFunc)(const SoftBusMessage *, void *);

Completed in 32 milliseconds

12