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

Diff for /mqtt/src/mqtt_subs.c between versions 1.1.2.1 and 1.2.2.2

version 1.1.2.1, 2011/12/20 16:04:34 version 1.2.2.2, 2012/04/24 13:54:50
Line 7 Line 7
 io_enableDEBUG;  io_enableDEBUG;
   
 extern char compiled[], compiledby[], compilehost[];  extern char compiled[], compiledby[], compilehost[];
intptr_t Kill;volatile intptr_t Kill;
   
 struct tagArgs *args;  struct tagArgs *args;
   
Line 181  main(int argc, char **argv) Line 181  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);
   
         if ((sock = InitClient()) == -1) {          if ((sock = InitClient()) == -1) {
                 args->free(args);                  args->free(args);
Line 189  main(int argc, char **argv) Line 190  main(int argc, char **argv)
                 return 2;                  return 2;
         }          }
   
        printf("Connected ... ");        switch ((ret = ConnectClient(sock))) {
        switch ((ret = try2Connect(sock))) { 
                 case -1:                  case -1:
                         printf(">> FAILED!\n");                          printf(">> FAILED!\n");
                         break;                          break;
Line 222  main(int argc, char **argv) Line 222  main(int argc, char **argv)
                 if (lf) {                  if (lf) {
                         ret = Subscribe(sock, lf);                          ret = Subscribe(sock, lf);
                         fclose(lf);                          fclose(lf);
                         shutdown(sock, SHUT_RDWR);  
                 } else                  } else
                         printf("Error:: in subscribe file #%d - %s\n", errno, strerror(errno));                          printf("Error:: in subscribe file #%d - %s\n", errno, strerror(errno));
        } else                CloseClient(sock);
         } else {
                 close(sock);
                 ret = 3;                  ret = 3;
           }
   
         close(sock);  
         args->free(args);          args->free(args);
         free(args);          free(args);
         return ret;          return ret;
Removed from v.1.1.2.1  
changed lines
  Added in v.1.2.2.2

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