--- mqtt/src/mqtt_subs.c	2012/05/22 14:15:04	1.2.2.8
+++ mqtt/src/mqtt_subs.c	2012/05/27 10:04:05	1.2.2.9
@@ -105,14 +105,14 @@ main(int argc, char **argv)
 	char *str, szStr[STRSIZ], szLogName[MAXPATHLEN] = { 0 };
 	FILE *lf;
 
-	if (!(args = malloc(sizeof(struct tagArgs)))) {
+	if (!(args = io_malloc(sizeof(struct tagArgs)))) {
 		printf("Error:: in arguments #%d - %s\n", errno, strerror(errno));
 		return 1;
 	} else
 		memset(args, 0, sizeof(struct tagArgs));
 	if (!(args->subscr = mqtt_subAlloc(idx))) {
 		printf("Error:: in subscribes array #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
-		free(args);
+		io_free(args);
 		return 1;
 	} else
 		args->free = cleanArgs;
@@ -120,7 +120,7 @@ main(int argc, char **argv)
 	if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) {
 		printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
 		args->free(args);
-		free(args);
+		io_free(args);
 		return 1;
 	}
 
@@ -158,7 +158,7 @@ main(int argc, char **argv)
 				if (!sub) {
 					printf("Error:: #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
 					args->free(args);
-					free(args);
+					io_free(args);
 					return 1;
 				} else
 					sub += idx++;
@@ -173,7 +173,7 @@ main(int argc, char **argv)
 						sub->sub_ret = (u_char) *str;
 				} else
 					sub->sub_ret = (u_char) args->QoS;
-				sub->sub_topic.msg_base = strdup(szStr);
+				sub->sub_topic.msg_base = io_strdup(szStr);
 				sub->sub_topic.msg_len = strlen(szStr);
 				break;
 			case 'q':
@@ -181,7 +181,7 @@ main(int argc, char **argv)
 				if (args->QoS > MQTT_QOS_EXACTLY) {
 					printf("Error:: invalid QoS level %d\n", args->QoS);
 					args->free(args);
-					free(args);
+					io_free(args);
 					return 1;
 				}
 				break;
@@ -206,7 +206,7 @@ main(int argc, char **argv)
 			case 'h':
 			default:
 				args->free(args);
-				free(args);
+				io_free(args);
 				Usage();
 				return 1;
 		}
@@ -215,7 +215,7 @@ main(int argc, char **argv)
 	if (argc < 2) {
 		printf("Error:: host for connect not found, connection id or topic not supplied!\n\n");
 		args->free(args);
-		free(args);
+		io_free(args);
 		Usage();
 		return 1;
 	} else {
@@ -229,7 +229,7 @@ main(int argc, char **argv)
 	if (!io_gethostbyname(*argv, port, &args->addr)) {
 		printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError());
 		args->free(args);
-		free(args);
+		io_free(args);
 		Usage();
 		return 1;
 	}
@@ -238,7 +238,7 @@ main(int argc, char **argv)
 
 	if (!(args->cli = mqtt_cli_Open(&args->addr.sa, args->ka))) {
 		args->free(args);
-		free(args);
+		io_free(args);
 		return 2;
 	}
 
@@ -284,6 +284,6 @@ main(int argc, char **argv)
 	mqtt_cli_Close(&args->cli);
 
 	args->free(args);
-	free(args);
+	io_free(args);
 	return ret;
 }