hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1606301 - in /hama/trunk/core/src: main/java/org/apache/hama/bsp/ft/ main/java/org/apache/hama/bsp/message/ test/java/org/apache/hama/bsp/
Date Sat, 28 Jun 2014 06:34:00 GMT
Author: edwardyoon
Date: Sat Jun 28 06:33:59 2014
New Revision: 1606301

URL: http://svn.apache.org/r1606301
Log:
Rename loopBackMessages to loopBackMessage

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/ft/AsyncRcvdMsgCheckpointImpl.java
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaMessageManagerImpl.java
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java
    hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/ft/AsyncRcvdMsgCheckpointImpl.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/ft/AsyncRcvdMsgCheckpointImpl.java?rev=1606301&r1=1606300&r2=1606301&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/ft/AsyncRcvdMsgCheckpointImpl.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/ft/AsyncRcvdMsgCheckpointImpl.java Sat
Jun 28 06:33:59 2014
@@ -399,7 +399,7 @@ public class AsyncRcvdMsgCheckpointImpl<
               message.readFields(in);
               bundle.addMessage(message);
             }
-            messenger.loopBackMessages(bundle);
+            messenger.loopBackBundle(bundle);
           } catch (EOFException e) {
             LOG.error("Error recovering from checkpointing", e);
             throw new IOException(e);

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=1606301&r1=1606300&r2=1606301&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 Jun 28 06:33:59 2014
@@ -278,7 +278,7 @@ public abstract class AbstractMessageMan
   }
 
   @Override
-  public void loopBackMessages(BSPMessageBundle<M> bundle) throws IOException {
+  public void loopBackBundle(BSPMessageBundle<M> bundle) throws IOException {
     bundle.setCompressor(compressor,
         conf.getLong("hama.messenger.compression.threshold", 128));
 

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaMessageManagerImpl.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaMessageManagerImpl.java?rev=1606301&r1=1606300&r2=1606301&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaMessageManagerImpl.java
(original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaMessageManagerImpl.java
Sat Jun 28 06:33:59 2014
@@ -151,8 +151,8 @@ public final class HamaMessageManagerImp
   }
 
   @Override
-  public final void put(BSPMessageBundle<M> messages) throws IOException {
-    loopBackMessages(messages);
+  public final void put(BSPMessageBundle<M> bundle) throws IOException {
+    loopBackBundle(bundle);
   }
 
   @Override

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java?rev=1606301&r1=1606300&r2=1606301&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java Sat Jun
28 06:33:59 2014
@@ -97,13 +97,13 @@ public interface MessageManager<M extend
   public int getNumCurrentMessages();
 
   /**
-   * Send the messages to self to receive in the next superstep.
+   * Send the message bundle to self to receive in the next superstep.
    */
-  public void loopBackMessages(BSPMessageBundle<M> bundle)
+  public void loopBackBundle(BSPMessageBundle<M> bundle)
       throws IOException;
 
   /**
-   * Send the message to self to receive in the next superstep.
+   * Send the single message to self to receive in the next superstep.
    */
   public void loopBackMessage(Writable message) throws IOException;
 

Modified: hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java?rev=1606301&r1=1606300&r2=1606301&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java Sat Jun 28 06:33:59
2014
@@ -131,7 +131,7 @@ public class TestCheckpoint extends Test
     }
 
     @Override
-    public void loopBackMessages(BSPMessageBundle<Text> bundle) {
+    public void loopBackBundle(BSPMessageBundle<Text> bundle) {
       this.loopbackBundle = (BSPMessageBundle<Text>) bundle;
     }
 



Mime
View raw message