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); }