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

Diff for /mqtt/src/daemon.c between versions 1.2.2.34 and 1.2.2.36

version 1.2.2.34, 2012/05/28 08:08:21 version 1.2.2.36, 2012/06/19 13:55:23
Line 24  initSession(int sock, ait_val_t * __restrict v) Line 24  initSession(int sock, ait_val_t * __restrict v)
                 memset(sess, 0, sizeof(struct tagSession));                  memset(sess, 0, sizeof(struct tagSession));
   
         SLIST_INIT(&sess->sess_subscr);          SLIST_INIT(&sess->sess_subscr);
           SLIST_INIT(&sess->sess_sndpkt);
   
         str = cfg_getAttribute(&cfg, "mqttd", "retry");          str = cfg_getAttribute(&cfg, "mqttd", "retry");
         if (!str)          if (!str)
Line 64  static void Line 65  static void
 finiSession(struct tagSession *sess)  finiSession(struct tagSession *sess)
 {  {
         struct tagStore *store;          struct tagStore *store;
           struct tagPkt *p;
   
         ioTRACE(5);          ioTRACE(5);
   
Line 90  finiSession(struct tagSession *sess) Line 92  finiSession(struct tagSession *sess)
                 io_free(store);                  io_free(store);
         }          }
   
           while ((p = SLIST_FIRST(&sess->sess_sndpkt))) {
                   SLIST_REMOVE_HEAD(&sess->sess_sndpkt, pkt_node);
   
                   io_freeVar(&p->pkt_data);
                   io_free(p);
           }
   
         if (sess->sess_will.msg)          if (sess->sess_will.msg)
                 free(sess->sess_will.msg);                  free(sess->sess_will.msg);
         if (sess->sess_will.topic)          if (sess->sess_will.topic)
Line 252  startSession(sched_task_t *task) Line 261  startSession(sched_task_t *task)
                 TAILQ_FOREACH(s, &Sessions, sess_node)                  TAILQ_FOREACH(s, &Sessions, sess_node)
                         if (!strcmp(s->sess_cid, sess->sess_cid)) {                          if (!strcmp(s->sess_cid, sess->sess_cid)) {
                                 /* found stale session & disconnect it! */                                  /* found stale session & disconnect it! */
                                schedWrite(root, leaveClient, sess, TASK_FD(task), NULL, 0);                                schedCancelby(root, taskMAX, CRITERIA_FD, (void*) s->sess_sock, NULL);
                                 schedWrite(root, leaveClient, s, s->sess_sock, NULL, 0);
                                 break;                                  break;
                         }                          }
         }          }
Removed from v.1.2.2.34  
changed lines
  Added in v.1.2.2.36

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