mqtt/src/daemon.c - diff

Return to daemon.c CVS log

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

version 1.1.2.18, 2011/12/14 12:45:30	version 1.1.2.19, 2011/12/14 13:15:35
Line 37 initSession(int sock, ait_val_t * __restrict v)	Line 37 initSession(int sock, ait_val_t * __restrict v)
}	}

sess->sess_sock = sock;	sess->sess_sock = sock;
strlcpy(sess->sess_addr, AIT_GET_STR(v), sizeof sess->sess_addr);	strlcpy(sess->sess_addr, (char*) AIT_GET_STR(v), sizeof sess->sess_addr);
io_freeVar(v);	io_freeVar(v);
return sess;	return sess;
}	}
Line 150 startSession(sched_task_t *task)	Line 150 startSession(sched_task_t *task)
return NULL;	return NULL;
} else {	} else {
VERB(5) ioLOGGER(LOG_DEBUG, "Sended %d bytes", ret);	VERB(5) ioLOGGER(LOG_DEBUG, "Sended %d bytes", ret);
mqtt_msgFree((mqtt_msg_t**) &msg, 0);	free(msg.msg_base);
	msg.msg_len = 0;
}	}

/* Start session thread OK ... */	/* Start session thread OK ... */
Line 173 end: /* close client connection */	Line 174 end: /* close client connection */
VERB(3) syslog(LOG_ERR, "Error:: send(%d) #%d - %s", sess->sess_sock, errno, strerror(errno));	VERB(3) syslog(LOG_ERR, "Error:: send(%d) #%d - %s", sess->sess_sock, errno, strerror(errno));
} else {	} else {
VERB(5) ioLOGGER(LOG_DEBUG, "Sended %d bytes", ret);	VERB(5) ioLOGGER(LOG_DEBUG, "Sended %d bytes", ret);
mqtt_msgFree((mqtt_msg_t**) &msg, 0);	free(msg.msg_base);
	msg.msg_len = 0;
}	}

VERB(1) ioLOGGER(LOG_DEBUG, "Close client %s with socket=%d", sess->sess_addr, sess->sess_sock);	VERB(1) ioLOGGER(LOG_DEBUG, "Close client %s with socket=%d", sess->sess_addr, sess->sess_sock);