| /base/startup/init/services/loopevent/task/ |
| D | le_asynctask.c | 58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
60 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in LE_DoAsyncEvent()
62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle); in LE_DoAsyncEvent()
66 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32… in HandleAsyncEvent_() argument
68 LE_LOGV("HandleAsyncEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleAsyncEvent_()
70 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in HandleAsyncEvent_()
73 int ret = read(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
74 …LE_LOGV("HandleAsyncEvent_ read fd:%d ret: %d eventId %llu", GetSocketFd(taskHandle), ret, eventId… in HandleAsyncEvent_()
77 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Write); in HandleAsyncEvent_()
82 (void)write(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
[all …]
|
| D | le_streamtask.c | 25 const TaskHandle taskHandle, const LE_SendMessageComplete complete) in HandleSendMsg_() argument
28 StreamTask *stream = (StreamTask *)taskHandle; in HandleSendMsg_()
31 int ret = write(GetSocketFd(taskHandle), buffer->data, buffer->dataSize); in HandleSendMsg_()
32 …LE_LOGV("HandleSendMsg_ fd:%d send data size %d %d", GetSocketFd(taskHandle), buffer->dataSize, re… in HandleSendMsg_()
35 complete(taskHandle, buffer); in HandleSendMsg_()
41 LE_LOGV("HandleSendMsg_ fd:%d empty wait read", GetSocketFd(taskHandle)); in HandleSendMsg_()
42 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleSendMsg_()
49 const TaskHandle taskHandle, const LE_RecvMessage recvMessage) in HandleRecvMsg_() argument
55 readLen = recv(GetSocketFd(taskHandle), buffer->data, LOOP_DEFAULT_BUFFER, 0); in HandleRecvMsg_()
56 LE_LOGV("HandleRecvMsg fd:%d read msg len %d", GetSocketFd(taskHandle), readLen); in HandleRecvMsg_()
[all …]
|
| D | le_watchtask.c | 18 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint… in HandleWatcherEvent_() argument
20 LE_LOGV("HandleWatcherEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleWatcherEvent_()
22 WatcherTask *watcher = (WatcherTask *)taskHandle; in HandleWatcherEvent_()
23 int fd = GetSocketFd(taskHandle); in HandleWatcherEvent_()
25 uint64_t userData = *(uint64_t *)LE_GetUserData(taskHandle); in HandleWatcherEvent_()
27 watcher->processEvent(taskHandle, fd, &events, (void *)userData); in HandleWatcherEvent_()
41 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events); in HandleWatcherEvent_()
46 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_() argument
48 CloseTask(loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
49 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
|
| D | le_task.c | 151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle) in LE_FreeBuffer() argument
153 FreeBuffer(loop, (StreamTask *)taskHandle, (LE_Buffer *)handle); in LE_FreeBuffer()
170 const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen) in LE_Send() argument
173 if (((BaseTask *)taskHandle)->flags & TASK_FLAGS_INVALID) { in LE_Send()
174 LE_FreeBuffer(loopHandle, taskHandle, buffHandle); in LE_Send()
179 if (CheckTaskFlags((BaseTask *)taskHandle, TASK_STREAM | TASK_CONNECT)) { in LE_Send()
180 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
181 } else if (CheckTaskFlags((BaseTask *)taskHandle, TASK_EVENT | TASK_ASYNC_EVENT)) { in LE_Send()
182 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
184 loop->modEvent(loop, (BaseTask *)taskHandle, Event_Write); in LE_Send()
[all …]
|
| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 71 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
77 void LE_FreeBuffer(const LoopHandle loopHandle, const TaskHandle taskHandle, const BufferHandle han…
82 typedef void (*LE_Close)(const TaskHandle taskHandle);
100 typedef void (*LE_SendMessageComplete)(const TaskHandle taskHandle, BufferHandle handle);
101 typedef void (*LE_RecvMessage)(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen…
123 TaskHandle *taskHandle, const LE_StreamServerInfo *info);
125 TaskHandle *taskHandle, const LE_StreamInfo *info);
127 const TaskHandle serverTask, TaskHandle *taskHandle, const LE_StreamInfo *info);
129 const TaskHandle taskHandle, const BufferHandle handle, uint32_t buffLen);
130 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
[all …]
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.c | 126 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
128 AppSpawnClientExt *client = (AppSpawnClientExt *)LE_GetUserData(taskHandle); in OnClose()
150 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() argument
152 AppSpawnClientExt *client = (AppSpawnClientExt *)LE_GetUserData(taskHandle); in SendMessageComplete()
320 static bool ReceiveRequestDataToDataGroup(const TaskHandle taskHandle, AppSpawnClientExt *client, in ReceiveRequestDataToDataGroup() argument
326 … APPSPAWN_CHECK(dataGroupInfoList->data != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToDataGroup()
331 …AWN_CHECK(dataGroupInfoList->totalLength >= buffLen, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToDataGroup()
335 APPSPAWN_CHECK(ret == 0, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToDataGroup()
342 static bool ReceiveRequestDataToOverlay(const TaskHandle taskHandle, AppSpawnClientExt *client, in ReceiveRequestDataToOverlay() argument
348 APPSPAWN_CHECK(overlayInfo->data != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToOverlay()
[all …]
|
| /base/startup/init/test/unittest/loopevent/ |
| D | loopserver_unittest.cpp | 66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *messa… in SendMessage() argument
75 LE_FreeBuffer(loopHandle, taskHandle, handle); in SendMessage()
81 int ret = LE_Send(loopHandle, taskHandle, handle, bufferSize); in SendMessage()
85 static void TestOnClose(const TaskHandle taskHandle) in TestOnClose() argument
120 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,… in ProcessAsyncEvent() argument
122 UNUSED(taskHandle); in ProcessAsyncEvent()
128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in TestSendMessageComplete() argument
185 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() argument
196 LE_StopTimer(g_loopClient_, taskHandle); in TestProcessTimer()
207 LE_StopTimer(g_loopClient_, taskHandle); in TestProcessTimer()
[all …]
|
| D | loopevent_unittest.cpp | 60 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,… in ProcessAsyncEvent() argument
62 UNUSED(taskHandle); in ProcessAsyncEvent()
75 static void ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *c… in ProcessWatchEventTest() argument
77 UNUSED(taskHandle); in ProcessWatchEventTest()
271 static void Test_ProcessTimer(const TimerHandle taskHandle, void *context) in Test_ProcessTimer() argument
|
| /base/startup/init/services/param/include/ |
| D | param_osadp.h | 107 typedef void (*ProcessTimer)(const struct ParamTimer_ *taskHandle, void *context);
118 typedef void (*ProcessTimer)(const ParamTaskPtr taskHandle, void *context);
|
| /base/startup/init/test/unittest/init/ |
| D | init_unittest.cpp | 93 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() argument
118 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TestProcessTimer()
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.c | 66 static void HandleTimerClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleTimerClose_() argument
68 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd_client.c | 27 CONTROL_FD_STATIC void ProcessPtyWrite(const WatcherHandle taskHandle, int fd, uint32_t *events, co… in ProcessPtyWrite() argument
47 CONTROL_FD_STATIC void ProcessPtyRead(const WatcherHandle taskHandle, int fd, uint32_t *events, con… in ProcessPtyRead() argument
|
| /base/startup/init/services/init/standard/ |
| D | fd_holder_service.c | 163 void ProcessFdHoldEvent(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *conte… in ProcessFdHoldEvent() argument
|
| /base/startup/init/test/unittest/innerkits/ |
| D | innerkits_unittest.cpp | 42 void ProcessPtyRead(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context);
43 void ProcessPtyWrite(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context);
|
| /base/startup/appspawn/test/unittest/app_spawn_standard_test/ |
| D | app_spawn_standard_test.cpp | 52 bool ReceiveRequestData(const TaskHandle taskHandle, AppSpawnClientExt *appProperty,
125 static void ProcessTimer(const TimerHandle taskHandle, void *context) in ProcessTimer() argument
|
| /base/startup/init/test/unittest/param/ |
| D | param_stub.cpp | 628 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
|
| D | param_unittest.cpp | 32 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
|