Searched refs:recvMessage (Results 1 – 14 of 14) sorted by relevance
| /base/startup/init/services/loopevent/task/ |
| D | le_streamtask.c | 54 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()
|
| D | le_task.h | 98 LE_RecvMessage recvMessage; member
107 LE_RecvMessage recvMessage; member
|
| /base/startup/init/services/param/linux/ |
| D | param_msgadp.c | 63 PARAM_CHECK(streamInfo->recvMessage != NULL, return -1, "Invalid recvMessage"); in ParamStreamCreate()
74 info.recvMessage = OnReceiveRequest; in ParamStreamCreate()
75 g_recvMessage = streamInfo->recvMessage; in ParamStreamCreate()
|
| D | param_message.h | 80 RecvMessage recvMessage; member
|
| D | param_service.c | 364 info.recvMessage = ProcessMessage; in OnIncomingConnect()
414 info.recvMessage = NULL; in InitParamService()
|
| /base/startup/init/test/unittest/loopevent/ |
| D | loopevent_unittest.cpp | 99 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()
|
| D | loopserver_unittest.cpp | 151 info.recvMessage = TestOnReceiveRequest; in TestTcpIncomingConnect()
168 info.recvMessage = TestOnReceiveRequest; in TestPipIncomingConnect()
292 info.recvMessage = TestClientOnReceiveRequest; in CreateConnect()
|
| /base/startup/init/interfaces/innerkits/include/ |
| D | loop_event.h | 111 LE_RecvMessage recvMessage; member
120 LE_RecvMessage recvMessage; member
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd_service.c | 130 info.recvMessage = CmdOnRecvMessage; in CmdOnIncommingConnect()
158 info.recvMessage = NULL; in CmdServiceInit()
|
| D | control_fd_client.c | 120 info.recvMessage = CmdClientOnRecvMessage; in CmdAgentCreate()
|
| /base/startup/init/test/unittest/param/ |
| D | param_unittest.cpp | 613 info.recvMessage = nullptr;
630 info.recvMessage = ProcessMessage;
641 info.recvMessage = nullptr;
|
| /base/startup/init/test/unittest/innerkits/ |
| D | innerkits_unittest.cpp | 382 info.recvMessage = nullptr;
|
| /base/startup/appspawn/test/unittest/ |
| D | app_spawn_test_helper.cpp | 259 info.recvMessage = OnReceiveRequest; in OnConnection()
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.c | 252 info.recvMessage = OnReceiveRequest; in OnConnection()
|