You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/02/25 23:09:58 UTC
[3/5] storm git commit: Track how many messages are being dropped
when a connection is unavailable
Track how many messages are being dropped when a connection is unavailable
Signed-off-by: P. Taylor Goetz <pt...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/81016c2e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/81016c2e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/81016c2e
Branch: refs/heads/0.9.3-branch
Commit: 81016c2ed7222da99138bc9971e335533d4cb518
Parents: 62788f2
Author: Michael G. Noll <mn...@verisign.com>
Authored: Mon Feb 16 10:01:27 2015 +0100
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Tue Feb 24 18:09:56 2015 -0500
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/81016c2e/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 ae8a8d5..f275ef6 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -449,6 +449,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
private void dropPendingMessages(Iterator<TaskMessage> msgs) {
// We consume the iterator by traversing and thus "emptying" it.
int msgCount = iteratorSize(msgs);
+ messagesLost.getAndAdd(msgCount);
LOG.error("dropping {} pending message(s) destined for {}", msgCount, dstAddressPrefixedName);
}