zzh
/
gatk-3.8
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Bugfix: handle case where queue is empty. 

git-svn-id: file:///humgen/gsa-scr1/gsa-engineering/svn_contents/trunk@808 348d0f76-0448-11de-a6fe-93d51630548a
This commit is contained in:
hanna 2009-05-22 21:45:22 +00:00
parent ec2e8d5726
commit 34413362fd
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
java/src/org/broadinstitute/sting/gatk/executive/HierarchicalMicroScheduler.java
View File

@ -1,7 +1,5 @@
package org.broadinstitute.sting.gatk.executive; package org.broadinstitute.sting.gatk.executive;
import org.broadinstitute.sting.gatk.traversals.TraverseLoci;
import org.broadinstitute.sting.gatk.traversals.TraversalEngine;
import org.broadinstitute.sting.gatk.walkers.Walker; import org.broadinstitute.sting.gatk.walkers.Walker;
import org.broadinstitute.sting.gatk.walkers.TreeReducible; import org.broadinstitute.sting.gatk.walkers.TreeReducible;
import org.broadinstitute.sting.gatk.dataSources.shards.ShardStrategy; import org.broadinstitute.sting.gatk.dataSources.shards.ShardStrategy;
@ -168,7 +166,10 @@ public class HierarchicalMicroScheduler extends MicroScheduler implements Reduce
* @return True if this output is ready to be merged. False otherwise. * @return True if this output is ready to be merged. False otherwise.
*/ */
protected boolean isOutputMergeReady() { protected boolean isOutputMergeReady() {
if( outputMergeTasks.size() > 0 )
return outputMergeTasks.peek().isComplete(); return outputMergeTasks.peek().isComplete();
else
return false;
} }
/** /**