You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ke...@apache.org on 2013/07/13 05:05:38 UTC

svn commit: r1502739 - in /hama/trunk: CHANGES.txt core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java

Author: kennethxian
Date: Sat Jul 13 03:05:36 2013
New Revision: 1502739

URL: http://svn.apache.org/r1502739
Log:
HAMA-776: localQueue is set as Send queue in init function of AbstractMessageManager

Modified:
    hama/trunk/CHANGES.txt
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java

Modified: hama/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hama/trunk/CHANGES.txt?rev=1502739&r1=1502738&r2=1502739&view=diff
==============================================================================
--- hama/trunk/CHANGES.txt (original)
+++ hama/trunk/CHANGES.txt Sat Jul 13 03:05:36 2013
@@ -6,6 +6,7 @@ Release 0.6.3 (unreleased changes)
 
   BUG FIXES
 
+   HAMA-776: localQueue is set as Send queue in init function of AbstractMessageManager (kennethxian)
    HAMA-769: Intermediate queue's close method is not called, clean work may be omitted (kennethxian)
    HAMA-771: Determining the count of active vertices (edwardyoon)
    HAMA-777: FunctionFactory does not work when create IdentityFunction (Yexi Jiang)

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=1502739&r1=1502738&r2=1502739&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 Sat Jul 13 03:05:36 2013
@@ -90,7 +90,7 @@ public abstract class AbstractMessageMan
     this.peer = peer;
     this.conf = conf;
     this.peerAddress = peerAddress;
-    this.localQueue = getSenderQueue();
+    this.localQueue = getReceiverQueue();
     this.localQueueForNextIteration = getSynchronizedReceiverQueue();
     this.maxCachedConnections = conf.getInt(MAX_CACHED_CONNECTIONS_KEY, 100);
   }