Lines Matching refs:reqNode

212 static int HandleMsgSend(AppSpawnReqMsgMgr *reqMgr, int socketId, AppSpawnReqMsgNode *reqNode)  in HandleMsgSend()  argument
214 …APPSPAWN_LOGV("HandleMsgSend reqId: %{public}u msgId: %{public}d", reqNode->reqId, reqNode->msg->m… in HandleMsgSend()
215 ListNode *sendNode = reqNode->msgBlocks.next; in HandleMsgSend()
218 while (sendNode != NULL && sendNode != &reqNode->msgBlocks) { in HandleMsgSend()
221 sendFd ? reqNode->fds : NULL, in HandleMsgSend()
222 sendFd ? &reqNode->fdCount : NULL); in HandleMsgSend()
225 ret, reqNode->msg->msgId, reqNode->msg->msgLen, currentIndex); in HandleMsgSend()
232 reqNode->reqId, reqNode->msg->msgId, ret); in HandleMsgSend()
255 static int ClientSendMsg(AppSpawnReqMsgMgr *reqMgr, AppSpawnReqMsgNode *reqNode, AppSpawnResult *re… in ClientSendMsg() argument
258 int isColdRun = reqNode->isAsan; in ClientSendMsg()
272 if (reqNode->msg->msgId == 0) { in ClientSendMsg()
273 reqNode->msg->msgId = reqMgr->msgNextId++; in ClientSendMsg()
275 int ret = HandleMsgSend(reqMgr, reqMgr->socketId, reqNode); in ClientSendMsg()
277 ret = ReadMessage(reqMgr->socketId, reqNode->msg->msgId, in ClientSendMsg()
290 reqNode->msg->msgId = 0; in ClientSendMsg()
344 AppSpawnReqMsgNode *reqNode = (AppSpawnReqMsgNode *)reqHandle; in AppSpawnClientSendMsg() local
345 APPSPAWN_CHECK(reqNode != NULL && reqNode->msg != NULL, AppSpawnReqMsgFree(reqHandle); in AppSpawnClientSendMsg()
349 reqNode->reqId, reqNode->msg->msgLen, reqNode->msg->processName); in AppSpawnClientSendMsg()
351 int ret = ClientSendMsg(reqMgr, reqNode, result); in AppSpawnClientSendMsg()
357 reqNode->reqId, result->result, result->pid); in AppSpawnClientSendMsg()