Home
last modified time | relevance | path

Searched refs:recvMessage (Results 1 – 14 of 14) sorted by relevance

/base/startup/init/services/loopevent/task/
Dle_streamtask.c54 const TaskHandle taskHandle, const LE_RecvMessage recvMessage) in HandleRecvMsg_() argument
80 if (recvMessage) { in HandleRecvMsg_()
81 recvMessage(taskHandle, buffer->data, readLen); in HandleRecvMsg_()
98 status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage); in HandleStreamEvent_()
122 status = HandleRecvMsg_(loopHandle, handle, client->recvMessage); in HandleClientEvent_()
236 …LE_CHECK(info->recvMessage != NULL, return LE_FAILURE, "Invalid parameters recvMessage %s", info->… in LE_CreateStreamClient()
251 task->recvMessage = info->recvMessage; in LE_CreateStreamClient()
264 LE_CHECK(info->recvMessage != NULL, return LE_INVALID_PARAM, "Invalid parameters recvMessage"); in LE_AcceptStreamClient()
279 task->recvMessage = info->recvMessage; in LE_AcceptStreamClient()
Dle_task.h98 LE_RecvMessage recvMessage; member
107 LE_RecvMessage recvMessage; member
/base/startup/init/services/param/linux/
Dparam_msgadp.c63 PARAM_CHECK(streamInfo->recvMessage != NULL, return -1, "Invalid recvMessage"); in ParamStreamCreate()
74 info.recvMessage = OnReceiveRequest; in ParamStreamCreate()
75 g_recvMessage = streamInfo->recvMessage; in ParamStreamCreate()
Dparam_message.h80 RecvMessage recvMessage; member
Dparam_service.c364 info.recvMessage = ProcessMessage; in OnIncomingConnect()
414 info.recvMessage = NULL; in InitParamService()
/base/startup/init/test/unittest/loopevent/
Dloopevent_unittest.cpp99 info.recvMessage = nullptr; in CreateServerTask()
107 streamInfo.recvMessage = OnReceiveRequest; in StreamTaskTest()
153 paramStreamInfo.recvMessage = ProcessMessage; in LeTaskTest()
166 …((StreamConnectTask *)client)->recvMessage(LE_GetDefaultLoop(), reinterpret_cast<uint8_t *>(reques… in LeTaskTest()
Dloopserver_unittest.cpp151 info.recvMessage = TestOnReceiveRequest; in TestTcpIncomingConnect()
168 info.recvMessage = TestOnReceiveRequest; in TestPipIncomingConnect()
292 info.recvMessage = TestClientOnReceiveRequest; in CreateConnect()
/base/startup/init/interfaces/innerkits/include/
Dloop_event.h111 LE_RecvMessage recvMessage; member
120 LE_RecvMessage recvMessage; member
/base/startup/init/interfaces/innerkits/control_fd/
Dcontrol_fd_service.c130 info.recvMessage = CmdOnRecvMessage; in CmdOnIncommingConnect()
158 info.recvMessage = NULL; in CmdServiceInit()
Dcontrol_fd_client.c120 info.recvMessage = CmdClientOnRecvMessage; in CmdAgentCreate()
/base/startup/init/test/unittest/param/
Dparam_unittest.cpp613 info.recvMessage = nullptr;
630 info.recvMessage = ProcessMessage;
641 info.recvMessage = nullptr;
/base/startup/init/test/unittest/innerkits/
Dinnerkits_unittest.cpp382 info.recvMessage = nullptr;
/base/startup/appspawn/test/unittest/
Dapp_spawn_test_helper.cpp259 info.recvMessage = OnReceiveRequest; in OnConnection()
/base/startup/appspawn/standard/
Dappspawn_service.c252 info.recvMessage = OnReceiveRequest; in OnConnection()