Make criteria for determining whether to stop and merge inputs more sane.
git-svn-id: file:///humgen/gsa-scr1/gsa-engineering/svn_contents/trunk@855 348d0f76-0448-11de-a6fe-93d51630548a
This commit is contained in:
parent
fe3b843b65
commit
a1edb898ef
|
|
@ -152,7 +152,7 @@ public class HierarchicalMicroScheduler extends MicroScheduler implements Reduce
|
||||||
// If any of the first MAX_OUTSTANDING merges aren't ready, the merge limit
|
// If any of the first MAX_OUTSTANDING merges aren't ready, the merge limit
|
||||||
// has not been exceeded.
|
// has not been exceeded.
|
||||||
OutputMerger[] outputMergers = outputMergeTasks.toArray( new OutputMerger[0] );
|
OutputMerger[] outputMergers = outputMergeTasks.toArray( new OutputMerger[0] );
|
||||||
for( int i = 0; i < outputMergers.length; i++ ) {
|
for( int i = 0; i < MAX_OUTSTANDING_OUTPUT_MERGES; i++ ) {
|
||||||
if( !outputMergers[i].isComplete() )
|
if( !outputMergers[i].isComplete() )
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue