From 8ffa179b3e1df82db408cbac481fe6bca79b62d1 Mon Sep 17 00:00:00 2001 From: Allanceng Date: Wed, 17 Dec 2014 09:05:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9C=A8=E6=89=93=E5=8D=B0=E6=A0=91=E7=BB=93?= =?UTF-8?q?=E6=9E=84=E7=9A=84=E5=87=BD=E6=95=B0=E4=B8=AD=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E5=AF=B9=E5=90=84=E4=B8=AA=E8=8A=82=E7=82=B9=E7=9A=84=E5=BE=85?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=8C=85=E6=83=85=E5=86=B5=E7=9A=84=E6=89=93?= =?UTF-8?q?=E5=8D=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/read_handle_server.c | 2 +- src/subs.c | 15 ++++++++++++++- 2 files changed, 15 insertions(+), 2 deletions(-) diff --git a/src/read_handle_server.c b/src/read_handle_server.c index eb50f65..ff8335f 100755 --- a/src/read_handle_server.c +++ b/src/read_handle_server.c @@ -661,7 +661,7 @@ int mqtt3_handle_subscribe(struct mosquitto_db *db, struct mosquitto *context) } } - if(qos != 0x80){ + if(qos != 0x80){ //mosquitto_acl_check如果检查没有问题 // printf("it's crutial to subclient%s\n", sub); rc2 = mqtt3_sub_add(db, context, sub, qos, &db->subs); if(rc2 == MOSQ_ERR_SUCCESS){ diff --git a/src/subs.c b/src/subs.c index 949cdbc..b289cdf 100755 --- a/src/subs.c +++ b/src/subs.c @@ -566,7 +566,7 @@ void mqtt3_sub_tree_print(struct _mosquitto_subhier *root, int level)//负责打 int i; struct _mosquitto_subhier *branch; struct _mosquitto_subleaf *leaf; - + struct _mosquitto_packet *packet; //allan adds for(i=0; icontext){ printf(" (context->id:%s, qos:%d)", leaf->context->id, leaf->qos); + printf("last_mid:%d\n", leaf->context->last_mid); + packet = leaf->context->out_packet; + while(packet) + { + printf("packet payload:%s\n", packet->payload); + packet = packet->next; + } + packet = leaf->context->current_out_packet; + while(packet) + { + printf("packet payload:%s\n", packet->payload); + packet = packet->next; + } }else{ printf(" (%s, qos:%d)", "", leaf->qos); }