--- mqtt/src/daemon.c 2011/12/16 12:55:30 1.1.2.26 +++ mqtt/src/daemon.c 2011/12/16 13:08:46 1.1.2.27 @@ -93,11 +93,14 @@ stopSession(struct tagSession *sess) else { ioDEBUG(5, "Sended %d bytes for disconnect", ret); free(msg.msg_base); - msg.msg_len = 0; + memset(&msg, 0, sizeof msg); } ioDEBUG(1, "Close socket=%d", sess->sess_sock); finiSession(sess); + + call.LOG(logg, "Session %s stopped from %s for user %s OK!\n", sess->sess_cid, + sess->sess_addr, sess->sess_user); } static int @@ -244,7 +247,7 @@ startSession(sched_task_t *task) } else { ioDEBUG(5, "Sended %d bytes", ret); free(msg.msg_base); - msg.msg_len = 0; + memset(&msg, 0, sizeof msg); } /* Start session thread OK ... */ @@ -268,7 +271,7 @@ end: /* close client connection */ } else { ioDEBUG(5, "Sended %d bytes", ret); free(msg.msg_base); - msg.msg_len = 0; + memset(&msg, 0, sizeof msg); } ioDEBUG(1, "Close client %s with socket=%d", sess->sess_addr, sess->sess_sock);