[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.2.2.2 and 1.2.2.3

version 1.2.2.2, 2012/04/24 08:06:08 version 1.2.2.3, 2012/04/27 10:07:50
Line 89  CloseClient(int sock) Line 89  CloseClient(int sock)
         return siz;          return siz;
 }  }
   
 int  
 KAClient(int sock)  
 {  
         int siz = 0;  
         struct pollfd pfd;  
   
         siz = mqtt_msgPINGREQ(args->msg);  
         if (siz == -1) {  
                 printf("Error:: msgPINGREQ #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());  
                 return -1;  
         }  
         if (SendTo(sock, siz) == -1)  
                 return -1;  
   
         pfd.fd = sock;  
         pfd.events = POLLIN | POLLPRI;  
         switch (poll(&pfd, 1, args->ka * 1000)) {  
                 case -1:  
                         printf("Error:: poll() #%d - %s\n", errno, strerror(errno));  
                         return -1;  
                 case 0:  
                         ioVERBOSE(3) printf("Timeout reached (%d) ...\n", args->ka * 1000);  
                         return -1;  
         }  
         if (pfd.revents & (POLLERR | POLLHUP | POLLNVAL))  
                 return -1;  
   
         siz = recv(sock, args->msg->msg_base, args->msg->msg_len, 0);  
         if (siz == -1) {  
                 printf("Error:: recv() #%d - %s\n", errno, strerror(errno));  
                 return -1;  
         } else  
                 ioVERBOSE(3) printf("Received %d bytes\n", siz);  
   
         return mqtt_readPINGRESP(args->msg);  
 }  
   
 void *  void *
 OpenFile(void)  OpenFile(void)
 {  {
Line 189  RecvFrom(int sock) Line 152  RecvFrom(int sock)
                                 return -1;                                  return -1;
                         case 0:                          case 0:
                                 ioVERBOSE(3) printf("Timeout reached (%d) ...\n", args->ka * 1000);                                  ioVERBOSE(3) printf("Timeout reached (%d) ...\n", args->ka * 1000);
                                if (KAClient(sock) == -1)                                if (mqtt_KeepAlive(sock, args->ka, 1) == -1)
                                         return -1;                                          return -1;
                                 continue;                                  continue;
                 }                  }
Removed from v.1.2.2.2  
changed lines
  Added in v.1.2.2.3

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