mqtt/src/pub.c - diff

Return to pub.c CVS log

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

version 1.1.2.4, 2011/11/21 15:07:12	version 1.1.2.5, 2011/11/21 15:27:26
Line 12	Line 12
* @Dup = Duplicate message	* @Dup = Duplicate message
* @QOS = QoS	* @QOS = QoS
* @Retain = Retain message	* @Retain = Retain message
	* @pData = Publish data into topic
	* @datlen = Publish data length
* return: -1 error or >-1 message size for send	* return: -1 error or >-1 message size for send
*/	*/
int	int
mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, u_short msgID,	mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, u_short msgID,
u_char Dup, u_char QOS, u_char Retain)	u_char Dup, u_char QOS, u_char Retain, const void *pData, u_short datlen)
{	{
int siz = 0;	int siz = 0;
struct mqtthdr *hdr;	struct mqtthdr *hdr;
mqtthdr_var_t *topic;	mqtthdr_var_t *topic;
mqtt_v_t *mid;	mqtt_v_t *mid;
	void *data;

if (!buf \|\| !csTopic)	if (!buf \|\| !csTopic)
return -1;	return -1;
Line 51 mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha	Line 54 mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const cha
mid = (mqtt_v_t*) (buf->msg_base + siz);	mid = (mqtt_v_t*) (buf->msg_base + siz);
mid->val = htons(msgID);	mid->val = htons(msgID);
siz += sizeof(mqtt_v_t);	siz += sizeof(mqtt_v_t);

	/* load with data */

	if (pData && datlen) {
	data = buf->msg_base + siz;
	memcpy(data, pData, datlen);
	siz += datlen;
	}

/* fixed header */	/* fixed header */