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:57 UTC
[2/5] storm git commit: Clarify name of method for dropping messages
Clarify name of method for dropping messages
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/97a76fc8
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/97a76fc8
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/97a76fc8
Branch: refs/heads/0.9.3-branch
Commit: 97a76fc896de508f015dbe32f1473ddbf10d736b
Parents: 81016c2
Author: Michael G. Noll <mn...@verisign.com>
Authored: Mon Feb 16 10:03:07 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 | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/97a76fc8/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 f275ef6..77c20c8 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -443,14 +443,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) {