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/

[edwardyoon]

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;
     }