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

Diff for /mqtt/src/mqttd_calls.c between versions 1.2.2.17 and 1.2.2.18

version 1.2.2.17, 2012/05/22 14:15:04 version 1.2.2.18, 2012/05/27 10:04:05
Line 155  cmdSUBSCRIBE(void *srv, int len, void *arg) Line 155  cmdSUBSCRIBE(void *srv, int len, void *arg)
                 }                  }
                 if (call.WritePUB_subscribe(&cfg, pub, sess->sess_cid, mid, buf,                   if (call.WritePUB_subscribe(&cfg, pub, sess->sess_cid, mid, buf, 
                                 sess->sess_user, sess->sess_addr, subs[i].sub_ret) > 0) {                                  sess->sess_user, sess->sess_addr, subs[i].sub_ret) > 0) {
                        store = malloc(sizeof(struct tagStore));                        store = io_malloc(sizeof(struct tagStore));
                         if (!store) {                          if (!store) {
                                 ioSYSERR(0);                                  ioSYSERR(0);
                                 goto end;                                  goto end;
Line 245  cmdUNSUBSCRIBE(void *srv, int len, void *arg) Line 245  cmdUNSUBSCRIBE(void *srv, int len, void *arg)
                                         free(store->st_subscr.sub_topic.msg_base);                                          free(store->st_subscr.sub_topic.msg_base);
                                 if (store->st_subscr.sub_value.msg_base)                                  if (store->st_subscr.sub_value.msg_base)
                                         free(store->st_subscr.sub_value.msg_base);                                          free(store->st_subscr.sub_value.msg_base);
                                free(store);                                io_free(store);
                         }                          }
                 }                  }
   
Line 329  cmdCONNECT(void *srv, int len, void *arg) Line 329  cmdCONNECT(void *srv, int len, void *arg)
                 if (store->st_subscr.sub_value.msg_base)                  if (store->st_subscr.sub_value.msg_base)
                         free(store->st_subscr.sub_value.msg_base);                          free(store->st_subscr.sub_value.msg_base);
   
                free(store);                io_free(store);
         }          }
   
         if (sess->sess_will.msg)          if (sess->sess_will.msg)
Removed from v.1.2.2.17  
changed lines
  Added in v.1.2.2.18

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