Repository: storm Updated Branches: refs/heads/master 81ce9a1d6 -> 3d48f4213
Add logging to closeChannelAndReconnect() to help with connnection troubleshooting Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/50aac686 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/50aac686 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/50aac686 Branch: refs/heads/master Commit: 50aac686de68f783c5767a281922f05ce05e4127 Parents: 27a3606 Author: Michael G. Noll <mn...@verisign.com> Authored: Wed Mar 11 12:07:11 2015 +0100 Committer: Michael G. Noll <mn...@verisign.com> Committed: Wed Mar 11 12:13:02 2015 +0100 ---------------------------------------------------------------------- storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/50aac686/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java index 7392d3e..56a4607 100644 --- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java +++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java @@ -487,8 +487,10 @@ public class Client extends ConnectionWithStatus implements IStatefulObject { private synchronized void closeChannelAndReconnect(Channel channel) { if (channel != null) { + LOG.info("closing channel {} to {}", channel.toString(), dstAddressPrefixedName); channel.close(); if (channelRef.compareAndSet(channel, null)) { + LOG.info("triggering reconnect to {}", dstAddressPrefixedName); connect(NO_DELAY_MS); } }
