[BACK]Return to client.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Diff for /mqtt/src/client.c between versions 1.1.2.6 and 1.1.2.7

version 1.1.2.6, 2011/12/14 12:45:30 version 1.1.2.7, 2011/12/14 15:09:31
Line 27  try2Connect(int sock) Line 27  try2Connect(int sock)
         struct pollfd pfd;          struct pollfd pfd;
   
         printf("ka=%d\n", args->ka);          printf("ka=%d\n", args->ka);
        siz = mqtt_msgCONNECT(args->msg, AIT_GET_STR(&args->ConnID), args->ka,         siz = mqtt_msgCONNECT(args->msg, (char*) AIT_GET_STR(&args->ConnID), args->ka, 
                        AIT_GET_STR(&args->User), AIT_GET_STR(&args->Pass),                         (char*) AIT_GET_STR(&args->User), (char*) AIT_GET_STR(&args->Pass), 
                        args->Will.Topic.val.string, args->Will.Msg.val.string,                         (char*) args->Will.Topic.val.string, (char*) args->Will.Msg.val.string, 
                         !args->notClear, args->QoS, args->Retain);                          !args->notClear, args->QoS, args->Retain);
         if (siz == -1) {          if (siz == -1) {
                 printf("Error:: msgCONNECT #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());                  printf("Error:: msgCONNECT #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
Line 41  try2Connect(int sock) Line 41  try2Connect(int sock)
                 printf("Error:: send() #%d - %s\n", errno, strerror(errno));                  printf("Error:: send() #%d - %s\n", errno, strerror(errno));
                 return -1;                  return -1;
         } else          } 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);          printf("ka=%d\n", args->ka);
         pfd.fd = sock;          pfd.fd = sock;
Line 52  try2Connect(int sock) Line 52  try2Connect(int sock)
                         return -1;                          return -1;
                 case 0:                  case 0:
         printf("ka=%d\n", args->ka);          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;                          return -1;
         }          }
         if (pfd.revents & (POLLERR | POLLHUP | POLLNVAL))          if (pfd.revents & (POLLERR | POLLHUP | POLLNVAL))
Line 63  try2Connect(int sock) Line 63  try2Connect(int sock)
                 printf("Error:: recv() #%d - %s\n", errno, strerror(errno));                  printf("Error:: recv() #%d - %s\n", errno, strerror(errno));
                 return -1;                  return -1;
         } else          } else
                VERB(3) printf("Received %d bytes\n", siz);                ioVERBOSE(3) printf("Received %d bytes\n", siz);
   
         return (u_char) mqtt_readCONNACK(args->msg);          return (u_char) mqtt_readCONNACK(args->msg);
 }  }
Removed from v.1.1.2.6  
changed lines
  Added in v.1.1.2.7

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>