HADOOP-9630. [RPC v9] Remove IpcSerializationType. (Junping Du via llu)

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

Author: vicaya

hadoop-common-project/hadoop-common/CHANGES.txt

@@ -358,17 +358,19 @@ Release 2.1.0-beta - UNRELEASED
 
     HADOOP-8886. Remove KFS support. (eli)
 
-    HADOOP-9163 The rpc msg in ProtobufRpcEngine.proto should be moved out to
+    HADOOP-9163. [RPC v9] The rpc msg in ProtobufRpcEngine.proto should be moved out to
     avoid an extra copy (Sanjay Radia)
 
-    HADOOP-9151 Include RPC error info in RpcResponseHeader instead of sending
+    HADOOP-9151. [RPC v9] Include RPC error info in RpcResponseHeader instead of sending
     it separately (sanjay Radia)
 
-    HADOOP-9380 Add totalLength to rpc response  (sanjay Radia)
+    HADOOP-9380. [RPC v9] Add totalLength to rpc response  (sanjay Radia)
 
-    HADOOP-9425 Add error codes to rpc-response (sanjay Radia)
+    HADOOP-9425. [RPC v9] Add error codes to rpc-response (sanjay Radia)
 
-    HADOOP-9194. RPC support for QoS. (Junping Du via llu)
+    HADOOP-9194. [RPC v9] RPC support for QoS. (Junping Du via llu)
+
+    HADOOP-9630. [RPC v9] Remove IpcSerializationType. (Junping Du via llu)
 
   NEW FEATURES
 

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java

@@ -750,8 +750,6 @@ private void handleConnectionFailure(int curRetries, IOException ioe
      * +----------------------------------+
      * |  Authmethod (1 byte)             |      
      * +----------------------------------+
-     * |  IpcSerializationType (1 byte)   |      
-     * +----------------------------------+
      */
     private void writeConnectionHeader(OutputStream outStream)
         throws IOException {
@@ -761,7 +759,6 @@ private void writeConnectionHeader(OutputStream outStream)
       out.write(Server.CURRENT_VERSION);
       out.write(serviceClass);
       authMethod.write(out);
-      Server.IpcSerializationType.PROTOBUF.write(out);
       out.flush();
     }
 

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java

@@ -164,22 +164,6 @@ boolean isTerse(Class<?> t) {
    */
   public static final ByteBuffer HEADER = ByteBuffer.wrap("hrpc".getBytes());
 
-  /**
-   * Serialization type for ConnectionContext and RpcRequestHeader
-   */
-  public enum IpcSerializationType {
-    // Add new serialization type to the end without affecting the enum order
-    PROTOBUF;
-    
-    void write(DataOutput out) throws IOException {
-      out.writeByte(this.ordinal());
-    }
-    
-    static IpcSerializationType fromByte(byte b) {
-      return IpcSerializationType.values()[b];
-    }
-  }
-  
   /**
    * If the user accidentally sends an HTTP GET to an IPC port, we detect this
    * and send back a nicer response.
@@ -1322,7 +1306,7 @@ public int readAndProcess() throws IOException, InterruptedException {
         if (!connectionHeaderRead) {
           //Every connection is expected to send the header.
           if (connectionHeaderBuf == null) {
-            connectionHeaderBuf = ByteBuffer.allocate(4);
+            connectionHeaderBuf = ByteBuffer.allocate(3);
           }
           count = channelRead(channel, connectionHeaderBuf);
           if (count < 0 || connectionHeaderBuf.remaining() > 0) {
@@ -1355,13 +1339,6 @@ public int readAndProcess() throws IOException, InterruptedException {
             return -1;
           }
 
-          IpcSerializationType serializationType = IpcSerializationType
-              .fromByte(connectionHeaderBuf.get(3));
-          if (serializationType != IpcSerializationType.PROTOBUF) {
-            respondUnsupportedSerialization(serializationType);
-            return -1;
-          }
-          
           dataLengthBuffer.clear();
           if (authMethod == null) {
             throw new IOException("Unable to read authentication method");
@@ -1554,18 +1531,6 @@ private void setupBadVersionResponse(int clientVersion) throws IOException {
       }
     }
 
-    private void respondUnsupportedSerialization(IpcSerializationType st) throws IOException {
-      String errMsg = "Server IPC version " + CURRENT_VERSION
-          + " do not support serilization " + st.toString();
-      ByteArrayOutputStream buffer = new ByteArrayOutputStream();
-
-      Call fakeCall = new Call(-1, null, this);
-      setupResponse(buffer, fakeCall, 
-       RpcStatusProto.FATAL,  RpcErrorCodeProto.FATAL_UNSUPPORTED_SERIALIZATION,
-       null, IpcException.class.getName(), errMsg);
-      responder.doRespond(fakeCall);
-    }
-    
     private void setupHttpRequestOnIpcPortResponse() throws IOException {
       Call fakeCall =  new Call(0, null, this);
       fakeCall.setResponse(ByteBuffer.wrap(