From d7105223fe7d8bb4848dbc2cfe7ccfbb9709b4b6 Mon Sep 17 00:00:00 2001
From: Mark DePristo <depristo@broadinstitute.org>
Date: Tue, 4 Sep 2012 13:44:39 -0400
Subject: [PATCH] More debugging output for NanoScheduler when debugging is
 enabled

---
 .../sting/utils/nanoScheduler/NanoScheduler.java               | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/public/java/src/org/broadinstitute/sting/utils/nanoScheduler/NanoScheduler.java b/public/java/src/org/broadinstitute/sting/utils/nanoScheduler/NanoScheduler.java
index 1ef4d3950..f0e77354f 100644
--- a/public/java/src/org/broadinstitute/sting/utils/nanoScheduler/NanoScheduler.java
+++ b/public/java/src/org/broadinstitute/sting/utils/nanoScheduler/NanoScheduler.java
@@ -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;