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

version 1.2.2.35, 2012/06/01 10:39:48 version 1.2.2.36, 2012/06/19 13:55:23
Line 261  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.35  
changed lines
  Added in v.1.2.2.36


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