--- mqtt/src/daemon.c 2011/12/16 12:16:17 1.1.2.24 +++ mqtt/src/daemon.c 2011/12/16 12:22:26 1.1.2.25 @@ -162,6 +162,7 @@ startSession(sched_task_t *task) ioDEBUG(2, "Old session %s should be disconnect!", sess->sess_cid); TAILQ_FOREACH(s, &Sessions, sess_node) if (!strcmp(s->sess_cid, sess->sess_cid)) { + /* found stale session & disconnect it! */ stopSession(s); break; }