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

version 1.2.2.14, 2012/05/08 13:10:41 version 1.2.2.15, 2012/05/08 14:27:46
Line 72  cmdSUBSCRIBE(void *srv, int len, void *arg) Line 72  cmdSUBSCRIBE(void *srv, int len, void *arg)
   
         /* add to db */          /* add to db */
         for (i = 0; i < siz; i++) {          for (i = 0; i < siz; i++) {
                if (call.WritePUB_subscribe(&cfg, pub, mid, subs[i].sub_topic.msg_base,                 if (call.WritePUB_subscribe(&cfg, pub, sess->sess_cid, mid, subs[i].sub_topic.msg_base, 
                                 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 = malloc(sizeof(struct tagStore));
                         if (!store) {                          if (!store) {
Line 147  cmdUNSUBSCRIBE(void *srv, int len, void *arg) Line 147  cmdUNSUBSCRIBE(void *srv, int len, void *arg)
                         }                          }
                 }                  }
   
                call.DeletePUB_subscribe(&cfg, pub, subs[i].sub_topic.msg_base,                 call.DeletePUB_subscribe(&cfg, pub, sess->sess_cid, subs[i].sub_topic.msg_base, 
                                sess->sess_user, sess->sess_addr);                                sess->sess_user, "%");
         }          }
   
         /* send acknowledge */          /* send acknowledge */
Removed from v.1.2.2.14  
changed lines
  Added in v.1.2.2.15

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