--- mqtt/src/client.c 2012/01/05 10:26:02 1.1.2.12 +++ 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,12 +164,12 @@ 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; } else - ioVERBOSE(3) printf("Sended PUBLISH %d bytes\n", siz); + ioVERBOSE(3) printf("Sended %d bytes\n", siz); return siz; }