Searched refs:recvMessage (Results 1 - 16 of 16) sorted by relevance
| /base/startup/init/services/loopevent/task/ |
| H A D | le_streamtask.c | 54 const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMsg)
in HandleRecvMsg_()
85 if (recvMessage) {
in HandleRecvMsg_()
86 recvMessage(taskHandle, buffer->data, readLen);
in HandleRecvMsg_()
102 status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage, stream->handleRecvMsg);
in HandleStreamEvent_()
125 status = HandleRecvMsg_(loopHandle, handle, client->recvMessage, client->handleRecvMsg);
in HandleClientEvent_()
239 LE_CHECK(info->recvMessage != NULL, return LE_FAILURE, "Invalid parameters recvMessage %s", info->server);
in LE_CreateStreamClient()
254 task->recvMessage = info->recvMessage;
in LE_CreateStreamClient()
268 LE_CHECK(info->recvMessage ! in LE_AcceptStreamClient()
53 HandleRecvMsg_(const LoopHandle loopHandle, const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMsg) HandleRecvMsg_() argument
[all...] |
| H A D | le_task.h | 98 LE_RecvMessage recvMessage;
member
108 LE_RecvMessage recvMessage;
member
|
| /base/startup/init/services/param/linux/ |
| H A 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()
|
| H A D | param_message.h | 80 RecvMessage recvMessage;
member
|
| H A D | param_service.c | 369 info.recvMessage = ProcessMessage;
in OnIncomingConnect()
419 info.recvMessage = NULL;
in InitParamService()
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopevent_unittest.cpp | 99 info.recvMessage = nullptr;
107 streamInfo.recvMessage = OnReceiveRequest;
153 paramStreamInfo.recvMessage = ProcessMessage;
166 ((StreamConnectTask *)client)->recvMessage(LE_GetDefaultLoop(), reinterpret_cast<uint8_t *>(request),
|
| H A 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/control_fd/ |
| H A D | control_fd_service.c | 130 info.recvMessage = CmdOnRecvMessage; in CmdOnIncommingConnect()
158 info.recvMessage = NULL; in CmdServiceInit()
|
| H A D | control_fd_client.c | 120 info.recvMessage = CmdClientOnRecvMessage; in CmdAgentCreate()
|
| /base/startup/init/interfaces/innerkits/include/ |
| H A D | loop_event.h | 112 LE_RecvMessage recvMessage;
member
121 LE_RecvMessage recvMessage;
member
|
| /base/startup/init/test/unittest/param/ |
| H A D | param_unittest.cpp | 632 info.recvMessage = nullptr; in HWTEST_F()
649 info.recvMessage = ProcessMessage; in HWTEST_F()
660 info.recvMessage = nullptr; in HWTEST_F()
|
| /base/startup/init/test/systest/ |
| H A D | loopserver_systest.c | 226 info.recvMessage = OnRecvMessage; in OnConnection()
303 info.recvMessage = NULL; in ServerInit()
|
| H A D | loopclient_systest.c | 84 info.recvMessage = ClientOnRecvMessage; in CreateAgent()
|
| /base/startup/init/test/unittest/innerkits/ |
| H A D | innerkits_unittest.cpp | 387 info.recvMessage = nullptr; in HWTEST_F()
|
| /base/startup/appspawn/test/unittest/ |
| H A D | app_spawn_test_helper.cpp | 294 info.recvMessage = OnReceiveRequest; in OnConnection()
|
| /base/startup/appspawn/standard/ |
| H A D | appspawn_service.c | 378 info.recvMessage = OnReceiveRequest; in OnConnection()
|
Completed in 14 milliseconds