[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.1 and 1.1.2.5

version 1.1.2.1, 2012/01/30 13:39:22 version 1.1.2.5, 2012/05/03 13:39:35
Line 16  Usage(void) Line 16  Usage(void)
         printf( " -= MQTT PING =- MQTT Ping from ELWIX\n"          printf( " -= MQTT PING =- MQTT Ping from ELWIX\n"
                 "=== %s@%s === Compiled: %s ===\n\n"                  "=== %s@%s === Compiled: %s ===\n\n"
                 " Syntax: mqtt_ping [options] <connect_to_broker[:port]> <ConnectID>\n\n"                  " Syntax: mqtt_ping [options] <connect_to_broker[:port]> <ConnectID>\n\n"
                   "\t-c <num>\t\tNumber of ping requests (default: 1)\n"
                 "\t-p <port>\t\tDifferent port for connect (default: 1883)\n"                  "\t-p <port>\t\tDifferent port for connect (default: 1883)\n"
                 "\t-T <timeout>\t\tKeep alive timeout in seconds (default: 10sec)\n"                  "\t-T <timeout>\t\tKeep alive timeout in seconds (default: 10sec)\n"
                 "\t-U <username>\t\tUsername\n"                  "\t-U <username>\t\tUsername\n"
Line 35  cleanArgs(struct tagArgs * __restrict args) Line 36  cleanArgs(struct tagArgs * __restrict args)
 }  }
   
 static int  static int
Ping(int sock)Ping(int sock, int num, struct timeval * __restrict accu)
 {  {
        int siz = 0;        struct timeval before, after, calc;
        struct timeval before, after; 
         ait_val_t val;          ait_val_t val;
   
         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;  
   
         if ((siz = RecvFrom(sock)) == -1 || !siz)  
                 return -1;  
         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 MQTT broker %s ... %f sec.\n", io_n2addr(&args->addr, &val),         timersub(&after, &before, &calc);
                        ((after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6));        timeradd(accu, &calc, accu);
 
         printf(" + Ping %d MQTT broker %s ... %f sec.\n", num, io_n2addr(&args->addr, &val), 
                         calc.tv_sec + calc.tv_usec / 1.e6);
         AIT_FREE_VAL(&val);          AIT_FREE_VAL(&val);
   
         return 0;          return 0;
Line 75  main(int argc, char **argv) Line 65  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, ret = 0;        int num = 1, ret = 0, lost = 0;
         register int i;
         struct timeval accu;
   
         if (!(args = malloc(sizeof(struct tagArgs)))) {          if (!(args = malloc(sizeof(struct tagArgs)))) {
                 printf("Error:: in alloc arguments #%d - %s\n", errno, strerror(errno));                  printf("Error:: in alloc arguments #%d - %s\n", errno, strerror(errno));
Line 96  main(int argc, char **argv) Line 88  main(int argc, char **argv)
         AIT_SET_STR(&args->Pass, "");          AIT_SET_STR(&args->Pass, "");
   
         args->ka = MQTT_KEEPALIVE;          args->ka = MQTT_KEEPALIVE;
        while ((ch = getopt(argc, argv, "T:U:P:p:vh")) != -1)        while ((ch = getopt(argc, argv, "T:U:P:p:c:vh")) != -1)
                 switch (ch) {                  switch (ch) {
                           case 'c':
                                   num = (int) strtol(optarg, NULL, 0);
                                   break;
                         case 'T':                          case 'T':
                                 args->ka = (u_short) strtol(optarg, NULL, 0);                                  args->ka = (u_short) strtol(optarg, NULL, 0);
                                 break;                                  break;
Line 141  main(int argc, char **argv) Line 136  main(int argc, char **argv)
                 Usage();                  Usage();
                 return 1;                  return 1;
         }          }
        ioVERBOSE(1) printf("Connecting to %s:%d ...\n", 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 174  main(int argc, char **argv) Line 169  main(int argc, char **argv)
                         break;                          break;
         }          }
   
           timerclear(&accu);
         if (ret == MQTT_RETCODE_ACCEPTED) {          if (ret == MQTT_RETCODE_ACCEPTED) {
                ret = Ping(sock) ? 3 : 0;                for (i = 0; i < num; i++)
                CloseClient(sock);                        if ((ret = Ping(args->cli->sock, i, &accu))) {
        } else {                                ret = 3;
                close(sock);                                lost++;
                         }
                 printf("\nMQTT ping sended %d requests with %d lost responses and avarage %f sec.\n", 
                                 num, lost, (accu.tv_sec + accu.tv_usec / 1.e6) / (num - lost));
         } else
                 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.1  
changed lines
  Added in v.1.1.2.5

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