[iotdb] branch IOTDB-4701-0.14 created (now 261588f7f7)

[hx...@apache.org]

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

hxd pushed a change to branch IOTDB-4701-0.14
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 261588f7f7 expose tsocket from TElasticFramedTransport

This branch includes the following new commits:

     new 261588f7f7 expose tsocket from TElasticFramedTransport

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: expose tsocket from TElasticFramedTransport

[hx...@apache.org]

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

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

commit 261588f7f739e0a2babab4fd760ecd930cf15702
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Thu Oct 20 22:57:51 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;
+  }
 }