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.18 and 1.2.2.20

version 1.2.2.18, 2012/04/26 09:15:26	version 1.2.2.20, 2012/05/03 13:39:34
Line 126 stopSession(struct tagSession *sess)	Line 126 stopSession(struct tagSession *sess)
free(msg.msg_base);	free(msg.msg_base);

ioDEBUG(1, "Close socket=%d", sess->sess_sock);	ioDEBUG(1, "Close socket=%d", sess->sess_sock);
finiSession(sess);

call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid,	call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid,
sess->sess_addr, sess->sess_user);	sess->sess_addr, sess->sess_user);

	finiSession(sess);
}	}

static void *	static void *
Line 176 thrSession(struct tagSession *sess)	Line 176 thrSession(struct tagSession *sess)
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 185 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;
case MQTT_TYPE_PINGREQ:
ioDEBUG(5, "Exec PINGREQ session");
break;
case MQTT_TYPE_PINGRESP:
ioDEBUG(5, "Exec PINGRESP session");
break;	break;
default:	default:
ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED",	ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED",

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

Removed from v.1.2.2.18
changed lines
	Added in v.1.2.2.20