[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.14 and 1.1.2.15

version 1.1.2.14, 2011/12/13 15:23:43 version 1.1.2.15, 2011/12/16 02:09:20
Line 33  mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha Line 33  mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
   
         if (!buf || !csConnID)          if (!buf || !csConnID)
                 return -1;                  return -1;
        if (strlen(csConnID) > 24) {        if (strlen(csConnID) > 23) {
                 mqtt_SetErr(EINVAL, "Error:: invalid argument ConnID is too long (max 23 bytes)");                  mqtt_SetErr(EINVAL, "Error:: invalid argument ConnID is too long (max 23 bytes)");
                 return -1;                  return -1;
         }          }
        if (csUser && strlen(csUser) > 13) {        if (csUser && strlen(csUser) > 12) {
                 mqtt_SetErr(EINVAL, "Error:: invalid argument Username is too long (max 12 bytes)");                  mqtt_SetErr(EINVAL, "Error:: invalid argument Username is too long (max 12 bytes)");
                 return -1;                  return -1;
         }          }
        if (csPass && strlen(csPass) > 13) {        if (csPass && strlen(csPass) > 12) {
                 mqtt_SetErr(EINVAL, "Error:: invalid argument Password is too long (max 12 bytes)");                  mqtt_SetErr(EINVAL, "Error:: invalid argument Password is too long (max 12 bytes)");
                 return -1;                  return -1;
         }          }
Line 312  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short  Line 312  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short 
         /* get ConnID */          /* get ConnID */
         var = (mqtthdr_var_t*) pos;          var = (mqtthdr_var_t*) pos;
         len -= MQTTHDR_VAR_SIZEOF(var);          len -= MQTTHDR_VAR_SIZEOF(var);
        if (len < 0) {        if (len < 0 || var->var_sb.sb.l > 23) {
                 mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Connection ID %d", len);                  mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Connection ID %d", len);
                 cack.retcode = MQTT_RETCODE_REFUSE_ID;                  cack.retcode = MQTT_RETCODE_REFUSE_ID;
                 return cack;                  return cack;
Line 369  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short  Line 369  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short 
         if (flg.username) {          if (flg.username) {
                 var = (mqtthdr_var_t*) pos;                  var = (mqtthdr_var_t*) pos;
                 len -= MQTTHDR_VAR_SIZEOF(var);                  len -= MQTTHDR_VAR_SIZEOF(var);
                if (len < 0) {                if (len < 0 || var->var_sb.sb.l > 12) {
                         mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Username %d", len);                          mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Username %d", len);
                         cack.retcode = MQTT_RETCODE_REFUSE_USERPASS;                          cack.retcode = MQTT_RETCODE_REFUSE_USERPASS;
                         return cack;                          return cack;
Line 385  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short  Line 385  mqtt_readCONNECT(mqtt_msg_t * __restrict buf, u_short 
         if (flg.password) {          if (flg.password) {
                 var = (mqtthdr_var_t*) pos;                  var = (mqtthdr_var_t*) pos;
                 len -= MQTTHDR_VAR_SIZEOF(var);                  len -= MQTTHDR_VAR_SIZEOF(var);
                if (len < 0) {                if (len < 0 || var->var_sb.sb.l > 12) {
                         mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Password %d", len);                          mqtt_SetErr(EINVAL, "Error:: unexpected EOM at Password %d", len);
                         cack.retcode = MQTT_RETCODE_REFUSE_USERPASS;                          cack.retcode = MQTT_RETCODE_REFUSE_USERPASS;
                         return cack;                          return cack;
Removed from v.1.1.2.14  
changed lines
  Added in v.1.1.2.15

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