You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2020/04/16 06:51:40 UTC
[incubator-iotdb] branch disable_mqtt_server updated: add private
stopped mark
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 be3a66a add private stopped mark
be3a66a is described below
commit be3a66ab1214a371bbc3e7231461aa4c3e4175ce
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Thu Apr 16 14:51:24 2020 +0800
add private stopped mark
---
.../org/apache/thrift/server/CustomizedTThreadPoolServer.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 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 e3a9fd4..6cbaa9c 100644
--- a/server/src/main/java/org/apache/thrift/server/CustomizedTThreadPoolServer.java
+++ b/server/src/main/java/org/apache/thrift/server/CustomizedTThreadPoolServer.java
@@ -44,6 +44,8 @@ import org.slf4j.LoggerFactory;
public class CustomizedTThreadPoolServer extends TServer {
private static final Logger LOGGER = LoggerFactory.getLogger(TThreadPoolServer.class.getName());
+ private volatile boolean stopped_ = false;
+
public static class Args extends AbstractServerArgs<Args> {
public int minWorkerThreads = 5;
public int maxWorkerThreads = Integer.MAX_VALUE;
@@ -161,6 +163,7 @@ public class CustomizedTThreadPoolServer extends TServer {
eventHandler_.preServe();
}
stopped_ = false;
+ super.stopped_ = false;
setServing(true);
return true;
@@ -179,7 +182,7 @@ public class CustomizedTThreadPoolServer extends TServer {
protected void execute() {
int failureCount = 0;
- while (!stopped_) {
+ while (!this.stopped_) {
try {
TTransport client = serverTransport_.accept();
WorkerProcess wp = new WorkerProcess(client);
@@ -254,7 +257,8 @@ public class CustomizedTThreadPoolServer extends TServer {
}
public void stop() {
- stopped_ = true;
+ this.stopped_ = true;
+ super.stopped_ = true;
serverTransport_.interrupt();
}