mqtt/src/daemon.c - diff

Return to daemon.c CVS log

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

version 1.2.2.17, 2012/04/26 08:20:20	version 1.2.2.19, 2012/04/27 10:07:50
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;	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 394 Run(int sock)	Line 389 Run(int sock)

schedPolling(root, &pl, NULL);	schedPolling(root, &pl, NULL);
schedRun(root, &Kill);	schedRun(root, &Kill);
sleep(1);

pthread_attr_destroy(&attr);	pthread_attr_destroy(&attr);