212 static int HandleMsgSend(AppSpawnReqMsgMgr *reqMgr, int socketId, AppSpawnReqMsgNode *reqNode)  in HandleMsgSend()  argument
238 static void TryCreateSocket(AppSpawnReqMsgMgr *reqMgr)  in TryCreateSocket()  argument
241     while (retryCount <= reqMgr->maxRetryCount) {  in TryCreateSocket()
242         if (reqMgr->socketId < 0) {  in TryCreateSocket()
243             reqMgr->socketId = CreateClientSocket(reqMgr->type, reqMgr->timeout);  in TryCreateSocket()
245         if (reqMgr->socketId < 0) {  in TryCreateSocket()
255 static int ClientSendMsg(AppSpawnReqMsgMgr *reqMgr, AppSpawnReqMsgNode *reqNode, AppSpawnResult *re…  in ClientSendMsg()  argument
259     while (retryCount <= reqMgr->maxRetryCount) {  in ClientSendMsg()
260         if (reqMgr->socketId < 0) { // try create socket  in ClientSendMsg()
261             TryCreateSocket(reqMgr);  in ClientSendMsg()
262             if (reqMgr->socketId < 0) {  in ClientSendMsg()
268         if (isColdRun && reqMgr->timeout < ASAN_TIMEOUT) {  in ClientSendMsg()
269             UpdateSocketTimeout(ASAN_TIMEOUT, reqMgr->socketId);  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()
278                 reqMgr->recvBlock.buffer, reqMgr->recvBlock.blockSize, result);  in ClientSendMsg()
281             if (isColdRun && reqMgr->timeout < ASAN_TIMEOUT) {  in ClientSendMsg()
282                 UpdateSocketTimeout(reqMgr->timeout, reqMgr->socketId);  in ClientSendMsg()
287         CloseClientSocket(reqMgr->socketId);  in ClientSendMsg()
288         reqMgr->socketId = -1;  in ClientSendMsg()
289         reqMgr->msgNextId = 1;  in ClientSendMsg()
319     AppSpawnReqMsgMgr *reqMgr = (AppSpawnReqMsgMgr *)handle;  in AppSpawnClientDestroy()  local
320     APPSPAWN_CHECK(reqMgr != NULL, return APPSPAWN_SYSTEM_ERROR, "Invalid reqMgr");  in AppSpawnClientDestroy()
322     if (reqMgr->type < sizeof(g_clientInstance) / sizeof(g_clientInstance[0])) {  in AppSpawnClientDestroy()
323         g_clientInstance[reqMgr->type] = NULL;  in AppSpawnClientDestroy()
326     pthread_mutex_destroy(&reqMgr->mutex);  in AppSpawnClientDestroy()
327     if (reqMgr->socketId >= 0) {  in AppSpawnClientDestroy()
328         CloseClientSocket(reqMgr->socketId);  in AppSpawnClientDestroy()
329         reqMgr->socketId = -1;  in AppSpawnClientDestroy()
331     free(reqMgr);  in AppSpawnClientDestroy()
341     AppSpawnReqMsgMgr *reqMgr = (AppSpawnReqMsgMgr *)handle;  in AppSpawnClientSendMsg()  local
342     APPSPAWN_CHECK(reqMgr != NULL, AppSpawnReqMsgFree(reqHandle);  in AppSpawnClientSendMsg()
350     pthread_mutex_lock(&reqMgr->mutex);  in AppSpawnClientSendMsg()
351     int ret = ClientSendMsg(reqMgr, reqNode, result);  in AppSpawnClientSendMsg()
355     pthread_mutex_unlock(&reqMgr->mutex);  in AppSpawnClientSendMsg()