--- mqtt/src/client.c 2012/01/30 22:58:24 1.2.2.1 +++ mqtt/src/client.c 2012/04/24 08:06:08 1.2.2.2 @@ -77,7 +77,7 @@ CloseClient(int sock) return -1; } - siz = send(sock, args->msg->msg_base, siz, 0); + siz = send(sock, args->msg->msg_base, siz, MSG_NOSIGNAL); if (siz == -1) { printf("Error:: send() #%d - %s\n", errno, strerror(errno)); return -1; @@ -164,7 +164,7 @@ CloseFile(void) inline int SendTo(int sock, int siz) { - siz = send(sock, args->msg->msg_base, siz, 0); + siz = send(sock, args->msg->msg_base, siz, MSG_NOSIGNAL); if (siz == -1) { printf("Error:: send() #%d - %s\n", errno, strerror(errno)); return -1;