[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.6 and 1.1.2.7

version 1.1.2.6, 2011/12/05 14:11:47 version 1.1.2.7, 2011/12/05 15:30:49
Line 392  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short  Line 392  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short 
   
         return flg;          return flg;
 }  }
   
   /*
    * mqtt_readCONNACK() Read CONNACK message
    *
    * @buf = Message buffer
    * return: -1 error or >-1 CONNECT message return code
    */
   u_char
   mqtt_readCONNACK(mqtt_msg_t * __restrict buf)
   {
           int len, ret;
           struct mqtthdr *hdr;
           mqtthdr_connack_t *ack;
           caddr_t pos;
   
           if (!buf || !buf->msg_base || !buf->msg_len)
                   return (u_char) -1;
   
           hdr = (struct mqtthdr*) buf->msg_base;
           if (hdr->mqtt_msg.type != MQTT_TYPE_CONNACK) {
                   mqtt_SetErr(EINVAL, "Error:: wrong command #%d", hdr->mqtt_msg.type);
                   return (u_char) -1;
           } else
                   len = mqtt_decodeLen(hdr->mqtt_len, &ret);
           if (len < sizeof(mqtthdr_connack_t)) {
                   mqtt_SetErr(EINVAL, "Error:: short message length %d", len);
                   return (u_char) -1;
           } else {
                   pos = buf->msg_base + ret + 1;
                   ack = (mqtthdr_connack_t*) pos;
           }
   
           if (ack->retcode > MQTT_RETCODE_DENIED) {
                   mqtt_SetErr(EINVAL, "Error:: invalid retcode %u", ack->retcode);
                   return (u_char) -1;
           }
   
           return ack->retcode;
   }
Removed from v.1.1.2.6  
changed lines
  Added in v.1.1.2.7

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