Lines Matching refs:LE_GetDefaultLoop
139 LE_StopLoop(LE_GetDefaultLoop());
197 LE_StopLoop(LE_GetDefaultLoop());
232 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer);
277 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize);
280 APPSPAWN_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), NULL, handle);
284 return LE_Send(LE_GetDefaultLoop(), connection->stream, handle, bufferSize);
293 LE_CloseStreamTask(LE_GetDefaultLoop(), connection->stream);
301 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeOut, connection);
303 ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer, MAX_WAIT_MSG_COMPLETE, 1);
390 LE_CloseStreamTask(LE_GetDefaultLoop(), stream);
431 APPSPAWN_CHECK(connection != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle);
433 APPSPAWN_CHECK(buffLen < MAX_MSG_TOTAL_LENGTH, LE_CloseTask(LE_GetDefaultLoop(), taskHandle);
456 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer);
461 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); return);
475 LE_CloseTask(LE_GetDefaultLoop(), taskHandle);
480 APPSPAWN_CHECK(ret == 0, LE_CloseStreamTask(LE_GetDefaultLoop(), taskHandle);
572 LE_CloseTask(LE_GetDefaultLoop(), taskHandle);
612 LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.pidFdWatcherHandle, &watchInfo, appPid);
639 LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.watcherHandle, &watchInfo, property);
642 status = LE_CreateTimer(LE_GetDefaultLoop(), &property->forkCtx.timer, WaitChildTimeout, property);
644 status = LE_StartTimer(LE_GetDefaultLoop(), property->forkCtx.timer, timeout * 1000, 0); // 1000 1s
648 LE_StopTimer(LE_GetDefaultLoop(), property->forkCtx.timer);
651 LE_RemoveWatcher(LE_GetDefaultLoop(), property->forkCtx.watcherHandle);
997 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)taskHandle);
1073 ret = LE_CreateStreamServer(LE_GetDefaultLoop(), server, &info);
1097 LE_CloseSignalTask(LE_GetDefaultLoop(), appSpawnContent->sigHandler);
1101 LE_CloseStreamTask(LE_GetDefaultLoop(), appSpawnContent->server);
1104 LE_StopLoop(LE_GetDefaultLoop());
1105 LE_CloseLoop(LE_GetDefaultLoop());
1239 LE_STATUS status = LE_CreateSignalTask(LE_GetDefaultLoop(), &appSpawnContent->sigHandler, ProcessSignal);
1241 (void)LE_AddSignal(LE_GetDefaultLoop(), appSpawnContent->sigHandler, SIGCHLD);
1242 (void)LE_AddSignal(LE_GetDefaultLoop(), appSpawnContent->sigHandler, SIGTERM);
1248 LE_RunLoop(LE_GetDefaultLoop());
1328 APPSPAWN_CHECK(LE_GetDefaultLoop() != NULL, return NULL, "Invalid default loop");