mqtt/src/conn.c - diff

Return to conn.c CVS log

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

version 1.1.2.2, 2011/11/21 12:47:15	version 1.1.2.3, 2011/11/21 14:40:56
Line 21 int	Line 21 int
mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID,	mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID,
const char csUser, const char csPass,	const char csUser, const char csPass,
const char csWillTopic, const char csWillMessage,	const char csWillTopic, const char csWillMessage,
char ClrSess, char WillQOS, char WillRetain)	u_char ClrSess, u_char WillQOS, u_char WillRetain)
{	{
int siz = 0;	int siz = 0;
struct mqtthdr *hdr;	struct mqtthdr *hdr;
Line 44 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha	Line 44 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
mqtt_SetErr(EINVAL, "Error:: invalid argument Password is too long (max 12 bytes)");	mqtt_SetErr(EINVAL, "Error:: invalid argument Password is too long (max 12 bytes)");
return -1;	return -1;
}	}
if (WillQOS < MQTT_QOS_ONCE && WillQOS > MQTT_QOS_EXACTLY) {	if (WillQOS > MQTT_QOS_EXACTLY) {
mqtt_SetErr(EINVAL, "Error:: invalid argument WillQOS - unknown QOS value");	mqtt_SetErr(EINVAL, "Error:: invalid argument WillQOS - unknown QOS value");
return -1;	return -1;
}	}
Line 132 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha	Line 132 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
}	}
}	}

*hdr->mqtt_len = mqtt_encodeLen(siz - 2);	*hdr->mqtt_len = mqtt_encodeLen(siz - sizeof(struct mqtthdr));
mqtt_msgRealloc(buf, siz);	mqtt_msgRealloc(buf, siz);
return siz;	return siz;
}	}