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 2022/10/20 14:55:03 UTC
[iotdb] 01/01: expose tsocket from TElasticFramedTransport
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 <sa...@gmail.com>
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;
+ }
}