Lines Matching defs:msg
248 struct msghdr msg = {
254 msg.msg_controllen = CMSG_SPACE(*fdCount * sizeof(int));
255 ctrlBuffer = (char *) malloc(msg.msg_controllen);
257 printf("WriteMessage fail to alloc memory for msg_control %d %d", msg.msg_controllen, errno);
260 msg.msg_control = ctrlBuffer;
261 struct cmsghdr *cmsg = CMSG_FIRSTHDR(&msg);
280 wLen = sendmsg(socketFd, &msg, MSG_NOSIGNAL);
293 printf("HandleMsgSend reqId: %u msgId: %d \n", reqNode->reqId, reqNode->msg->msgId);
303 printf("Write msg ret: %d msgId: %u %u %u \n",
304 ret, reqNode->msg->msgId, reqNode->msg->msgLen, currentIndex);
310 printf("Send msg fail reqId: %u msgId: %d ret: %d \n",
311 reqNode->reqId, reqNode->msg->msgId, ret);
326 ResponseMsg *msg = (ResponseMsg *)(buf);
327 if (sendMsgId != msg->msgHdr.msgId) {
328 printf("Invalid msg recvd %u %u \n", sendMsgId, msg->msgHdr.msgId);
329 return memcpy_s(result, sizeof(Result), &msg->result, sizeof(msg->result));
348 if (reqNode->msg->msgId == 0) {
349 reqNode->msg->msgId = reqMgr->msgNextId++;
353 ret = ReadMessage(reqMgr->socketId, reqNode->msg->msgId,
363 reqNode->msg->msgId = 0;