svn commit: r1351388 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java

[tommaso]

Author: tommaso
Date: Mon Jun 18 15:39:59 2012
New Revision: 1351388

URL: http://svn.apache.org/viewvc?rev=1351388&view=rev
Log:
[HAMA-572] - minor fix to javadoc, useless boolean initialization and unneded 
declared exceptions

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java?rev=1351388&r1=1351387&r2=1351388&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java 
(original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java Mon Jun 
18 15:39:59 2012
@@ -305,7 +305,7 @@ public final class BSPPeerImpl<K1, V1, K
     Iterator<Entry<InetSocketAddress, MessageQueue<M>>> it = messenger
         .getMessageIterator();
 
-    boolean shouldCheckPoint = false;
+    boolean shouldCheckPoint;
 
     if ((shouldCheckPoint = isReadyToCheckpoint())) {
       lastCheckPointStep = getSuperstepCount();
@@ -363,8 +363,7 @@ public final class BSPPeerImpl<K1, V1, K
         currentTaskStatus.getSuperstepCount());
   }
 
-  public final void close() throws SyncException, IOException,
-      InterruptedException {
+  public final void close() {
     // there are many catches, because we want to close always every component
     // even if the one before failed.
     if (in != null) {
@@ -448,7 +447,7 @@ public final class BSPPeerImpl<K1, V1, K
   /**
    * Sets the current status
    * 
-   * @param currentTaskStatus
+   * @param currentTaskStatus the new task status to set
    */
   public final void setCurrentTaskStatus(TaskStatus currentTaskStatus) {
     this.currentTaskStatus = currentTaskStatus;