[incubator-iotdb] branch disable_mqtt_server updated: add more log

[hx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hxd pushed a commit to branch disable_mqtt_server
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/disable_mqtt_server by this push:
     new 8d3bd63  add more log
8d3bd63 is described below

commit 8d3bd6389ac5e9699af6b70cee28420c0f36d242
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Thu Apr 16 17:57:04 2020 +0800

    add more log
---
 .../java/org/apache/thrift/server/CustomizedTThreadPoolServer.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/server/src/main/java/org/apache/thrift/server/CustomizedTThreadPoolServer.java b/server/src/main/java/org/apache/thrift/server/CustomizedTThreadPoolServer.java
index 7640b2c..b181bfa 100644
--- a/server/src/main/java/org/apache/thrift/server/CustomizedTThreadPoolServer.java
+++ b/server/src/main/java/org/apache/thrift/server/CustomizedTThreadPoolServer.java
@@ -163,7 +163,7 @@ public class CustomizedTThreadPoolServer extends TServer {
     if (eventHandler_ != null) {
       eventHandler_.preServe();
     }
-    LOGGER.info("set stopped_ to false");
+    LOGGER.info("set stopped_ to false. Memory instance {}", this);
     stoppedCheck.set(false);
     stopped_ = false;
     setServing(true);
@@ -231,7 +231,7 @@ public class CustomizedTThreadPoolServer extends TServer {
       } catch (TTransportException ttx) {
         if (!stopped_) {
           ++failureCount;
-          LOGGER.warn("Stopped: {}. Transport error occurred during acceptance of message.", stopped_, ttx);
+          LOGGER.warn("Stopped: {}. Transport error occurred during acceptance of message. Memory instance {}", stopped_, ttx, this);
           stopped_ = stoppedCheck.get();
           LOGGER.info("update Stopped to {}.", stopped_);
         }
@@ -261,7 +261,7 @@ public class CustomizedTThreadPoolServer extends TServer {
   }
 
   public void stop() {
-    LOGGER.info("set stopped_ to true");
+    LOGGER.info("set stopped_ to true. Memory instance {}", this);
     stoppedCheck.set(true);
     super.stopped_ = true;
     serverTransport_.interrupt();