You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2018/01/16 19:38:13 UTC
asterixdb git commit: [NO ISSUE] Address comments in
ReconnectingIPCHandle
Repository: asterixdb
Updated Branches:
refs/heads/master d94dc6dc9 -> d4914fbd8
[NO ISSUE] Address comments in ReconnectingIPCHandle
Change-Id: I916939f3419cdc6983253b4f6d8b46756fa13e69
Reviewed-on: https://asterix-gerrit.ics.uci.edu/2287
Reviewed-by: Murtadha Hubail <mh...@apache.org>
Sonar-Qube: Jenkins <je...@fulliautomatix.ics.uci.edu>
Integration-Tests: Murtadha Hubail <mh...@apache.org>
Tested-by: Murtadha Hubail <mh...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/d4914fbd
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/d4914fbd
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/d4914fbd
Branch: refs/heads/master
Commit: d4914fbd87a6d8c1f3138bc1aa3d2d5e26b236fd
Parents: d94dc6d
Author: Michael Blow <mi...@couchbase.com>
Authored: Tue Jan 16 14:14:22 2018 -0500
Committer: Michael Blow <mb...@apache.org>
Committed: Tue Jan 16 11:37:58 2018 -0800
----------------------------------------------------------------------
.../java/org/apache/hyracks/ipc/impl/ReconnectingIPCHandle.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/d4914fbd/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/ReconnectingIPCHandle.java
----------------------------------------------------------------------
diff --git a/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/ReconnectingIPCHandle.java b/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/ReconnectingIPCHandle.java
index f0da860..9a2fc80 100644
--- a/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/ReconnectingIPCHandle.java
+++ b/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/ReconnectingIPCHandle.java
@@ -72,11 +72,11 @@ class ReconnectingIPCHandle implements IIPCHandle {
if (delegate.isConnected()) {
return delegate;
}
+ LOGGER.warn("ipcHandle {} disconnected; will attempt to reconnect {} times", delegate, reconnectAttempts);
listener.ipcHandleDisconnected(delegate);
delegate = ipc.getHandle(getRemoteAddress(), reconnectAttempts);
- LOGGER.warn("ipcHandle " + delegate + " restored");
+ LOGGER.warn("ipcHandle {} restored", delegate);
listener.ipcHandleRestored(delegate);
-
return delegate;
}