Home
last modified time | relevance | path

Searched refs:receiverCtx (Results 1 - 7 of 7) sorted by relevance

/base/startup/appspawn/standard/
H A Dappspawn_service.c231 if (connection->receiverCtx.timer) { in OnClose()
232 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer); in OnClose()
233 connection->receiverCtx.timer = NULL; in OnClose()
237 DeleteAppSpawnMsg(connection->receiverCtx.incompleteMsg); in OnClose()
238 connection->receiverCtx.incompleteMsg = NULL; in OnClose()
291 DeleteAppSpawnMsg(connection->receiverCtx.incompleteMsg); in WaitMsgCompleteTimeOut()
292 connection->receiverCtx.incompleteMsg = NULL; in WaitMsgCompleteTimeOut()
298 if (connection->receiverCtx.timer != NULL) { in StartTimerForCheckMsg()
301 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeOut, connection); in StartTimerForCheckMsg()
303 ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx in StartTimerForCheckMsg()
[all...]
H A Dappspawn_service.h58 AppSpawnMsgReceiverCtx receiverCtx; member
/base/startup/init/test/systest/
H A Dloopserver_systest.c177 if (connection->receiverCtx.timer != NULL) { in StartTimerForCheckMsg()
180 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeOut, connection); in StartTimerForCheckMsg()
182 ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer, MAX_WAIT_MSG_COMPLETE, 1); in StartTimerForCheckMsg()
620 if (task->receiverCtx.nextMsgId != msg->msgId) { in ProcessRecvMsg()
621 printf("Invalid msg id %u %u \n", task->receiverCtx.nextMsgId, msg->msgId); in ProcessRecvMsg()
623 task->receiverCtx.nextMsgId++; in ProcessRecvMsg()
/base/startup/appspawn/test/unittest/
H A Dapp_spawn_test_helper.cpp274 return -1, "failed to recv fd %d %d", connection->receiverCtx.fdCount, fdCount); in HandleRecvMessage()
275 APPSPAWN_CHECK(memcpy_s(connection->receiverCtx.fds, fdCount * sizeof(int), fd, in HandleRecvMessage()
277 connection->receiverCtx.fdCount = fdCount; in HandleRecvMessage()
329 int fdCount = spawnConnection->receiverCtx.fdCount; in OnClose()
331 APPSPAWN_LOGI("OnClose close fd %d", spawnConnection->receiverCtx.fds[i]); in OnClose()
332 if (spawnConnection->receiverCtx.fds[i] >= 0) { in OnClose()
333 close(spawnConnection->receiverCtx.fds[i]); in OnClose()
/base/startup/appspawn/modules/common/
H A Dappspawn_common.c482 int fdCount = property->message->connection->receiverCtx.fdCount; in CloseFdArgs()
483 int *fds = property->message->connection->receiverCtx.fds; in CloseFdArgs()
491 property->message->connection->receiverCtx.fdCount = 0; in CloseFdArgs()
503 AppSpawnMsgReceiverCtx recvCtx = message->connection->receiverCtx; in SetFdEnv()
/base/startup/appspawn/modules/native_adapter/
H A Dnative_adapter.cpp43 recvCtx = message->connection->receiverCtx; in BuildFdInfoMap()
/base/startup/appspawn/modules/ace_adapter/
H A Dace_adapter.cpp150 recvCtx = message->connection->receiverCtx; in BuildFdInfoMap()

Completed in 7 milliseconds