BlockReadDataServerHandler Implementation

Alluxio · Dec 20, 2016 · 55928ee · 55928ee
1 parent 6cd4edf
commit 55928ee
Show file tree

Hide file tree

Showing 5 changed files with 191 additions and 382 deletions.
diff --git a/core/common/src/main/java/alluxio/network/protocol/RPCBlockReadResponse.java b/core/common/src/main/java/alluxio/network/protocol/RPCBlockReadResponse.java
@@ -69,6 +69,16 @@ public static RPCBlockReadResponse createErrorResponse(long blockId, Status stat
     return new RPCBlockReadResponse(blockId, -1, 0, null, status);
   }
 
+  /**
+   * Creates a {@link RPCBlockReadResponse} object that indicates a success for the given
+   * {@link RPCBlockReadRequest}.
+   *
+   * @return The generated {@link RPCBlockReadResponse} object
+   */
+  public static RPCBlockReadResponse createSuccessResponse(long blockId) {
+    return new RPCBlockReadResponse(blockId, -1, 0, null, Status.SUCCESS);
+  }
+
   /**
    * Decodes the input {@link ByteBuf} into a {@link RPCBlockReadResponse} object and returns it.
    *

diff --git a/core/common/src/main/java/alluxio/network/protocol/RPCResponse.java b/core/common/src/main/java/alluxio/network/protocol/RPCResponse.java
@@ -47,6 +47,7 @@ public enum Status {
 
     // TODO(now): Redesign the error codes. For now, treat all the errors the same.
     FAILED(106),
+    CANCELLED(107),
     ;
 
     private static final String DEFAULT_ERROR_STRING = "Unknown error.";