This is an automated email from the ASF dual-hosted git repository. hxd pushed a commit to branch IOTDB-4701 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3c330135a00d7947b025d990fb2ad30ea05f5a13 Author: xiangdong huang <[email protected]> AuthorDate: Thu Oct 20 22:54:42 2022 +0800 expose tsocket from TElasticFramedTransport --- .../src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java | 4 ++++ .../org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java | 6 ++++++ 2 files changed, 10 insertions(+) diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java b/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java index 036881d709..fb88642e84 100644 --- a/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java +++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java @@ -160,4 +160,8 @@ public class TElasticFramedTransport extends TTransport { public void write(byte[] buf, int off, int len) { writeBuffer.write(buf, off, len); } + + public TTransport getSocket() { + return underlying; + } } diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java b/service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java index 17f05e3f9f..95d8889582 100644 --- a/service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java +++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java @@ -66,4 +66,10 @@ public class TimeoutChangeableTFastFramedTransport extends TElasticFramedTranspo } } } + + @Override + public TTransport getSocket() { + // in fact, this should be the same with underlying... + return underlyingSocket; + } }
