--- mqtt/src/mqttd_calls.c	2012/05/22 14:15:04	1.2.2.17
+++ mqtt/src/mqttd_calls.c	2012/05/27 10:04:05	1.2.2.18
@@ -155,7 +155,7 @@ cmdSUBSCRIBE(void *srv, int len, void *arg)
 		}
 		if (call.WritePUB_subscribe(&cfg, pub, sess->sess_cid, mid, buf, 
 				sess->sess_user, sess->sess_addr, subs[i].sub_ret) > 0) {
-			store = malloc(sizeof(struct tagStore));
+			store = io_malloc(sizeof(struct tagStore));
 			if (!store) {
 				ioSYSERR(0);
 				goto end;
@@ -245,7 +245,7 @@ cmdUNSUBSCRIBE(void *srv, int len, void *arg)
 					free(store->st_subscr.sub_topic.msg_base);
 				if (store->st_subscr.sub_value.msg_base)
 					free(store->st_subscr.sub_value.msg_base);
-				free(store);
+				io_free(store);
 			}
 		}
 
@@ -329,7 +329,7 @@ cmdCONNECT(void *srv, int len, void *arg)
 		if (store->st_subscr.sub_value.msg_base)
 			free(store->st_subscr.sub_value.msg_base);
 
-		free(store);
+		io_free(store);
 	}
 
 	if (sess->sess_will.msg)