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

Diff for /libaitmqtt/src/pub.c between versions 1.1.1.1.2.6 and 1.2.2.1

version 1.1.1.1.2.6, 2012/06/19 15:41:15 version 1.2.2.1, 2012/06/21 13:47:30
Line 64  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha Line 64  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha
                 u_char Dup, u_char QOS, u_char Retain, const void *pData, int datlen)                  u_char Dup, u_char QOS, u_char Retain, const void *pData, int datlen)
 {  {
         int len, siz;          int len, siz;
           u_int n, *l;
         struct mqtthdr *hdr;          struct mqtthdr *hdr;
         mqtthdr_var_t *topic;          mqtthdr_var_t *topic;
         mqtt_len_t *mid;          mqtt_len_t *mid;
Line 71  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha Line 72  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha
   
         if (!buf || !csTopic)          if (!buf || !csTopic)
                 return -1;                  return -1;
         else  
                 data = buf->msg_base;  
         if (QOS > MQTT_QOS_EXACTLY) {          if (QOS > MQTT_QOS_EXACTLY) {
                 mqtt_SetErr(EINVAL, "Invalid QoS parameter");                  mqtt_SetErr(EINVAL, "Invalid QoS parameter");
                 return -1;                  return -1;
Line 89  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha Line 88  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha
   
         /* calculate header size */          /* calculate header size */
         siz = sizeof(struct mqtthdr);                   /* mqtt fixed header */          siz = sizeof(struct mqtthdr);                   /* mqtt fixed header */
        siz += mqtt_sizeLen(mqtt_encodeLen(len)) - 1;  /* length size */        n = mqtt_encodeLen(len);                        /* message size */
         siz += mqtt_sizeLen(n) - 1;                  /* length size */
   
         if (mqtt_msgRealloc(buf, siz + len) == -1)          if (mqtt_msgRealloc(buf, siz + len) == -1)
                 return -1;                  return -1;
        else        else {
                 data = buf->msg_base;
                 hdr = (struct mqtthdr *) data;                  hdr = (struct mqtthdr *) data;
           }
   
         /* fixed header */          /* fixed header */
         MQTTHDR_MSGINIT(hdr);          MQTTHDR_MSGINIT(hdr);
Line 102  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha Line 104  mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha
         hdr->mqtt_msg.qos = QOS;          hdr->mqtt_msg.qos = QOS;
         hdr->mqtt_msg.dup = Dup ? 1 : 0;          hdr->mqtt_msg.dup = Dup ? 1 : 0;
         hdr->mqtt_msg.retain = Retain ? 1 : 0;          hdr->mqtt_msg.retain = Retain ? 1 : 0;
        *hdr->mqtt_len = mqtt_encodeLen(len);        l = (u_int*) hdr->mqtt_len;
         *l = n;
         data += siz;          data += siz;
   
         /* variable header */          /* variable header */
Removed from v.1.1.1.1.2.6  
changed lines
  Added in v.1.2.2.1

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