Diff for /mqtt/src/daemon.c between versions 1.2 and 1.2.2.1

version 1.2, 2012/01/27 15:05:38 version 1.2.2.1, 2012/01/27 15:18:12
Line 65  finiSession(struct tagSession *sess, int preservSock) Line 65  finiSession(struct tagSession *sess, int preservSock)
         while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {          while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {
                 TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);                  TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);
   
                if (store->st_subscr.sub_topic._base)                if (store->st_subscr.sub_topic.msg_base)
                        free(store->st_subscr.sub_topic._base);                        free(store->st_subscr.sub_topic.msg_base);
                if (store->st_subscr.sub_value._base)                if (store->st_subscr.sub_value.msg_base)
                        free(store->st_subscr.sub_value._base);                        free(store->st_subscr.sub_value.msg_base);
   
                 free(store);                  free(store);
         }          }
Line 211  thrSession(struct tagSession *sess) Line 211  thrSession(struct tagSession *sess)
                                 while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {                                  while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {
                                         TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);                                          TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);
   
                                        if (store->st_subscr.sub_topic._base)                                        if (store->st_subscr.sub_topic.msg_base)
                                                free(store->st_subscr.sub_topic._base);                                                free(store->st_subscr.sub_topic.msg_base);
                                        if (store->st_subscr.sub_value._base)                                        if (store->st_subscr.sub_value.msg_base)
                                                free(store->st_subscr.sub_value._base);                                                free(store->st_subscr.sub_value.msg_base);
   
                                         free(store);                                          free(store);
                                 }                                  }

Removed from v.1.2  
changed lines
  Added in v.1.2.2.1


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