mqtt/src/daemon.c - diff

Return to daemon.c CVS log

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

version 1.2.2.31, 2012/05/14 13:04:14	version 1.2.2.32, 2012/05/22 14:15:04
Line 347 end:	Line 347 end:
int	int
Run(int sock)	Run(int sock)
{	{
struct tagPub *pub;
struct tagSession *sess;	struct tagSession *sess;
struct timespec pl = { 0, 100000000 };	struct timespec pl = { 0, 100000000 };

Line 369 Run(int sock)	Line 368 Run(int sock)
schedRun(root, &Kill);	schedRun(root, &Kill);

/* free all undeleted elements into lists */	/* free all undeleted elements into lists */
TAILQ_FOREACH(pub, &Pubs, pub_node) {
TAILQ_REMOVE(&Pubs, pub, pub_node);

AIT_FREE_VAL(&pub->pub_name);
if (pub->pub_packet.msg_base)
free(pub->pub_packet.msg_base);
}
TAILQ_FOREACH(sess, &Sessions, sess_node) {	TAILQ_FOREACH(sess, &Sessions, sess_node) {
TAILQ_REMOVE(&Sessions, sess, sess_node);	TAILQ_REMOVE(&Sessions, sess, sess_node);