This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch fix-cn-rpc-processor-block in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3190f10d3eab7aa3619cdfb388a120445341d0fa Author: Yongzao <[email protected]> AuthorDate: Fri Sep 5 09:18:47 2025 +0800 Update AbstractThriftServiceThread.java --- .../iotdb/commons/service/AbstractThriftServiceThread.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java index 7537308d6cd..93b216890cb 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java @@ -37,7 +37,6 @@ import org.apache.thrift.server.TThreadedSelectorServer; import org.apache.thrift.transport.TNonblockingServerSocket; import org.apache.thrift.transport.TNonblockingServerTransport; import org.apache.thrift.transport.TSSLTransportFactory; -import org.apache.thrift.transport.TServerSocket; import org.apache.thrift.transport.TServerTransport; import org.apache.thrift.transport.TTransportException; import org.apache.thrift.transport.TTransportFactory; @@ -214,7 +213,9 @@ public abstract class AbstractThriftServiceThread extends Thread { this.serviceName = serviceName; try { - serverTransport = openTransport(bindAddress, port); + serverTransport = + openNonblockingTransport( + bindAddress, port, (int) TimeUnit.SECONDS.toMillis(timeoutSecond)); TThreadPoolServer.Args poolArgs = initSyncedPoolArgs(processor, threadsName, maxWorkerThreads, timeoutSecond); poolServer = new TThreadPoolServer(poolArgs); @@ -275,12 +276,6 @@ public abstract class AbstractThriftServiceThread extends Thread { return poolArgs; } - @SuppressWarnings("java:S2259") - private TServerTransport openTransport(String bindAddress, int port) throws TTransportException { - // bind any address - return new TServerSocket(new InetSocketAddress(port)); - } - private TServerTransport openNonblockingTransport( String bindAddress, int port, int connectionTimeoutInMS) throws TTransportException { // bind any address
