--- libaitmqtt/src/sub.c	2012/04/07 20:54:57	1.1.1.1.2.1
+++ libaitmqtt/src/sub.c	2012/04/26 11:49:12	1.1.1.1.2.2
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: sub.c,v 1.1.1.1.2.1 2012/04/07 20:54:57 misho Exp $
+* $Id: sub.c,v 1.1.1.1.2.2 2012/04/26 11:49:12 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -270,9 +270,9 @@ mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, u_short 
  * @buf = Message buffer
  * @msgID = MessageID
  * @subscr = Subscriptions, must be free after use with mqtt_subFree()
- * return: NULL error or !=NULL MQTT fixed header
+ * return: -1 error or >-1 elements into subscr
  */
-struct mqtthdr *
+int
 mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_short *msgID, mqtt_subscr_t **subscr)
 {
 	register int i;
@@ -284,11 +284,11 @@ mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_shor
 	caddr_t pos;
 
 	if (!buf || !msgID || !subscr)
-		return NULL;
+		return -1;
 
 	hdr = _mqtt_readHEADER(buf, MQTT_TYPE_SUBSCRIBE, &ret, &len);
 	if (!hdr)
-		return NULL;
+		return -1;
 	pos = buf->msg_base + ret + 1;
 	v = (mqtt_len_t*) pos;
 
@@ -296,7 +296,7 @@ mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_shor
 	len -= sizeof(mqtt_len_t);
 	if (len < 0) {
 		mqtt_SetErr(EINVAL, "Short message length %d", len);
-		return NULL;
+		return -1;
 	} else {
 		*msgID = ntohs(v->val);
 		pos += sizeof(mqtt_len_t);
@@ -304,7 +304,7 @@ mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_shor
 
 	subs = mqtt_subAlloc(0);
 	if (!subs)
-		return NULL;
+		return -1;
 	else
 		*subscr = subs;
 
@@ -315,12 +315,12 @@ mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_shor
 		if (len < 0) {
 			mqtt_subFree(subscr);
 			mqtt_SetErr(EINVAL, "Short message length %d", len);
-			return NULL;
+			return -1;
 		}
 		subs = mqtt_subRealloc(subs, i + 1);
 		if (!subs) {
 			mqtt_subFree(subscr);
-			return NULL;
+			return -1;
 		} else
 			*subscr = subs;
 
@@ -330,7 +330,7 @@ mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_shor
 		if (!subs[i].sub_topic.msg_base) {
 			LOGERR;
 			mqtt_subFree(subscr);
-			return NULL;
+			return -1;
 		} else
 			memcpy(subs[i].sub_topic.msg_base, var->var_data, subs[i].sub_topic.msg_len);
 		pos += MQTTHDR_VAR_SIZEOF(var);
@@ -339,7 +339,7 @@ mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, u_shor
 		pos++;
 	}
 
-	return hdr;
+	return i;
 }
 
 /*
@@ -394,9 +394,9 @@ mqtt_readSUBACK(mqtt_msg_t * __restrict buf, u_short *
  * @buf = Message buffer
  * @msgID = MessageID
  * @subscr = Subscriptions, must be free after use with mqtt_subFree()
- * return: NULL error or !=NULL MQTT fixed header
+ * return: -1 error or >-1 elements into subscr
  */
-struct mqtthdr *
+int
 mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, u_short *msgID, mqtt_subscr_t **subscr)
 {
 	register int i;
@@ -408,11 +408,11 @@ mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, u_sh
 	caddr_t pos;
 
 	if (!buf || !msgID || !subscr)
-		return NULL;
+		return -1;
 
 	hdr = _mqtt_readHEADER(buf, MQTT_TYPE_UNSUBSCRIBE, &ret, &len);
 	if (!hdr)
-		return NULL;
+		return -1;
 	pos = buf->msg_base + ret + 1;
 	v = (mqtt_len_t*) pos;
 
@@ -420,7 +420,7 @@ mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, u_sh
 	len -= sizeof(mqtt_len_t);
 	if (len < 0) {
 		mqtt_SetErr(EINVAL, "Short message length %d", len);
-		return NULL;
+		return -1;
 	} else {
 		*msgID = ntohs(v->val);
 		pos += sizeof(mqtt_len_t);
@@ -428,7 +428,7 @@ mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, u_sh
 
 	subs = mqtt_subAlloc(0);
 	if (!subs)
-		return NULL;
+		return -1;
 	else
 		*subscr = subs;
 
@@ -439,12 +439,12 @@ mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, u_sh
 		if (len < 0) {
 			mqtt_subFree(subscr);
 			mqtt_SetErr(EINVAL, "Short message length %d", len);
-			return NULL;
+			return -1;
 		}
 		subs = mqtt_subRealloc(subs, i + 1);
 		if (!subs) {
 			mqtt_subFree(subscr);
-			return NULL;
+			return -1;
 		} else
 			*subscr = subs;
 
@@ -454,13 +454,13 @@ mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, u_sh
 		if (!subs[i].sub_topic.msg_base) {
 			LOGERR;
 			mqtt_subFree(subscr);
-			return NULL;
+			return -1;
 		} else
 			memcpy(subs[i].sub_topic.msg_base, var->var_data, subs[i].sub_topic.msg_len);
 		pos += MQTTHDR_VAR_SIZEOF(var);
 	}
 
-	return hdr;
+	return i;
 }
 
 /*