Merge pull request #593 from fengzeroz/main

connection: add buf used log

plugins/restful/rest.c

@@ -196,6 +196,8 @@ static int dashb_plugin_close(neu_plugin_t *plugin)
 {
     int rv = 0;
 
+    nlog_info("Success to before free plugin: %s",
+              neu_plugin_module.module_name);
     nng_http_server_stop(plugin->api_server);
     nng_http_server_release(plugin->api_server);
     nng_http_server_stop(plugin->web_server);

src/connection/connection.c

@@ -776,6 +776,8 @@ void neu_conn_stream_consume(neu_conn_t *conn, void *context,
         while (neu_protocol_unpack_buf_unused_size(&protocol_buf) > 0) {
             int used = fn(context, &protocol_buf);
 
+            zlog_debug(conn->param.log, "buf used: %d offset: %d", used,
+                       offset);
             if (used == 0) {
                 break;
             } else if (used == -1) {