Author: dhruba
Date: Fri Apr 25 14:29:17 2008
New Revision: 651703
URL: http://svn.apache.org/viewvc?rev=651703&view=rev
Log:
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)
Modified:
hadoop/core/trunk/src/java/org/apache/hadoop/dfs/ClientProtocol.java
hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DatanodeProtocol.java
hadoop/core/trunk/src/java/org/apache/hadoop/dfs/NamenodeProtocol.java
Modified: hadoop/core/trunk/src/java/org/apache/hadoop/dfs/ClientProtocol.java
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/dfs/ClientProtocol.java?rev=651703&r1=651702&r2=651703&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/dfs/ClientProtocol.java
(original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/dfs/ClientProtocol.java Fri
Apr 25 14:29:17 2008
@@ -37,9 +37,9 @@
* 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
Modified: hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DatanodeProtocol.java
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DatanodeProtocol.java?rev=651703&r1=651702&r2=651703&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DatanodeProtocol.java
(original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DatanodeProtocol.java Fri
Apr 25 14:29:17 2008
@@ -30,13 +30,10 @@
*
**********************************************************************/
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;
Modified: hadoop/core/trunk/src/java/org/apache/hadoop/dfs/NamenodeProtocol.java
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/dfs/NamenodeProtocol.java?rev=651703&r1=651702&r2=651703&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/dfs/NamenodeProtocol.java
(original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/dfs/NamenodeProtocol.java Fri
Apr 25 14:29:17 2008
@@ -27,7 +27,10 @@
* 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>
