storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From knusb...@apache.org
Subject [1/4] storm git commit: Add logging to closeChannelAndReconnect() to help with connnection troubleshooting
Date Mon, 16 Mar 2015 19:31:04 GMT
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 <mnoll@verisign.com>
Authored: Wed Mar 11 12:07:11 2015 +0100
Committer: Michael G. Noll <mnoll@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);
             }
         }


Mime
View raw message