From a5d044424d5d18cc35f4d9ef253a3f607fab331f Mon Sep 17 00:00:00 2001
From: adam <adam@megacz.com>
Date: Mon, 17 Nov 2008 02:25:15 +0100
Subject: [PATCH] add extratokens option to shutdown code

---
 src/edu/berkeley/fleet/ir/Process.java |    8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/edu/berkeley/fleet/ir/Process.java b/src/edu/berkeley/fleet/ir/Process.java
index bb29b3e..4087064 100644
--- a/src/edu/berkeley/fleet/ir/Process.java
+++ b/src/edu/berkeley/fleet/ir/Process.java
@@ -215,6 +215,10 @@ public class Process {
                 peer.sendWord(lf);
             }
             public void reset(Context ctx, int phase) {
+
+                // set this to true to get a more "fine grained" report of the shutdown process
+                boolean extratokens = false;
+
                 switch(phase) {
                     case 0: {
                         torpedoes.add(dock);
@@ -222,13 +226,14 @@ public class Process {
                     }
                     case 1: {
                         Context.LoopFactory lf = ctx.new LoopFactory(dock, 1);
-                        lf.sendToken(fleet.getShip("Debug",0).getDock("in").getDataDestination());
                         if (peer != null) {
                             for(int i=0; i<peer.getTokensToAbsorb(); i++) {
                                 lf.recvToken();
+                                if (extratokens) lf.sendToken(fleet.getShip("Debug",0).getDock("in").getDataDestination());
                             }
                             //lf.sendToken(dip_peer.dock.getInstructionDestination());
                         }
+                        lf.sendToken(fleet.getShip("Debug",0).getDock("in").getDataDestination());
                         lf = lf.makeNext(0);
                         lf.abortLoopIfTorpedoPresent();
                         lf.collectWord();
@@ -236,6 +241,7 @@ public class Process {
                     }
                     case 2: {
                         reset_count++;
+                        if (extratokens && peer != null) reset_count += peer.getTokensToAbsorb();
                         break;
                     }
                     case 3: {
-- 
1.7.10.4