public synchronized NodeTask getNodeTask()

in myriad-scheduler/src/main/java/org/apache/myriad/state/SchedulerState.java [286:299]

• 14 lines of code
• 6 McCabe index (conditional complexity)

  public synchronized NodeTask getNodeTask(SlaveID slaveId, String taskPrefix) {
    if (taskPrefix == null) {
      return null;
    }
    for (Map.Entry<Protos.TaskID, NodeTask> entry : tasks.entrySet()) {
      final NodeTask task = entry.getValue();
      if (task.getSlaveId() != null &&
          task.getSlaveId().equals(slaveId) &&
          taskPrefix.equals(task.getTaskPrefix())) {
        return entry.getValue();
      }
    }
    return null;
  }