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 <[email protected]> Sonar-Qube: Jenkins <[email protected]> Integration-Tests: Murtadha Hubail <[email protected]> Tested-by: Murtadha Hubail <[email protected]> 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 <[email protected]> Authored: Tue Jan 16 14:14:22 2018 -0500 Committer: Michael Blow <[email protected]> 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; }
