Lines Matching defs:socketId
60 int socketId;
117 clientInstance->socketId = -1;
153 if (reqMgr->socketId >= 0) {
154 CloseClientSocket(reqMgr->socketId);
155 reqMgr->socketId = -1;
161 static void CloseClientSocket(int socketId)
163 printf("Closed socket with fd %d \n", socketId);
164 if (socketId >= 0) {
166 setsockopt(socketId, IPPROTO_TCP, TCP_NODELAY, (char *)&flag, sizeof(int));
167 close(socketId);
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)
299 int ret = WriteMessage(socketId, sendBlock->buffer, sendBlock->currentIndex,
339 if (reqMgr->socketId < 0) { // try create socket
341 if (reqMgr->socketId < 0) {
351 int ret = HandleMsgSend(reqMgr, reqMgr->socketId, reqNode);
353 ret = ReadMessage(reqMgr->socketId, reqNode->msg->msgId,
360 CloseClientSocket(reqMgr->socketId);
361 reqMgr->socketId = -1;