Bläddra i källkod

HADOOP-3283. The Datanode has a RPC server. It currently supports
two RPCs: the first RPC retrives the metadata about a block and the
second RPC sets the generation stamp of an existing block.
(Tsz Wo (Nicholas), SZE via dhruba)



git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/trunk@651703 13f79535-47bb-0310-9956-ffa450edef68

Dhruba Borthakur 17 år sedan
förälder
incheckning
6e9e6b9d78

+ 2 - 2
src/java/org/apache/hadoop/dfs/ClientProtocol.java

@@ -37,9 +37,9 @@ interface ClientProtocol extends VersionedProtocol {
    * Compared to the previous version the following changes have been introduced:
    * (Only the latest change is reflected.
    * The log of historical changes can be retrieved from the svn).
-   * 30 : add underConstruction flag to LocatedBlocks
+   * 31: changed the serialization in DatanodeRegistration and DatanodeInfo
    */
-  public static final long versionID = 30L;
+  public static final long versionID = 31L;
   
   ///////////////////////////////////////
   // File contents

+ 3 - 6
src/java/org/apache/hadoop/dfs/DatanodeProtocol.java

@@ -30,13 +30,10 @@ import org.apache.hadoop.ipc.VersionedProtocol;
  *
  **********************************************************************/
 interface DatanodeProtocol extends VersionedProtocol {
-  /*
-   * 12: removed the rack ID from registration;
-   * 12: added DNA_BLOCKREPORT
-   * 11 : reportBadBlocks() is added.
-   * 11 Block reports as long[]
+  /**
+   * 13: changed the serialization in DatanodeRegistration and DatanodeInfo
    */
-  public static final long versionID = 12L;
+  public static final long versionID = 13L;
   
   // error code
   final static int NOTIFY = 0;

+ 4 - 1
src/java/org/apache/hadoop/dfs/NamenodeProtocol.java

@@ -27,7 +27,10 @@ import org.apache.hadoop.ipc.VersionedProtocol;
  * It's used to get part of the name node state
  *****************************************************************************/
 interface NamenodeProtocol extends VersionedProtocol {
-  public static final long versionID = 0L;
+  /**
+   * 1: changed the serialization in DatanodeInfo
+   */
+  public static final long versionID = 1L;
 
   /** Get a list of blocks belonged to <code>datanode</code>
     * whose total size is equal to <code>size</code>