Lines Matching refs:reqMgr
45 int ret = GetParameter("persist.appspawn.reqMgr.timeout", "0", data, sizeof(data));
212 static int HandleMsgSend(AppSpawnReqMsgMgr *reqMgr, int socketId, AppSpawnReqMsgNode *reqNode)
238 APPSPAWN_STATIC void TryCreateSocket(AppSpawnReqMsgMgr *reqMgr)
241 while (retryCount <= reqMgr->maxRetryCount) {
242 if (reqMgr->socketId < 0) {
243 reqMgr->socketId = CreateClientSocket(reqMgr->type, reqMgr->timeout);
245 if (reqMgr->socketId < 0) {
255 static int ClientSendMsg(AppSpawnReqMsgMgr *reqMgr, AppSpawnReqMsgNode *reqNode, AppSpawnResult *result)
259 while (retryCount <= reqMgr->maxRetryCount) {
260 if (reqMgr->socketId < 0) { // try create socket
261 TryCreateSocket(reqMgr);
262 if (reqMgr->socketId < 0) {
268 if (isColdRun && reqMgr->timeout < ASAN_TIMEOUT) {
269 UpdateSocketTimeout(ASAN_TIMEOUT, reqMgr->socketId);
273 reqNode->msg->msgId = reqMgr->msgNextId++;
275 int ret = HandleMsgSend(reqMgr, reqMgr->socketId, reqNode);
277 ret = ReadMessage(reqMgr->socketId, reqNode->msg->msgId,
278 reqMgr->recvBlock.buffer, reqMgr->recvBlock.blockSize, result);
281 if (isColdRun && reqMgr->timeout < ASAN_TIMEOUT) {
282 UpdateSocketTimeout(reqMgr->timeout, reqMgr->socketId);
287 CloseClientSocket(reqMgr->socketId);
288 reqMgr->socketId = -1;
289 reqMgr->msgNextId = 1;
312 APPSPAWN_CHECK(ret == 0, return APPSPAWN_SYSTEM_ERROR, "Failed to create reqMgr");
319 AppSpawnReqMsgMgr *reqMgr = (AppSpawnReqMsgMgr *)handle;
320 APPSPAWN_CHECK(reqMgr != NULL, return APPSPAWN_SYSTEM_ERROR, "Invalid reqMgr");
322 if (reqMgr->type < sizeof(g_clientInstance) / sizeof(g_clientInstance[0])) {
323 g_clientInstance[reqMgr->type] = NULL;
326 pthread_mutex_destroy(&reqMgr->mutex);
327 if (reqMgr->socketId >= 0) {
328 CloseClientSocket(reqMgr->socketId);
329 reqMgr->socketId = -1;
331 free(reqMgr);
341 AppSpawnReqMsgMgr *reqMgr = (AppSpawnReqMsgMgr *)handle;
342 APPSPAWN_CHECK(reqMgr != NULL, AppSpawnReqMsgFree(reqHandle);
343 return APPSPAWN_ARG_INVALID, "Invalid reqMgr");
350 pthread_mutex_lock(&reqMgr->mutex);
351 int ret = ClientSendMsg(reqMgr, reqNode, result);
355 pthread_mutex_unlock(&reqMgr->mutex);