[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.5 and 1.2.2.6

version 1.2.2.5, 2012/05/08 11:45:57 version 1.2.2.6, 2012/05/09 13:57:39
Line 19  Usage(void) Line 19  Usage(void)
                 " Syntax: mqtt_pub [options] <connect_to_broker[:port]> <ConnectID> <topic> <value_for_publish>\n\n"                  " Syntax: mqtt_pub [options] <connect_to_broker[:port]> <ConnectID> <topic> <value_for_publish>\n\n"
                 "\t-f\t\t\t'value_for_publish' is file name instead text\n"                  "\t-f\t\t\t'value_for_publish' is file name instead text\n"
                 "\t-q <QoS>\t\tQoS level (0-at most 1, 1-at least 1, 2-exactly 1)\n"                  "\t-q <QoS>\t\tQoS level (0-at most 1, 1-at least 1, 2-exactly 1)\n"
                 "\t-m <message_id>\t\tMessage ID for publish message\n"  
                 "\t-d\t\t\tSend duplicate message\n"                  "\t-d\t\t\tSend duplicate message\n"
                 "\t-r\t\t\tRetain message from broker\n\n"                  "\t-r\t\t\tRetain message from broker\n\n"
                 "\t-C\t\t\tNot clear before connect!!!\n"                  "\t-C\t\t\tNot clear before connect!!!\n"
Line 51  static int Line 50  static int
 Publish(int sock)  Publish(int sock)
 {  {
         int siz = 0;          int siz = 0;
           u_short mid = 0;
   
        siz = mqtt_msgPUBLISH(args->msg, AIT_GET_STR(&args->Publish), args->MsgID, args->Dup,         srandomdev();
                        args->QoS, args->Retain, AIT_ADDR(&args->Value), AIT_LEN(&args->Value));        mid = random() % USHRT_MAX;
 
         printf(" > Execute PUBLISH request #%d ... ", mid);
         siz = mqtt_cli_Publish(args->cli, mid, args->Dup, args->QoS, args->Retain, 
                         AIT_GET_STR(&args->Publish), AIT_ADDR(&args->Value), AIT_LEN(&args->Value));
         if (siz == -1) {          if (siz == -1) {
                printf("Error:: msgPUBLISH #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());                printf("Error:: Publish #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
                 return -1;                  return -1;
        }        } else
        if (SendTo(sock, siz) == -1)                printf("OK\n");
                return -1; 
        /* QoS == MQTT_QOS_ONCE, no wait for reply */ 
        if (args->QoS == MQTT_QOS_ONCE) 
                return 0; 
   
        if ((siz = RecvFrom(sock)) == -1 || !siz)        return siz;
                return -1; 
        /* QoS == MQTT_QOS_ACK, wait for PUBACK */ 
        if (args->QoS == MQTT_QOS_ACK) { 
                siz = mqtt_readPUBACK(args->msg); 
                if (siz == args->MsgID) 
                        return siz; 
                if (!args->Dup) { 
                        args->Dup++; 
                        return Publish(sock); 
                } 
                goto end; 
        } 
 
 
        /* QoS == MQTT_QOS_EXACTLY */ 
        siz = mqtt_readPUBREC(args->msg); 
        if (siz != args->MsgID) { 
                if (!args->Dup) { 
                        args->Dup++; 
                        return Publish(sock); 
                } 
                goto end; 
        } 
 
        do { 
                siz = mqtt_msgPUBREL(args->msg, args->MsgID); 
                if (siz == -1) { 
                        printf("Error:: msgPUBREL #%d - %s\n", mqtt_GetErrno(), mqtt_GetError()); 
                        return -1; 
                } 
                if (SendTo(sock, siz) == -1) 
                        return -1; 
 
                if ((siz = RecvFrom(sock)) == -1 || !siz) 
                        return -1; 
 
                siz = mqtt_readPUBCOMP(args->msg); 
                if (siz == args->MsgID) 
                        return siz; 
                if (!args->Dup) { 
                        args->Dup++; 
                        continue; 
                } 
        } while (0); 
 
end: 
        printf("Error:: Message not delivered\n"); 
        return -1; 
 }  }
   
   
Line 143  main(int argc, char **argv) Line 95  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:q:drCW:M:m:fvh")) != -1)        while ((ch = getopt(argc, argv, "T:U:P:p:q:drCW:M:fvh")) != -1)
                 switch (ch) {                  switch (ch) {
                         case 'T':                          case 'T':
                                 args->ka = (u_short) strtol(optarg, NULL, 0);                                  args->ka = (u_short) strtol(optarg, NULL, 0);
Line 164  main(int argc, char **argv) Line 116  main(int argc, char **argv)
                                 AIT_FREE_VAL(&args->Pass);                                  AIT_FREE_VAL(&args->Pass);
                                 AIT_SET_STR(&args->Pass, optarg);                                  AIT_SET_STR(&args->Pass, optarg);
                                 break;                                  break;
                         case 'm':  
                                 args->MsgID = (u_short) strtol(optarg, NULL, 0);  
                                 break;  
                         case 'p':                          case 'p':
                                 port = (u_short) strtol(optarg, NULL, 0);                                  port = (u_short) strtol(optarg, NULL, 0);
                                 break;                                  break;
Line 224  main(int argc, char **argv) Line 173  main(int argc, char **argv)
                 Usage();                  Usage();
                 return 1;                  return 1;
         }          }
         if (args->QoS && !args->MsgID)  
                 args->MsgID = MQTT_DEFAULT_MSGID;  
         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);
   
Line 267  main(int argc, char **argv) Line 214  main(int argc, char **argv)
         }          }
   
         if (ret == MQTT_RETCODE_ACCEPTED) {          if (ret == MQTT_RETCODE_ACCEPTED) {
                ret = !(Publish(args->cli->sock) == args->MsgID);                ret = (Publish(args->cli->sock) == -1);
         } else          } else
                 ret = 4;                  ret = 4;
   
Removed from v.1.2.2.5  
changed lines
  Added in v.1.2.2.6

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