You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2015/02/24 02:07:08 UTC
accumulo git commit: ACCUMULO-3616 Use TTimeoutTransport instead of
TSocket
Repository: accumulo
Updated Branches:
refs/heads/master 92384163a -> ae7c2d257
ACCUMULO-3616 Use TTimeoutTransport instead of TSocket
TTimeoutTransport also sets some slightly larger buffers than TSocket.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/ae7c2d25
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/ae7c2d25
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/ae7c2d25
Branch: refs/heads/master
Commit: ae7c2d25774045c04f8324b20ec85e7a07e83610
Parents: 9238416
Author: Josh Elser <el...@apache.org>
Authored: Mon Feb 23 19:05:04 2015 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Mon Feb 23 19:05:04 2015 -0500
----------------------------------------------------------------------
.../main/java/org/apache/accumulo/core/rpc/ThriftUtil.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/ae7c2d25/core/src/main/java/org/apache/accumulo/core/rpc/ThriftUtil.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/rpc/ThriftUtil.java b/core/src/main/java/org/apache/accumulo/core/rpc/ThriftUtil.java
index 51dd5ba..f2e8612 100644
--- a/core/src/main/java/org/apache/accumulo/core/rpc/ThriftUtil.java
+++ b/core/src/main/java/org/apache/accumulo/core/rpc/ThriftUtil.java
@@ -337,7 +337,13 @@ public class ThriftUtil {
log.trace("Creating SASL connection to {}:{}", address.getHostText(), address.getPort());
- transport = new TSocket(address.getHostText(), address.getPort());
+ // Make sure a timeout is set
+ try {
+ transport = TTimeoutTransport.create(address, timeout);
+ } catch (IOException e) {
+ log.warn("Failed to open transport to {}", address);
+ throw new TTransportException(e);
+ }
try {
// Log in via UGI, ensures we have logged in with our KRB credentials