--- mqtt/src/client.c 2011/12/14 12:45:30 1.1.2.6 +++ mqtt/src/client.c 2011/12/20 15:03:42 1.1.2.8 @@ -26,10 +26,9 @@ try2Connect(int sock) int siz = 0; struct pollfd pfd; - printf("ka=%d\n", args->ka); - siz = mqtt_msgCONNECT(args->msg, AIT_GET_STR(&args->ConnID), args->ka, - AIT_GET_STR(&args->User), AIT_GET_STR(&args->Pass), - args->Will.Topic.val.string, args->Will.Msg.val.string, + siz = mqtt_msgCONNECT(args->msg, (char*) AIT_GET_STR(&args->ConnID), args->ka, + (char*) AIT_GET_STR(&args->User), (char*) AIT_GET_STR(&args->Pass), + (char*) args->Will.Topic.val.string, (char*) args->Will.Msg.val.string, !args->notClear, args->QoS, args->Retain); if (siz == -1) { printf("Error:: msgCONNECT #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); @@ -41,9 +40,8 @@ try2Connect(int sock) printf("Error:: send() #%d - %s\n", errno, strerror(errno)); return -1; } else - VERB(3) printf("Sended CONNECT %d bytes\n", siz); + ioVERBOSE(3) printf("Sended CONNECT %d bytes\n", siz); - printf("ka=%d\n", args->ka); pfd.fd = sock; pfd.events = POLLIN; switch (poll(&pfd, 1, args->ka * 1000)) { @@ -51,8 +49,7 @@ try2Connect(int sock) printf("Error:: poll() #%d - %s\n", errno, strerror(errno)); return -1; case 0: - printf("ka=%d\n", args->ka); - VERB(3) printf("Timeout reached (%d) ...\n", args->ka * 1000); + ioVERBOSE(3) printf("Timeout reached (%d) ...\n", args->ka * 1000); return -1; } if (pfd.revents & (POLLERR | POLLHUP | POLLNVAL)) @@ -63,7 +60,7 @@ try2Connect(int sock) printf("Error:: recv() #%d - %s\n", errno, strerror(errno)); return -1; } else - VERB(3) printf("Received %d bytes\n", siz); + ioVERBOSE(3) printf("Received %d bytes\n", siz); return (u_char) mqtt_readCONNACK(args->msg); }