private MessageType getMsgType()

in runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageEnvironment.java [206:230]

• 25 lines of code
• 17 McCabe index (conditional complexity)

  private MessageType getMsgType(final ControlMessage.Message controlMessage) {
    switch (controlMessage.getType()) {
      case TaskStateChanged:
      case ScheduleTask:
      case BlockStateChanged:
      case ExecutorFailed:
      case RunTimePassMessage:
      case ExecutorDataCollected:
      case MetricMessageReceived:
      case RequestMetricFlush:
      case MetricFlushed:
      case PipeInit:
        return MessageType.Send;
      case RequestBlockLocation:
      case RequestBroadcastVariable:
      case RequestPipeLoc:
        return MessageType.Request;
      case BlockLocationInfo:
      case InMasterBroadcastVariable:
      case PipeLocInfo:
        return MessageType.Reply;
      default:
        throw new IllegalArgumentException(controlMessage.toString());
    }
  }