mqtt/src/mqtt_pub.c - diff

Return to mqtt_pub.c CVS log

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

version 1.1.2.6, 2012/01/05 10:26:02	version 1.1.2.7, 2012/01/05 13:09:05
Line 67 Publish(int sock)	Line 67 Publish(int sock)
if ((siz = RecvFrom(sock)) == -1 \|\| !siz)	if ((siz = RecvFrom(sock)) == -1 \|\| !siz)
return -1;	return -1;
/* QoS == MQTT_QOS_ACK, wait for PUBACK */	/* QoS == MQTT_QOS_ACK, wait for PUBACK */
if (args->QoS == MQTT_QOS_ACK)	if (args->QoS == MQTT_QOS_ACK) {
return mqtt_readPUBACK(args->msg);	siz = mqtt_readPUBACK(args->msg);
	if (siz == args->MsgID)
	return siz;
	if (!args->Dup) {
	args->Dup++;
	return Publish(sock);
	}
	goto end;
	}


/* QoS == MQTT_QOS_EXACTLY */	/* QoS == MQTT_QOS_EXACTLY */
if (mqtt_readPUBREC(args->msg) != args->MsgID) {	siz = mqtt_readPUBREC(args->msg);
printf("Error:: Message not delivered\n");	if (siz != args->MsgID) {
return -1;	if (!args->Dup) {
	args->Dup++;
	return Publish(sock);
	}
	goto end;
}	}

siz = mqtt_msgPUBREL(args->msg, args->MsgID);	siz = mqtt_msgPUBREL(args->msg, args->MsgID);
Line 87 Publish(int sock)	Line 99 Publish(int sock)

if ((siz = RecvFrom(sock)) == -1 \|\| !siz)	if ((siz = RecvFrom(sock)) == -1 \|\| !siz)
return -1;	return -1;
return mqtt_readPUBCOMP(args->msg);
	siz = mqtt_readPUBCOMP(args->msg);
	if (siz == args->MsgID)
	return siz;
	if (!args->Dup) {
	args->Dup++;
	return Publish(sock);
	}

	end:
	printf("Error:: Message not delivered\n");
	return -1;
}	}