in src/main/java/org/apache/nifi/controller/status/ProcessGroupStatus.java [651:671]
public static FlowFileAvailability mergeFlowFileAvailability(final FlowFileAvailability availabilityA, final FlowFileAvailability availabilityB) {
if (availabilityA == availabilityB) {
return availabilityA;
}
if (availabilityA == null) {
return availabilityB;
}
if (availabilityB == null) {
return availabilityA;
}
if (availabilityA == FlowFileAvailability.FLOWFILE_AVAILABLE || availabilityB == FlowFileAvailability.FLOWFILE_AVAILABLE) {
return FlowFileAvailability.FLOWFILE_AVAILABLE;
}
if (availabilityA == FlowFileAvailability.HEAD_OF_QUEUE_PENALIZED || availabilityB == FlowFileAvailability.HEAD_OF_QUEUE_PENALIZED) {
return FlowFileAvailability.HEAD_OF_QUEUE_PENALIZED;
}
return FlowFileAvailability.FLOWFILE_AVAILABLE;
}