You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by kn...@apache.org on 2015/03/16 20:31:05 UTC
[2/4] storm git commit: Add logging to connect() for corner cases
(e.g. client is being closed)
Add logging to connect() for corner cases (e.g. client is being closed)
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ea2a61d9
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ea2a61d9
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ea2a61d9
Branch: refs/heads/master
Commit: ea2a61d91310835a78354052889e37761a68f5cf
Parents: 50aac68
Author: Michael G. Noll <mn...@verisign.com>
Authored: Wed Mar 11 12:14:18 2015 +0100
Committer: Michael G. Noll <mn...@verisign.com>
Committed: Wed Mar 11 12:14:18 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/ea2a61d9/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 56a4607..4ab60f7 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -246,10 +246,12 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
private synchronized void connect(long delayMs) {
try {
if (closing) {
+ LOG.info("not connecting to {} because this client is being closed", dstAddressPrefixedName);
return;
}
if (connectionEstablished(channelRef.get())) {
+ LOG.info("not connecting to {} because the connection is already established", dstAddressPrefixedName);
return;
}