--- mqtt/src/Attic/conn.c	2011/11/22 14:00:09	1.1.2.4
+++ mqtt/src/Attic/conn.c	2011/11/22 14:13:04	1.1.2.5
@@ -179,3 +179,63 @@ mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, u_char re
 
 	return siz;
 }
+
+static int
+_mqtt_msgSIMPLE_(mqtt_msg_t * __restrict buf, u_char cmd)
+{
+	int siz = 0;
+	struct mqtthdr *hdr;
+
+	if (!buf)
+		return -1;
+
+	if (mqtt_msgRealloc(buf, sizeof(struct mqtthdr)) == -1)
+		return -1;
+	else {
+		hdr = (struct mqtthdr *) (buf->msg_base + siz);
+		siz += sizeof(struct mqtthdr);
+	}
+
+	/* fixed header */
+	MQTTHDR_MSGINIT(hdr);
+	hdr->mqtt_msg.type = cmd;
+	*hdr->mqtt_len = 0;
+
+	return siz;
+}
+
+/*
+ * mqtt_msgPINGREQ() Create PINGREQ message
+ *
+ * @buf = Message buffer
+ * return: -1 error or >-1 message size for send
+ */
+int
+mqtt_msgPINGREQ(mqtt_msg_t * __restrict buf)
+{
+	return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_PINGREQ);
+}
+
+/*
+ * mqtt_msgPINGRESP() Create PINGRESP message
+ *
+ * @buf = Message buffer
+ * return: -1 error or >-1 message size for send
+ */
+int
+mqtt_msgPINGRESP(mqtt_msg_t * __restrict buf)
+{
+	return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_PINGRESP);
+}
+
+/*
+ * mqtt_msgDISCONNECT() Create DISCONNECT message
+ *
+ * @buf = Message buffer
+ * return: -1 error or >-1 message size for send
+ */
+int
+mqtt_msgDISCONNECT(mqtt_msg_t * __restrict buf)
+{
+	return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_DISCONNECT);
+}