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

Diff for /mqtt/src/mqtt_ping.c between versions 1.1.2.3 and 1.1.2.4

version 1.1.2.3, 2012/04/26 09:15:26 version 1.1.2.4, 2012/05/01 22:19:29
Line 38  cleanArgs(struct tagArgs * __restrict args) Line 38  cleanArgs(struct tagArgs * __restrict args)
 static int  static int
 Ping(int sock, int num)  Ping(int sock, int num)
 {  {
         int siz = 0;  
         struct timeval before, after;          struct timeval before, after;
         ait_val_t val;          ait_val_t val;
         struct mqtthdr *hdr;  
   
         gettimeofday(&before, NULL);          gettimeofday(&before, NULL);
   
        siz = mqtt_msgPINGREQ(args->msg);        if (mqtt_KeepAlive(args->cli->sock, args->ka, 1) == -1)
        if (siz == -1) { 
                printf("Error:: msgPINGREQ #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); 
                 return -1;                  return -1;
         }  
         if (SendTo(sock, siz) == -1)  
                 return -1;  
   
 reply:  
         if ((siz = RecvFrom(sock)) == -1 || !siz)  
                 return -1;  
         else  
                 hdr = (struct mqtthdr*) args->msg->msg_base;  
         if (hdr->mqtt_msg.type == MQTT_TYPE_PINGREQ) {  
                 siz = mqtt_msgPINGRESP(args->msg);  
                 if (siz == -1) {  
                         printf("Error:: msgPINGRESP #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());  
                         return -1;  
                 }  
                 if (SendTo(sock, siz) == -1)  
                         return -1;  
   
                 goto reply;  
         } else {  
                 siz = mqtt_readPINGRESP(args->msg);  
                 if (siz == -1) {  
                         printf("Error:: readPINGRESP #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());  
                         return -1;  
                 }  
         }  
   
         gettimeofday(&after, NULL);          gettimeofday(&after, NULL);
   
         printf(" + Ping %d MQTT broker %s ... %f sec.\n", num, io_n2addr(&args->addr, &val),           printf(" + Ping %d MQTT broker %s ... %f sec.\n", num, io_n2addr(&args->addr, &val), 
Line 92  main(int argc, char **argv) Line 62  main(int argc, char **argv)
         char ch;          char ch;
         ait_val_t val;          ait_val_t val;
         u_short port = atoi(MQTT_PORT);          u_short port = atoi(MQTT_PORT);
        int sock, num = 1, ret = 0, lost = 0;        int num = 1, ret = 0, lost = 0;
         register int i;          register int i;
   
         if (!(args = malloc(sizeof(struct tagArgs)))) {          if (!(args = malloc(sizeof(struct tagArgs)))) {
Line 164  main(int argc, char **argv) Line 134  main(int argc, char **argv)
         printf("Connecting to %s:%d ... ", io_n2addr(&args->addr, &val), io_n2port(&args->addr));          printf("Connecting to %s:%d ... ", io_n2addr(&args->addr, &val), io_n2port(&args->addr));
         AIT_FREE_VAL(&val);          AIT_FREE_VAL(&val);
   
        if ((sock = InitClient()) == -1) {        if (!(args->cli = mqtt_cli_Open(&args->addr.sa))) {
                 args->free(args);                  args->free(args);
                 free(args);                  free(args);
                 return 2;                  return 2;
         }          }
   
        switch ((ret = ConnectClient(sock))) {        switch ((ret = ConnectClient(args->cli->sock))) {
                 case -1:                  case -1:
                         printf(">> FAILED!\n");                          printf(">> FAILED!\n");
                         break;                          break;
Line 196  main(int argc, char **argv) Line 166  main(int argc, char **argv)
   
         if (ret == MQTT_RETCODE_ACCEPTED) {          if (ret == MQTT_RETCODE_ACCEPTED) {
                 for (i = 0; i < num; i++)                  for (i = 0; i < num; i++)
                        if ((ret = Ping(sock, i))) {                        if ((ret = Ping(args->cli->sock, i))) {
                                 ret = 3;                                  ret = 3;
                                 lost++;                                  lost++;
                         }                          }
                 CloseClient(sock);  
   
                 printf("\nMQTT ping sended %d requests with %d lost responses\n", num, lost);                  printf("\nMQTT ping sended %d requests with %d lost responses\n", num, lost);
        } else {        } else
                close(sock); 
                 ret = 4;                  ret = 4;
        }
         mqtt_cli_Close(&args->cli);
   
         args->free(args);          args->free(args);
         free(args);          free(args);
Removed from v.1.1.2.3  
changed lines
  Added in v.1.1.2.4

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