Index: /trunk/Ohana/src/opihi/pantasks/CheckJobs.c
===================================================================
--- /trunk/Ohana/src/opihi/pantasks/CheckJobs.c	(revision 9277)
+++ /trunk/Ohana/src/opihi/pantasks/CheckJobs.c	(revision 9278)
@@ -8,4 +8,5 @@
   int i, status;
   char varname[64];
+  Queue *queue;
 
   /** test all jobs: ready to test?  finished? **/
@@ -99,4 +100,10 @@
 	}
 
+	/* flush the stderr and stdout queues */
+	queue = FindQueue ("stdout");
+	if (queue) InitQueue (queue);
+	queue = FindQueue ("stderr");
+	if (queue) InitQueue (queue);
+
 	DeleteJob (job);
 	continue;
@@ -115,4 +122,7 @@
       if (GetTaskTimer(job[0].start) < job[0].task[0].timeout_period) continue;
       if (VerboseMode()) gprint (GP_LOG, "timeout on %s\n", job[0].task[0].name);
+
+      // XXX harvest STDERR and STDOUT from timeout job (should be available...)
+      // XXX add this to controller as well
 
       /* update the timeout counter */