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

More debugging output for NanoScheduler when debugging is enabled

This commit is contained in:
Mark DePristo 2012-09-04 13:44:39 -04:00
parent 9823102c0c
commit d7105223fe
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
public/java/src/org/broadinstitute/sting/utils/nanoScheduler/NanoScheduler.java
View File

@ -220,12 +220,14 @@ public class NanoScheduler<InputType, MapType, ReduceType> {
try {
// read in our input values
final List<InputType> inputs = readInputs(inputReader);
debugPrint("Enqueuing " + inputs.size() + " elements to map");
// send jobs for map
final Queue<Future<MapType>> mapQueue = submitMapJobs(map, executor, inputs);
// send off the reduce job, and block until we get at least one reduce result
sum = reduceSerial(reduce, mapQueue, sum);
debugPrint(" Done with cycle of map/reduce");
} catch (InterruptedException ex) {
throw new ReviewedStingException("got execution exception", ex);
} catch (ExecutionException ex) {
@ -307,6 +309,7 @@ public class NanoScheduler<InputType, MapType, ReduceType> {
@Override public MapType call() throws Exception {
if ( TIME_CALLS) mapTimer.restart();
if ( debug ) debugPrint("\t\tmap " + input);
final MapType result = map.apply(input);
if ( TIME_CALLS) mapTimer.stop();
return result;