if (alreadyScheduled.contains(source)) { assert source.getPrimePump() <= trace.getPrimePump() : "Unsupported schedule created (source: " + source.toString() + ", dest: " + trace.toString();
if (scheduler.scheduledBefore(source, trace)) {
    private static void incrementUpstream(Trace trace, HashSet alreadyScheduled)     {	Iterator sources = trace.getHead().getSourceSet().iterator();	while (sources.hasNext()) {	    Trace source = ((Edge)sources.next()).getSrc().getParent();	    if (alreadyScheduled.contains(source)) {		assert source.getPrimePump() <= trace.getPrimePump() :		    "Unsupported schedule created (source: " + source.toString() + ", dest: " + trace.toString();		source.setPrimePump(trace.getPrimePump());	    }	    else {		source.setPrimePump(trace.getPrimePump() + 1);	    }	}    }