public synchronized Collection getActiveTaskIDsForProfile()

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

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

  public synchronized Collection<Protos.TaskID> getActiveTaskIDsForProfile(ServiceResourceProfile serviceProfile) {
    List<Protos.TaskID> activeTaskIDs = new ArrayList<>();
    Set<Protos.TaskID> activeTaskIds = getActiveTaskIds();
    if (CollectionUtils.isNotEmpty(activeTaskIds) && CollectionUtils.isNotEmpty(tasks.values())) {
      for (Map.Entry<Protos.TaskID, NodeTask> entry : tasks.entrySet()) {
        NodeTask nodeTask = entry.getValue();
        if (activeTaskIds.contains(entry.getKey()) && nodeTask.getProfile().getName().equals(serviceProfile.getName())) {
          activeTaskIDs.add(entry.getKey());
        }
      }
    }
    return Collections.unmodifiableCollection(activeTaskIDs);
  }