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

Diff for /mqtt/src/Attic/conn.c between versions 1.1.2.4 and 1.1.2.5

version 1.1.2.4, 2011/11/22 14:00:09 version 1.1.2.5, 2011/11/22 14:13:04
Line 179  mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, u_char re Line 179  mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, u_char re
   
         return siz;          return siz;
 }  }
   
   static int
   _mqtt_msgSIMPLE_(mqtt_msg_t * __restrict buf, u_char cmd)
   {
           int siz = 0;
           struct mqtthdr *hdr;
   
           if (!buf)
                   return -1;
   
           if (mqtt_msgRealloc(buf, sizeof(struct mqtthdr)) == -1)
                   return -1;
           else {
                   hdr = (struct mqtthdr *) (buf->msg_base + siz);
                   siz += sizeof(struct mqtthdr);
           }
   
           /* fixed header */
           MQTTHDR_MSGINIT(hdr);
           hdr->mqtt_msg.type = cmd;
           *hdr->mqtt_len = 0;
   
           return siz;
   }
   
   /*
    * mqtt_msgPINGREQ() Create PINGREQ message
    *
    * @buf = Message buffer
    * return: -1 error or >-1 message size for send
    */
   int
   mqtt_msgPINGREQ(mqtt_msg_t * __restrict buf)
   {
           return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_PINGREQ);
   }
   
   /*
    * mqtt_msgPINGRESP() Create PINGRESP message
    *
    * @buf = Message buffer
    * return: -1 error or >-1 message size for send
    */
   int
   mqtt_msgPINGRESP(mqtt_msg_t * __restrict buf)
   {
           return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_PINGRESP);
   }
   
   /*
    * mqtt_msgDISCONNECT() Create DISCONNECT message
    *
    * @buf = Message buffer
    * return: -1 error or >-1 message size for send
    */
   int
   mqtt_msgDISCONNECT(mqtt_msg_t * __restrict buf)
   {
           return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_DISCONNECT);
   }
Removed from v.1.1.2.4  
changed lines
  Added in v.1.1.2.5

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