def toStatusCode()

in common/src/main/scala/org/apache/celeborn/common/util/Utils.scala [892:979]

• 88 lines of code
• 43 McCabe index (conditional complexity)

  def toStatusCode(status: Int): StatusCode = {
    status match {
      case 0 =>
        StatusCode.SUCCESS
      case 1 =>
        StatusCode.PARTIAL_SUCCESS
      case 2 =>
        StatusCode.REQUEST_FAILED
      case 3 =>
        StatusCode.SHUFFLE_ALREADY_REGISTERED
      case 4 =>
        StatusCode.SHUFFLE_NOT_REGISTERED
      case 5 =>
        StatusCode.RESERVE_SLOTS_FAILED
      case 6 =>
        StatusCode.SLOT_NOT_AVAILABLE
      case 7 =>
        StatusCode.WORKER_NOT_FOUND
      case 8 =>
        StatusCode.PARTITION_NOT_FOUND
      case 9 =>
        StatusCode.REPLICA_PARTITION_NOT_FOUND
      case 10 =>
        StatusCode.DELETE_FILES_FAILED
      case 11 =>
        StatusCode.PARTITION_EXISTS
      case 12 =>
        StatusCode.REVIVE_FAILED
      case 13 =>
        StatusCode.REPLICATE_DATA_FAILED
      case 14 =>
        StatusCode.NUM_MAPPER_ZERO
      case 15 =>
        StatusCode.MAP_ENDED
      case 16 =>
        StatusCode.STAGE_ENDED
      case 17 =>
        StatusCode.PUSH_DATA_FAIL_NON_CRITICAL_CAUSE
      case 18 =>
        StatusCode.PUSH_DATA_WRITE_FAIL_REPLICA
      case 19 =>
        StatusCode.PUSH_DATA_WRITE_FAIL_PRIMARY
      case 20 =>
        StatusCode.PUSH_DATA_FAIL_PARTITION_NOT_FOUND
      case 21 =>
        StatusCode.HARD_SPLIT
      case 22 =>
        StatusCode.SOFT_SPLIT
      case 23 =>
        StatusCode.STAGE_END_TIME_OUT
      case 24 =>
        StatusCode.SHUFFLE_DATA_LOST
      case 25 =>
        StatusCode.WORKER_SHUTDOWN
      case 26 =>
        StatusCode.NO_AVAILABLE_WORKING_DIR
      case 27 =>
        StatusCode.WORKER_EXCLUDED
      case 28 =>
        StatusCode.WORKER_UNKNOWN
      case 30 =>
        StatusCode.PUSH_DATA_SUCCESS_PRIMARY_CONGESTED
      case 31 =>
        StatusCode.PUSH_DATA_SUCCESS_REPLICA_CONGESTED
      case 38 =>
        StatusCode.PUSH_DATA_CREATE_CONNECTION_FAIL_PRIMARY
      case 39 =>
        StatusCode.PUSH_DATA_CREATE_CONNECTION_FAIL_REPLICA
      case 40 =>
        StatusCode.PUSH_DATA_CONNECTION_EXCEPTION_PRIMARY
      case 41 =>
        StatusCode.PUSH_DATA_CONNECTION_EXCEPTION_REPLICA
      case 42 =>
        StatusCode.PUSH_DATA_TIMEOUT_PRIMARY
      case 43 =>
        StatusCode.PUSH_DATA_TIMEOUT_REPLICA
      case 44 =>
        StatusCode.PUSH_DATA_PRIMARY_WORKER_EXCLUDED
      case 45 =>
        StatusCode.PUSH_DATA_REPLICA_WORKER_EXCLUDED
      case 46 =>
        StatusCode.FETCH_DATA_TIMEOUT
      case 47 =>
        StatusCode.REVIVE_INITIALIZED
      case _ =>
        null
    }
  }