mqtt/src/daemon.c - diff

Return to daemon.c CVS log

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

Diff for /mqtt/src/daemon.c between versions 1.1.2.11 and 1.1.2.12

version 1.1.2.11, 2011/12/08 17:02:25	version 1.1.2.12, 2011/12/09 09:53:54
Line 10 startSession(sched_task_t *task)	Line 10 startSession(sched_task_t *task)
{	{
u_char basebuf[USHRT_MAX];	u_char basebuf[USHRT_MAX];
mqtt_cb_t cbs[MQTT_TYPE_MAX + 1] = { 0 };	mqtt_cb_t cbs[MQTT_TYPE_MAX + 1] = { 0 };
// mqtt_msg_t *buf = { basebuf, sizeof basebuf };	mqtt_msg_t buf = { basebuf, sizeof basebuf };
mqtthdr_connflgs_t flg;	mqtthdr_connflgs_t flg;
int ret = 0;	int ret = 0;
struct timeval tv = { 0 };	struct timeval tv = { 0 };
u_short ka;	u_short ka;
	struct tagSession *sess = NULL;

FTRACE(4);	FTRACE(4);

/*	sess = malloc(sizeof(struct tagSession));
buf = mqtt_msgAlloc(USHRT_MAX);	if (!sess) {
if (!buf) {	VERB(3) syslog(LOG_ERR, "Error:: in malloc #%d - %s", errno, strerror(errno));
syslog(LOG_ERR, "Error:: allocate message buf (%d) #%d - %s", (int) TASK_FD(task),
mqtt_GetErrno(), mqtt_GetError());
goto end;	goto end;
}	}
*/

if (recv(TASK_FD(task), basebuf, sizeof basebuf, 0) == -1) {	if (recv(TASK_FD(task), buf.msg_base, buf.msg_len, 0) == -1) {
VERB(3) syslog(LOG_ERR, "Error:: recv(%d) #%d - %s", (int) TASK_FD(task),	VERB(3) syslog(LOG_ERR, "Error:: recv(%d) #%d - %s", (int) TASK_FD(task),
errno, strerror(errno));	errno, strerror(errno));
goto end;	goto end;
}	}
	flg = mqtt_readCONNECT(&buf, &ka, sess->sess_cid, sizeof sess->sess_cid,
/*	sess->sess_user, sizeof sess->sess_user, sess->sess_pass, sizeof sess->sess_pass,
flg = mqtt_readCONNECT(buf, &ka, );	sess->sess_will.topic, sess->sess_will.msg);
if (flg.reserved) {	if (flg.reserved) {
VERB(3) syslog(LOG_ERR, "Error:: in MQTT protocol #%d - %s",	VERB(3) syslog(LOG_ERR, "Error:: in MQTT protocol #%d - %s",
mqtt_GetErrno(), mqtt_GetError());	mqtt_GetErrno(), mqtt_GetError());
goto end;	goto end;
} */	}

/*
for (ret = i = 0; cliCmd[i] && !(ret = (hdr->mqtt_msg.type == cliCmd[i])); i++);
if (!ret) {
VERB(2) syslog(LOG_ERR, "Error:: wrong command type #%d %s",
hdr->mqtt_msg.type, cliStr[i]);
goto end;
}
*/

/* check online table for user */	/* check online table for user */
// ChkSessPUB(&cfg, );

// ret = mqttDispatcher(cbs, buf);
// mqtt_msgFree(&buf, 42);

/*
switch (ret) {
case -1:
syslog(LOG_ERR, "Error:: in MQTT protocol #%d - %s", mqtt_GetErrno(), mqtt_GetError());
break;
default:
return NULL;
}
*/
end: /* close client connection */	end: /* close client connection */
	if (sess)
	free(sess);
close(TASK_FD(task));	close(TASK_FD(task));
VERB(1) syslog(LOG_DEBUG, "Close client %s with socket=%d",	VERB(1) syslog(LOG_DEBUG, "Close client %s with socket=%d",
(char*) TASK_ARG(task), (int) TASK_FD(task));	(char*) TASK_ARG(task), (int) TASK_FD(task));

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.1.2.11
changed lines
	Added in v.1.1.2.12