Lines Matching refs:LE_GetDefaultLoop

127     LE_StopLoop(LE_GetDefaultLoop());  in StopAppSpawn()
188 LE_StopLoop(LE_GetDefaultLoop()); in ProcessSignal()
223 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer); in OnClose()
268 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendResponse()
271 APPSPAWN_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), NULL, handle); in SendResponse()
275 return LE_Send(LE_GetDefaultLoop(), connection->stream, handle, bufferSize); in SendResponse()
284 LE_CloseStreamTask(LE_GetDefaultLoop(), connection->stream); in WaitMsgCompleteTimeOut()
292 …int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeO… in StartTimerForCheckMsg()
294 … ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer, MAX_WAIT_MSG_COMPLETE, 1); in StartTimerForCheckMsg()
381 LE_CloseStreamTask(LE_GetDefaultLoop(), stream); in OnConnection()
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()
447 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer); 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()
564 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ProcessChildProcessFd()
604 …LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.pidFdWatcherHandle, &wa… in WatchChildProcessFd()
632 …LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.watcherHandle, &watchIn… in AddChildWatcher()
635 …status = LE_CreateTimer(LE_GetDefaultLoop(), &property->forkCtx.timer, WaitChildTimeout, property); in AddChildWatcher()
637 …status = LE_StartTimer(LE_GetDefaultLoop(), property->forkCtx.timer, timeout * 1000, 0); // 1000 1s in AddChildWatcher()
641 LE_StopTimer(LE_GetDefaultLoop(), property->forkCtx.timer); in AddChildWatcher()
644 LE_RemoveWatcher(LE_GetDefaultLoop(), property->forkCtx.watcherHandle); in AddChildWatcher()
988 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)taskHandle); in ProcessChildResponse()
1063 ret = LE_CreateStreamServer(LE_GetDefaultLoop(), server, &info); in CreateAppSpawnServer()
1084 LE_CloseSignalTask(LE_GetDefaultLoop(), appSpawnContent->sigHandler); in AppSpawnDestroyContent()
1088 LE_CloseStreamTask(LE_GetDefaultLoop(), appSpawnContent->server); in AppSpawnDestroyContent()
1092 LE_StopLoop(LE_GetDefaultLoop()); in AppSpawnDestroyContent()
1093 LE_CloseLoop(LE_GetDefaultLoop()); in AppSpawnDestroyContent()
1225 …LE_STATUS status = LE_CreateSignalTask(LE_GetDefaultLoop(), &appSpawnContent->sigHandler, ProcessS… in AppSpawnRun()
1227 (void)LE_AddSignal(LE_GetDefaultLoop(), appSpawnContent->sigHandler, SIGCHLD); in AppSpawnRun()
1228 (void)LE_AddSignal(LE_GetDefaultLoop(), appSpawnContent->sigHandler, SIGTERM); in AppSpawnRun()
1237 LE_RunLoop(LE_GetDefaultLoop()); in AppSpawnRun()
1318 APPSPAWN_CHECK(LE_GetDefaultLoop() != NULL, return NULL, "Invalid default loop"); in StartSpawnService()