public static Type decode()

in common/src/main/java/org/apache/uniffle/common/netty/protocol/Message.java [71:121]

• 51 lines of code
• 23 McCabe index (conditional complexity)

    public static Type decode(ByteBuf buf) {
      byte id = buf.readByte();
      switch (id) {
        case 0:
          return RPC_RESPONSE;
        case 1:
          return SHUFFLE_REGISTER_REQUEST;
        case 2:
          return SHUFFLE_UNREGISTER_REQUEST;
        case 3:
          return SEND_SHUFFLE_DATA_REQUEST;
        case 4:
          return GET_LOCAL_SHUFFLE_INDEX_REQUEST;
        case 5:
          return GET_LOCAL_SHUFFLE_DATA_REQUEST;
        case 6:
          return GET_MEMORY_SHUFFLE_DATA_REQUEST;
        case 7:
          return SHUFFLE_COMMIT_REQUEST;
        case 8:
          return REPORT_SHUFFLE_RESULT_REQUEST;
        case 9:
          return GET_SHUFFLE_RESULT_REQUEST;
        case 10:
          return GET_SHUFFLE_RESULT_FOR_MULTI_PART_REQUEST;
        case 11:
          return FINISH_SHUFFLE_REQUEST;
        case 12:
          return REQUIRE_BUFFER_REQUEST;
        case 13:
          return APP_HEART_BEAT_REQUEST;
        case 14:
          return GET_LOCAL_SHUFFLE_INDEX_RESPONSE;
        case 15:
          return GET_LOCAL_SHUFFLE_DATA_RESPONSE;
        case 16:
          return GET_MEMORY_SHUFFLE_DATA_RESPONSE;
        case 17:
          return SHUFFLE_COMMIT_RESPONSE;
        case 18:
          return GET_SHUFFLE_RESULT_RESPONSE;
        case 19:
          return GET_SHUFFLE_RESULT_FOR_MULTI_PART_RESPONSE;
        case 20:
          return REQUIRE_BUFFER_RESPONSE;
        case -1:
          throw new IllegalArgumentException("User type messages cannot be decoded.");
        default:
          throw new IllegalArgumentException("Unknown message type: " + id);
      }
    }