Message::Type Message::decodeType()

in cpp/celeborn/network/Message.cpp [22:69]

• 48 lines of code
• 22 McCabe index (conditional complexity)

Message::Type Message::decodeType(uint8_t typeId) {
  switch (typeId) {
    case 0:
      return CHUNK_FETCH_REQUEST;
    case 1:
      return CHUNK_FETCH_SUCCESS;
    case 2:
      return CHUNK_FETCH_FAILURE;
    case 3:
      return RPC_REQUEST;
    case 4:
      return RPC_RESPONSE;
    case 5:
      return RPC_FAILURE;
    case 6:
      return OPEN_STREAM;
    case 7:
      return STREAM_HANDLE;
    case 9:
      return ONE_WAY_MESSAGE;
    case 11:
      return PUSH_DATA;
    case 12:
      return PUSH_MERGED_DATA;
    case 13:
      return REGION_START;
    case 14:
      return REGION_FINISH;
    case 15:
      return PUSH_DATA_HAND_SHAKE;
    case 16:
      return READ_ADD_CREDIT;
    case 17:
      return READ_DATA;
    case 18:
      return OPEN_STREAM_WITH_CREDIT;
    case 19:
      return BACKLOG_ANNOUNCEMENT;
    case 20:
      return TRANSPORTABLE_ERROR;
    case 21:
      return BUFFER_STREAM_END;
    case 22:
      return HEARTBEAT;
    default:
      CELEBORN_FAIL("Unknown message type " + std::to_string(typeId));
  }
}