mqtt/src/daemon.c - diff

Return to daemon.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

version 1.1.2.26, 2011/12/16 12:55:30	version 1.1.2.27, 2011/12/16 13:08:46
Line 93 stopSession(struct tagSession *sess)	Line 93 stopSession(struct tagSession *sess)
else {	else {
ioDEBUG(5, "Sended %d bytes for disconnect", ret);	ioDEBUG(5, "Sended %d bytes for disconnect", ret);
free(msg.msg_base);	free(msg.msg_base);
msg.msg_len = 0;	memset(&msg, 0, sizeof msg);
}	}

ioDEBUG(1, "Close socket=%d", sess->sess_sock);	ioDEBUG(1, "Close socket=%d", sess->sess_sock);
finiSession(sess);	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	static int
Line 244 startSession(sched_task_t *task)	Line 247 startSession(sched_task_t *task)
} else {	} else {
ioDEBUG(5, "Sended %d bytes", ret);	ioDEBUG(5, "Sended %d bytes", ret);
free(msg.msg_base);	free(msg.msg_base);
msg.msg_len = 0;	memset(&msg, 0, sizeof msg);
}	}

/* Start session thread OK ... */	/* Start session thread OK ... */
Line 268 end: /* close client connection */	Line 271 end: /* close client connection */
} else {	} else {
ioDEBUG(5, "Sended %d bytes", ret);	ioDEBUG(5, "Sended %d bytes", ret);
free(msg.msg_base);	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);	ioDEBUG(1, "Close client %s with socket=%d", sess->sess_addr, sess->sess_sock);