You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2014/08/29 00:46:47 UTC
svn commit: r1621219 -
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
Author: edwardyoon
Date: Thu Aug 28 22:46:47 2014
New Revision: 1621219
URL: http://svn.apache.org/r1621219
Log:
small improvement.
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java?rev=1621219&r1=1621218&r2=1621219&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java Thu Aug 28 22:46:47 2014
@@ -284,6 +284,8 @@ public abstract class AbstractMessageMan
conf.getLong("hama.messenger.compression.threshold", 128));
}
+ peer.incrementCounter(BSPPeerImpl.PeerCounter.TOTAL_MESSAGES_RECEIVED, bundle.size());
+
Iterator<? extends Writable> it = bundle.iterator();
while (it.hasNext()) {
loopBackMessage(it.next());
@@ -294,9 +296,7 @@ public abstract class AbstractMessageMan
@Override
public void loopBackMessage(Writable message) throws IOException {
this.localQueueForNextIteration.add((M) message);
- peer.incrementCounter(BSPPeerImpl.PeerCounter.TOTAL_MESSAGES_RECEIVED, 1L);
notifyReceivedMessage((M) message);
-
}
}