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

Diff for /mqtt/src/mqtt_pub.c between versions 1.2.2.6 and 1.2.2.7

version 1.2.2.6, 2012/05/09 13:57:39 version 1.2.2.7, 2012/05/27 10:04:05
Line 76  main(int argc, char **argv) Line 76  main(int argc, char **argv)
         u_short port = atoi(MQTT_PORT);          u_short port = atoi(MQTT_PORT);
         int ret = 0;          int ret = 0;
   
        if (!(args = malloc(sizeof(struct tagArgs)))) {        if (!(args = io_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));
                 return 1;                  return 1;
         } else          } else
Line 86  main(int argc, char **argv) Line 86  main(int argc, char **argv)
         if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) {          if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) {
                 printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());                  printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
                 args->free(args);                  args->free(args);
                free(args);                io_free(args);
                 return 1;                  return 1;
         }          }
   
Line 124  main(int argc, char **argv) Line 124  main(int argc, char **argv)
                                 if (args->QoS > MQTT_QOS_EXACTLY) {                                  if (args->QoS > MQTT_QOS_EXACTLY) {
                                         printf("Error:: invalid QoS level %d\n", args->QoS);                                          printf("Error:: invalid QoS level %d\n", args->QoS);
                                         args->free(args);                                          args->free(args);
                                        free(args);                                        io_free(args);
                                         return 1;                                          return 1;
                                 }                                  }
                                 break;                                  break;
Line 146  main(int argc, char **argv) Line 146  main(int argc, char **argv)
                         case 'h':                          case 'h':
                         default:                          default:
                                 args->free(args);                                  args->free(args);
                                free(args);                                io_free(args);
                                 Usage();                                  Usage();
                                 return 1;                                  return 1;
                 }                  }
Line 155  main(int argc, char **argv) Line 155  main(int argc, char **argv)
         if (argc < 4) {          if (argc < 4) {
                 printf("Error:: host for connect not found, connection id, topic or value not supplied!\n\n");                  printf("Error:: host for connect not found, connection id, topic or value not supplied!\n\n");
                 args->free(args);                  args->free(args);
                free(args);                io_free(args);
                 Usage();                  Usage();
                 return 1;                  return 1;
         } else {          } else {
Line 169  main(int argc, char **argv) Line 169  main(int argc, char **argv)
         if (!io_gethostbyname(*argv, port, &args->addr)) {          if (!io_gethostbyname(*argv, port, &args->addr)) {
                 printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError());                  printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError());
                 args->free(args);                  args->free(args);
                free(args);                io_free(args);
                 Usage();                  Usage();
                 return 1;                  return 1;
         }          }
Line 178  main(int argc, char **argv) Line 178  main(int argc, char **argv)
   
         if (!(args->cli = mqtt_cli_Open(&args->addr.sa, args->ka))) {          if (!(args->cli = mqtt_cli_Open(&args->addr.sa, args->ka))) {
                 args->free(args);                  args->free(args);
                free(args);                io_free(args);
                 return 2;                  return 2;
         }          }
   
         if (args->isFile && !OpenFile()) {          if (args->isFile && !OpenFile()) {
                 mqtt_cli_Close(&args->cli);                  mqtt_cli_Close(&args->cli);
                 args->free(args);                  args->free(args);
                free(args);                io_free(args);
                 return 3;                  return 3;
         }          }
   
Line 222  main(int argc, char **argv) Line 222  main(int argc, char **argv)
   
         CloseFile();          CloseFile();
         args->free(args);          args->free(args);
        free(args);        io_free(args);
         return ret;          return ret;
 }  }
Removed from v.1.2.2.6  
changed lines
  Added in v.1.2.2.7

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