[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.7

version 1.1.2.4, 2011/11/22 14:00:09 version 1.1.2.7, 2011/12/05 15:30:49
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);
   }
   
   /* ============= decode ============ */
   
   /*
    * mqtt_readCONNECT() Read elements from CONNECT message
    *
    * @buf = Message buffer
    * @kasec = Keep Alive in seconds for current connection
    * @psConnID = ConnectID
    * @connLen = ConnectID length
    * @psUser = Username if !=NULL
    * @userLen = Username length
    * @psPass = Password for Username, only if csUser is set
    * @passLen = Password length
    * @psWillTopic = Will Topic if !=NULL Will Flags set into message
    * @topicLen = Will Topic length
    * @psWillMessage = Will Message, may be NULL
    * @msgLen = Will Message length
    * return: .reserved == 1 is error or == 0 connection flags & msg ok
    */
   mqtthdr_connflgs_t
   mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short *kasec, char * __restrict psConnID, int connLen, 
                   char * __restrict psUser, int userLen, char * __restrict psPass, int passLen,  
                   char * __restrict psWillTopic, int topicLen, char * __restrict psWillMessage, int msgLen)
   {
           mqtthdr_connflgs_t flg = MQTT_CONNFLGS_INIT;
           struct mqtthdr *hdr;
           mqtthdr_var_t *var;
           mqtt_v_t *ka;
           mqtthdr_protover_t *proto;
           int len, ret;
           caddr_t pos;
   
           if (!buf || !buf->msg_base || !buf->msg_len || !psConnID || !connLen)
                   return flg;
   
           hdr = (struct mqtthdr*) buf->msg_base;
           if (hdr->mqtt_msg.type != MQTT_TYPE_CONNECT) {
                   mqtt_SetErr(EINVAL, "Error:: wrong command #%d", hdr->mqtt_msg.type);
                   return flg;
           } else
                   len = mqtt_decodeLen(hdr->mqtt_len, &ret);
           if (len < 12) {
                   mqtt_SetErr(EINVAL, "Error:: short message length %d", len);
                   return flg;
           } else {
                   pos = buf->msg_base + ret + 1;
                   var = (mqtthdr_var_t*) pos;
           }
           /* check init string & protocol */
           if (var->var_sb.sb.l != 6 || strncmp(var->var_data, MQTT_CONN_STR, 6)) {
                   mqtt_SetErr(EINVAL, "Error:: invalid init string %.6s(%d)", 
                                   var->var_data, var->var_sb.sb.l);
                   return flg;
           } else {
                   pos += var->var_sb.sb.l + sizeof(mqtt_v_t);
                   proto = (mqtthdr_protover_t*) pos;
           }
           if (*proto != MQTT_PROTO_VER) {
                   mqtt_SetErr(EINVAL, "Error:: invalid protocol version %d", *pos);
                   return flg;
           } else
                   pos++;
           flg = *(mqtthdr_connflgs_t*) pos;
           pos++;
           ka = (mqtt_v_t*) pos;
           *kasec = ntohs(ka->val);
           pos += sizeof(mqtt_v_t);
   
           len -= pos - (caddr_t) var;
   
           /* get ConnID */
           var = (mqtthdr_var_t*) pos;
           len -= MQTTHDR_VAR_SIZEOF(var);
           if (len < 0) {
                   mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Connection ID %d", len);
                   flg.reserved = 1;
                   return flg;
           } else {
                   memset(psConnID, 0, connLen--);
                   memcpy(psConnID, var->var_data, ntohs(var->var_sb.val) > connLen ? connLen : ntohs(var->var_sb.val));
                   pos += MQTTHDR_VAR_SIZEOF(var);
           }
   
           /* get Willz */
           if (flg.will_flg) {
                   var = (mqtthdr_var_t*) pos;
                   len -= MQTTHDR_VAR_SIZEOF(var);
                   if (len < 0) {
                           mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Will Topic %d", len);
                           flg.reserved = 1;
                           return flg;
                   } else {
                           if (psWillTopic && topicLen) {
                                   memset(psWillTopic, 0, topicLen--);
                                   memcpy(psWillTopic, var->var_data, 
                                                   ntohs(var->var_sb.val) > topicLen ? topicLen : ntohs(var->var_sb.val));
                           }
                           pos += MQTTHDR_VAR_SIZEOF(var);
                   }
   
                   var = (mqtthdr_var_t*) pos;
                   len -= MQTTHDR_VAR_SIZEOF(var);
                   if (len < 0) {
                           mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Will Message %d", len);
                           flg.reserved = 1;
                           return flg;
                   } else {
                           if (psWillMessage && msgLen) {
                                   memset(psWillMessage, 0, msgLen--);
                                   memcpy(psWillMessage, var->var_data, 
                                                   ntohs(var->var_sb.val) > msgLen ? msgLen : ntohs(var->var_sb.val));
                           }
                           pos += MQTTHDR_VAR_SIZEOF(var);
                   }
           }
   
           /* get User/Pass */
           if (flg.username) {
                   var = (mqtthdr_var_t*) pos;
                   len -= MQTTHDR_VAR_SIZEOF(var);
                   if (len < 0) {
                           mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Username %d", len);
                           flg.reserved = 1;
                           return flg;
                   } else {
                           if (psUser && userLen) {
                                   memset(psUser, 0, userLen--);
                                   memcpy(psUser, var->var_data, 
                                                   ntohs(var->var_sb.val) > userLen ? userLen : ntohs(var->var_sb.val));
                           }
                           pos += MQTTHDR_VAR_SIZEOF(var);
                   }
           }
           if (flg.password) {
                   var = (mqtthdr_var_t*) pos;
                   len -= MQTTHDR_VAR_SIZEOF(var);
                   if (len < 0) {
                           mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Password %d", len);
                           flg.reserved = 1;
                           return flg;
                   } else {
                           if (psPass && passLen) {
                                   memset(psPass, 0, passLen--);
                                   memcpy(psPass, var->var_data, 
                                                   ntohs(var->var_sb.val) > passLen ? passLen : ntohs(var->var_sb.val));
                           }
                           pos += MQTTHDR_VAR_SIZEOF(var);
                   }
           }
   
           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.4  
changed lines
  Added in v.1.1.2.7

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