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/23 22:11:30 UTC
[3/6] storm git commit: Clarify name of method for dropping messages
Clarify name of method for dropping messages
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/00613438
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/00613438
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/00613438
Branch: refs/heads/master
Commit: 006134383ed448084e358f993e34f12ba5b45dcf
Parents: b60ab23
Author: Michael G. Noll <mn...@verisign.com>
Authored: Mon Feb 16 10:03:07 2015 +0100
Committer: Michael G. Noll <mn...@verisign.com>
Committed: Mon Feb 16 10:03:07 2015 +0100
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/00613438/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 71aa794..189fa95 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -431,14 +431,14 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
*/
private void handleMessagesWhenConnectionIsUnavailable(Iterator<TaskMessage> msgs) {
LOG.error("connection to {} is unavailable", dstAddressPrefixedName);
- dropPendingMessages(msgs);
+ dropMessages(msgs);
}
- private void dropPendingMessages(Iterator<TaskMessage> msgs) {
+ private void dropMessages(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);
+ LOG.error("dropping {} message(s) destined for {}", msgCount, dstAddressPrefixedName);
}
private int iteratorSize(Iterator<TaskMessage> msgs) {