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.2.2.15 and 1.2.2.19

version 1.2.2.15, 2012/04/25 16:36:26	version 1.2.2.19, 2012/04/27 10:07:50
Line 23 initSession(int sock, ait_val_t * __restrict v)	Line 23 initSession(int sock, ait_val_t * __restrict v)
sess = malloc(sizeof(struct tagSession));	sess = malloc(sizeof(struct tagSession));
if (!sess) {	if (!sess) {
ioSYSERR(0);	ioSYSERR(0);
io_freeVar(v);
return NULL;	return NULL;
} else	} else
memset(sess, 0, sizeof(struct tagSession));	memset(sess, 0, sizeof(struct tagSession));
Line 42 initSession(int sock, ait_val_t * __restrict v)	Line 41 initSession(int sock, ait_val_t * __restrict v)
if (!sess->sess_buf) {	if (!sess->sess_buf) {
ioLIBERR(mqtt);	ioLIBERR(mqtt);
free(sess);	free(sess);
io_freeVar(v);
return NULL;	return NULL;
}	}

Line 52 initSession(int sock, ait_val_t * __restrict v)	Line 50 initSession(int sock, ait_val_t * __restrict v)
ioDEBUG(3, "Error:: in srv_Init #%d - %s", mqtt_GetErrno(), mqtt_GetError());	ioDEBUG(3, "Error:: in srv_Init #%d - %s", mqtt_GetErrno(), mqtt_GetError());
mqtt_msgFree(&sess->sess_buf, 42);	mqtt_msgFree(&sess->sess_buf, 42);
free(sess);	free(sess);
io_freeVar(v);
return NULL;	return NULL;
} else {	} else {
mqtt_srv_setCmd(sess->sess_srv, MQTT_TYPE_CONNECT, cmdCONNECT);	mqtt_srv_setCmd(sess->sess_srv, MQTT_TYPE_CONNECT, cmdCONNECT);
Line 66 initSession(int sock, ait_val_t * __restrict v)	Line 63 initSession(int sock, ait_val_t * __restrict v)

sess->sess_sock = sock;	sess->sess_sock = sock;
strlcpy(sess->sess_addr, (char*) AIT_GET_STR(v), sizeof sess->sess_addr);	strlcpy(sess->sess_addr, (char*) AIT_GET_STR(v), sizeof sess->sess_addr);
io_freeVar(v);
return sess;	return sess;
}	}

Line 84 finiSession(struct tagSession *sess)	Line 80 finiSession(struct tagSession *sess)
call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%");	call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%");

SESS_ELEM_LOCK(sess);	SESS_ELEM_LOCK(sess);

while ((store = SLIST_FIRST(&sess->sess_subscr))) {	while ((store = SLIST_FIRST(&sess->sess_subscr))) {
SLIST_REMOVE_HEAD(&sess->sess_subscr, st_node);	SLIST_REMOVE_HEAD(&sess->sess_subscr, st_node);

Line 143 thrSession(struct tagSession *sess)	Line 138 thrSession(struct tagSession *sess)
int ret, locKill = 42;	int ret, locKill = 42;
struct pollfd pfd;	struct pollfd pfd;
struct mqtthdr *hdr;	struct mqtthdr *hdr;
ait_val_t *v;

pthread_cleanup_push((void()(void)) stopSession, sess);	pthread_cleanup_push((void()(void)) stopSession, sess);
ioTRACE(2);	ioTRACE(2);
Line 175 thrSession(struct tagSession *sess)	Line 169 thrSession(struct tagSession *sess)
ioLIBERR(mqtt);	ioLIBERR(mqtt);
switch (hdr->mqtt_msg.type) {	switch (hdr->mqtt_msg.type) {
case MQTT_TYPE_CONNECT:	case MQTT_TYPE_CONNECT:
ioDEBUG(5, "Exec CONNECT session");	schedEvent(root, startSession, NULL, (u_long) sess->sess_sock, sess, ret);
if ((v = io_allocVar())) {
AIT_SET_STR(v, sess->sess_addr);
if (!schedEvent(root, startSession, v, (u_long) sess->sess_sock, sess, ret))
io_freeVar(v);
} else
ioLIBERR(mqtt);

SESS_LOCK;
TAILQ_REMOVE(&Sessions, sess, sess_node);
SESS_UNLOCK;

locKill ^= locKill;	locKill ^= locKill;
break;	break;
case MQTT_TYPE_DISCONNECT:	case MQTT_TYPE_DISCONNECT:
ioDEBUG(5, "Exec DISCONNECT session");
SESS_LOCK;
TAILQ_REMOVE(&Sessions, sess, sess_node);
SESS_UNLOCK;

finiSession(sess);	finiSession(sess);
locKill ^= locKill;	locKill ^= locKill;
continue;	continue;
	case MQTT_TYPE_SUBSCRIBE:
	case MQTT_TYPE_PINGREQ:
	break;
case MQTT_TYPE_PUBLISH:	case MQTT_TYPE_PUBLISH:
ioDEBUG(5, "Exec PUBLISH topic QoS=%d", hdr->mqtt_msg.qos);	ioDEBUG(5, "Exec PUBLISH topic QoS=%d", hdr->mqtt_msg.qos);
/*	/*
Line 207 thrSession(struct tagSession *sess)	Line 188 thrSession(struct tagSession *sess)
break;	break;
case MQTT_TYPE_PUBREL:	case MQTT_TYPE_PUBREL:
break;	break;
case MQTT_TYPE_SUBSCRIBE:
break;
case MQTT_TYPE_UNSUBSCRIBE:	case MQTT_TYPE_UNSUBSCRIBE:
break;	break;
case MQTT_TYPE_PINGREQ:
ioDEBUG(5, "Exec PINGREQ session");
break;
case MQTT_TYPE_PINGRESP:
ioDEBUG(5, "Exec PINGRESP session");
break;
default:	default:
ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED",	ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED",
sess->sess_cid, hdr->mqtt_msg.type);	sess->sess_cid, hdr->mqtt_msg.type);
Line 246 startSession(sched_task_t *task)	Line 219 startSession(sched_task_t *task)
if (!TASK_DATA(task)) {	if (!TASK_DATA(task)) {
/* flow from accept new clients */	/* flow from accept new clients */
sess = initSession(TASK_FD(task), TASK_ARG(task));	sess = initSession(TASK_FD(task), TASK_ARG(task));
	io_freeVar(TASK_ARG(task));
if (!sess) {	if (!sess) {
io_freeVar(TASK_ARG(task));
close(TASK_FD(task));	close(TASK_FD(task));
return NULL;	return NULL;
}	}
Line 373 acceptClient(sched_task_t *task)	Line 346 acceptClient(sched_task_t *task)
} else {	} else {
memset(str, 0, sizeof str);	memset(str, 0, sizeof str);
snprintf(str, sizeof str, "%s:%hu", io_n2addr(&sa, v), io_n2port(&sa));	snprintf(str, sizeof str, "%s:%hu", io_n2addr(&sa, v), io_n2port(&sa));
	AIT_FREE_VAL(v);
AIT_SET_STR(v, str);	AIT_SET_STR(v, str);
}	}
ioDEBUG(1, "Connected client with socket=%d from %s", cli, AIT_GET_STR(v));	ioDEBUG(1, "Connected client with socket=%d from %s", cli, AIT_GET_STR(v));

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

Removed from v.1.2.2.15
changed lines
	Added in v.1.2.2.19