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:02 UTC
[iotdb] branch IOTDB-4701 created (now 3c330135a0)
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch IOTDB-4701
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 3c330135a0 expose tsocket from TElasticFramedTransport
This branch includes the following new commits:
new 3c330135a0 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
Posted by hx...@apache.org.
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;
+ }
}