Lines Matching refs:taskHandle

61 static void WaitChildTimeout(const TimerHandle taskHandle, void *context);
62 static void ProcessChildResponse(const WatcherHandle taskHandle, int fd, uint32_t *events, const vo…
64 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
215 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
220 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in OnClose()
227 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnClose()
234 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() argument
236 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in OnDisConnect()
239 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnDisConnect()
240 OnClose(taskHandle); in OnDisConnect()
243 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() argument
245 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in SendMessageComplete()
278 static void WaitMsgCompleteTimeOut(const TimerHandle taskHandle, void *context) in WaitMsgCompleteTimeOut() argument
299 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int fla… in HandleRecvMessage() argument
301 int socketFd = LE_GetSocketFd(taskHandle); in HandleRecvMessage()
314 AppSpawnConnection *connection = (AppSpawnConnection *) LE_GetUserData(taskHandle); in HandleRecvMessage()
419 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest() argument
421 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in OnReceiveRequest()
422 APPSPAWN_CHECK(connection != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
424 APPSPAWN_CHECK(buffLen < MAX_MSG_TOTAL_LENGTH, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
452 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); return); in OnReceiveRequest()
468 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
473 APPSPAWN_CHECK(ret == 0, LE_CloseStreamTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
541 static void ClosePidfdWatcher(const TaskHandle taskHandle) in ClosePidfdWatcher() argument
543 int fd = LE_GetSocketFd(taskHandle); in ClosePidfdWatcher()
547 void *p = LE_GetUserData(taskHandle); in ClosePidfdWatcher()
553 static void ProcessChildProcessFd(const WatcherHandle taskHandle, int fd, uint32_t *events, const v… in ProcessChildProcessFd() argument
564 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ProcessChildProcessFd()
950 static void WaitChildTimeout(const TimerHandle taskHandle, void *context) in WaitChildTimeout() argument
984 static void ProcessChildResponse(const WatcherHandle taskHandle, int fd, uint32_t *events, const vo… in ProcessChildResponse() argument
988 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)taskHandle); in ProcessChildResponse()