Track how many messages are being dropped when a connection is unavailable
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b60ab23c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b60ab23c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b60ab23c Branch: refs/heads/master Commit: b60ab23c467b7bc3d7cd1de34b3ce52126148743 Parents: 205eaf4 Author: Michael G. Noll <[email protected]> Authored: Mon Feb 16 10:01:27 2015 +0100 Committer: Michael G. Noll <[email protected]> Committed: Mon Feb 16 10:01:27 2015 +0100 ---------------------------------------------------------------------- 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/b60ab23c/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 5d99718..71aa794 100644 --- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java +++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java @@ -437,6 +437,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); }
