Lines Matching refs:reqMgr
143 int ClientDestroy(ReqMsgMgr *reqMgr)
145 if (reqMgr == NULL) {
146 printf("Invalid reqMgr \n");
152 pthread_mutex_destroy(&reqMgr->mutex);
153 if (reqMgr->socketId >= 0) {
154 CloseClientSocket(reqMgr->socketId);
155 reqMgr->socketId = -1;
157 free(reqMgr);
222 static void TryCreateSocket(ReqMsgMgr *reqMgr)
225 while (retryCount <= reqMgr->maxRetryCount) {
226 if (reqMgr->socketId < 0) {
227 reqMgr->socketId = CreateClientSocket(reqMgr->timeout);
229 if (reqMgr->socketId < 0) {
291 static int HandleMsgSend(ReqMsgMgr *reqMgr, int socketId, ReqMsgNode *reqNode)
335 static int ClientSendMsg(ReqMsgMgr *reqMgr, ReqMsgNode *reqNode, Result *result)
338 while (retryCount <= reqMgr->maxRetryCount) {
339 if (reqMgr->socketId < 0) { // try create socket
340 TryCreateSocket(reqMgr);
341 if (reqMgr->socketId < 0) {
349 reqNode->msg->msgId = reqMgr->msgNextId++;
351 int ret = HandleMsgSend(reqMgr, reqMgr->socketId, reqNode);
353 ret = ReadMessage(reqMgr->socketId, reqNode->msg->msgId,
354 reqMgr->recvBlock.buffer, reqMgr->recvBlock.blockSize, result);
360 CloseClientSocket(reqMgr->socketId);
361 reqMgr->socketId = -1;
362 reqMgr->msgNextId = 1;