From 4c95b5e3a92023f23b949e43d916f2ae76671ab3 Mon Sep 17 00:00:00 2001
From: adam <adam@megacz.com>
Date: Tue, 21 Aug 2007 09:28:32 +0100
Subject: [PATCH] added dataOutDest

---
 src/edu/berkeley/fleet/api/Instruction.java        |    5 ++++-
 src/edu/berkeley/fleet/assembler/Parser.java       |    4 +++-
 src/edu/berkeley/fleet/assembler/fleet.g           |    1 +
 src/edu/berkeley/fleet/fpga/Generator.java         |   10 ++++++---
 src/edu/berkeley/fleet/ies44/BitManipulations.java |    2 +-
 .../berkeley/fleet/ies44/InstructionEncoder.java   |   23 ++++++++++----------
 .../berkeley/fleet/interpreter/Interpreter.java    |    4 ++--
 src/edu/berkeley/fleet/interpreter/Outbox.java     |   10 ++++++++-
 8 files changed, 39 insertions(+), 20 deletions(-)

diff --git a/src/edu/berkeley/fleet/api/Instruction.java b/src/edu/berkeley/fleet/api/Instruction.java
index 0be7246..33c49a4 100644
--- a/src/edu/berkeley/fleet/api/Instruction.java
+++ b/src/edu/berkeley/fleet/api/Instruction.java
@@ -27,6 +27,7 @@ public abstract class Instruction {
         public final boolean  tokenIn;
         public final boolean  dataIn;
         public final boolean  latch;
+        public final boolean  dataOutDest;
         public final boolean  dataOut;
         public final boolean  tokenOut;
         public final boolean  requeue;
@@ -38,6 +39,7 @@ public abstract class Instruction {
                           boolean     tokenIn,
                           boolean     dataIn,
                           boolean     latch,
+                          boolean     dataOutDest,
                           boolean     dataOut,
                           boolean     tokenOut,
                           boolean     requeue) {
@@ -47,6 +49,7 @@ public abstract class Instruction {
             this.tokenIn = tokenIn;
             this.dataIn = dataIn;
             this.latch = latch;
+            this.dataOutDest = dataOutDest;
             this.dataOut = dataOut;
             this.tokenOut = tokenOut;
             this.requeue = requeue;
@@ -61,7 +64,7 @@ public abstract class Instruction {
         public Instruction.Executable decrementCount() {
             if (count==1) return null;
             return new Executable(benkoBox, dest, count==0 ? 0 : count-1,
-                                  tokenIn, dataIn, latch, dataOut, tokenOut, requeue);
+                                  tokenIn, dataIn, latch, dataOutDest, dataOut, tokenOut, requeue);
         }
 
         public String toString() {
diff --git a/src/edu/berkeley/fleet/assembler/Parser.java b/src/edu/berkeley/fleet/assembler/Parser.java
index 890304f..af432a8 100644
--- a/src/edu/berkeley/fleet/assembler/Parser.java
+++ b/src/edu/berkeley/fleet/assembler/Parser.java
@@ -270,6 +270,7 @@ public class Parser {
                 boolean latch = false;
                 boolean dataOut = false;
                 boolean tokenOut = false;
+                boolean dataOutDest = false;
                 Destination dest = null;
                 for(int i=0; i<ttx.size(); i++) {
                     Tree ttt = ttx.child(i);
@@ -285,12 +286,13 @@ public class Parser {
                     else if ("Discard".equals(ttt.head())) { dataIn = true; latch = false; }
                     else if ("Take".equals(ttt.head()))    { dataIn = true; latch = true; }
                     else if ("SendTo".equals(ttt.head()))  { dataOut = true; dest = portReference(ttt.child(0)); }
+                    else if ("DataOutDest".equals(ttt.head()))  { dataOutDest = true; }
                     else if ("Deliver".equals(ttt.head())) { dataOut = true;  }
                     else if ("Ack".equals(ttt.head()))     { tokenOut = true; dest = portReference(ttt.child(0)); }
                 }
                 cb.add(new Instruction.Executable(benkobox,
                                                   dest, count, tokenIn, dataIn,
-                                                  latch, dataOut, tokenOut, requeue));
+                                                  latch, dataOutDest, dataOut, tokenOut, requeue));
             }
         }
     }
diff --git a/src/edu/berkeley/fleet/assembler/fleet.g b/src/edu/berkeley/fleet/assembler/fleet.g
index 4e69705..f73a0fe 100644
--- a/src/edu/berkeley/fleet/assembler/fleet.g
+++ b/src/edu/berkeley/fleet/assembler/fleet.g
@@ -33,6 +33,7 @@ Command         = Nop::      "nop"
                 | Discard::  "dismiss"
                 | Take::     ("take"|"receive")
                 | SendTo::   "sendto" ws! Port
+                | DataOutDest::   "send"
                 | Deliver::  "deliver"
                 | Ack::      "notify" ws! Port
 
diff --git a/src/edu/berkeley/fleet/fpga/Generator.java b/src/edu/berkeley/fleet/fpga/Generator.java
index 5036f9c..78432a4 100644
--- a/src/edu/berkeley/fleet/fpga/Generator.java
+++ b/src/edu/berkeley/fleet/fpga/Generator.java
@@ -625,12 +625,16 @@ public class Generator {
                                              new ConditionalAction("`instruction_bit_tokenout(ondeck)",
                                                                    new AssignAction(new SimpleAssignable("`packet_dest("+token_out.getName()+")"),
                                                                                     "`instruction_bit_dest(ondeck)")),
-                                             new ConditionalAction("`instruction_bit_dataout(ondeck)",
+                                             new ConditionalAction("`instruction_bit_dataout(ondeck) && !`instruction_bit_tokenout(ondeck)",
                                                                    inbox ? new SimpleAction("")
                                                                    : new AssignAction(new SimpleAssignable("`packet_dest("+data_out.getName()+")"),
-                                                                                      "`instruction_bit_dest(ondeck)"))
+                                                                                      "`instruction_bit_dest(ondeck)")),
+                                             new ConditionalAction("`instruction_bit_dataout(ondeck) && `instruction_bit_tokenout(ondeck)",
+                                                                   inbox ? new SimpleAction("")
+                                                                   : new AssignAction(new SimpleAssignable("`packet_dest("+data_out.getName()+")"),
+                                                                                      data_out.getName()+"["+(WIDTH_WORD-1)+":"+(WIDTH_WORD-WIDTH_DEST_ADDR)+"]"))
                               }
-                              );
+                      );
 
         PrintWriter pw = new PrintWriter(new OutputStreamWriter(new FileOutputStream(prefix+"/"+name+".v")));
         pw.println("`define instruction_bit_tokenout(instruction) instruction["+OFFSET_TO+"]");
diff --git a/src/edu/berkeley/fleet/ies44/BitManipulations.java b/src/edu/berkeley/fleet/ies44/BitManipulations.java
index de39c53..5197f10 100644
--- a/src/edu/berkeley/fleet/ies44/BitManipulations.java
+++ b/src/edu/berkeley/fleet/ies44/BitManipulations.java
@@ -3,7 +3,7 @@ import edu.berkeley.fleet.api.*;
 import edu.berkeley.fleet.*;
 import java.io.*;
 
-class BitManipulations {
+public class BitManipulations {
     public static boolean getBit(int bit, long val) { return ((val & (1L << bit)) != 0); }
     public static long getSignedField(int highBit, int lowBit, long val) {
         long ret = getField(highBit, lowBit, val);
diff --git a/src/edu/berkeley/fleet/ies44/InstructionEncoder.java b/src/edu/berkeley/fleet/ies44/InstructionEncoder.java
index 8ca184a..abe7f58 100644
--- a/src/edu/berkeley/fleet/ies44/InstructionEncoder.java
+++ b/src/edu/berkeley/fleet/ies44/InstructionEncoder.java
@@ -58,15 +58,16 @@ public abstract class InstructionEncoder {
                 BenkoBox name    = getBoxByInstAddr(getIntField(OFFSET_PUMP_ADDR+WIDTH_PUMP_ADDR-1, OFFSET_PUMP_ADDR, inst));
                 Destination dest = getDestByAddr   (getIntField(OFFSET_DEST+WIDTH_DEST_ADDR-1,      OFFSET_DEST,      inst));
                 int count        = getIntField(                 OFFSET_COUNT+WIDTH_COUNT-1,         OFFSET_COUNT,     inst);
-                boolean tokenIn  = getBit(OFFSET_TI, instr);
-                boolean dataIn   = getBit(OFFSET_DI, instr);
-                boolean latch    = getBit(OFFSET_DL, instr);
-                boolean dataOut  = getBit(OFFSET_DO, instr);
-                boolean tokenOut = getBit(OFFSET_TO, instr);
-                boolean requeue  = getBit(OFFSET_RQ, instr);
+                boolean tokenIn     = getBit(OFFSET_TI, instr);
+                boolean dataIn      = getBit(OFFSET_DI, instr);
+                boolean latch       = getBit(OFFSET_DL, instr);
+                boolean dataOut     = getBit(OFFSET_DO, instr);
+                boolean tokenOut    = getBit(OFFSET_TO, instr);
+                boolean requeue     = getBit(OFFSET_RQ, instr);
+                boolean dataOutDest = dataOut && tokenOut;
                 if (latch & !dataIn) return new Instruction.Kill(name, count, tokenIn);
-                return new Instruction.Executable(name, dest, count, tokenIn, dataIn,
-                                                  latch, dataOut, tokenOut, requeue);
+                return new Instruction.Executable(name, dest, count, tokenIn, dataIn, latch, dataOutDest,
+                                                  dataOut, tokenOut, requeue);
             }
 
             case 1: {
@@ -98,7 +99,7 @@ public abstract class InstructionEncoder {
         if (d instanceof Instruction.Kill) {
             Instruction.Kill k = (Instruction.Kill)d;
             d = new Instruction.Executable(k.benkoBox, null, k.count, k.killOnlyStandingInstructions,
-                                           false, true, false, false, false);
+                                           false, true, false, false, false, false);
         }
 
         if (d instanceof Instruction.Executable) {
@@ -109,8 +110,8 @@ public abstract class InstructionEncoder {
             instr |= putField(OFFSET_TI,                          OFFSET_TI,          inst.tokenIn?1:0);
             instr |= putField(OFFSET_DI,                          OFFSET_DI,          inst.dataIn?1:0);
             instr |= putField(OFFSET_DL,                          OFFSET_DL,          inst.latch?1:0);
-            instr |= putField(OFFSET_DO,                          OFFSET_DO,          inst.dataOut?1:0);
-            instr |= putField(OFFSET_TO,                          OFFSET_TO,          inst.tokenOut?1:0);
+            instr |= putField(OFFSET_DO,                          OFFSET_DO,          (inst.dataOutDest||inst.dataOut)?1:0);
+            instr |= putField(OFFSET_TO,                          OFFSET_TO,          (inst.dataOutDest||inst.tokenOut)?1:0);
             instr |= putField(OFFSET_RQ,                          OFFSET_RQ,          inst.requeue?1:0);
 
         } else if (d instanceof Instruction.Literal.CodeBagDescriptor) {
diff --git a/src/edu/berkeley/fleet/interpreter/Interpreter.java b/src/edu/berkeley/fleet/interpreter/Interpreter.java
index a259fb3..59b1575 100644
--- a/src/edu/berkeley/fleet/interpreter/Interpreter.java
+++ b/src/edu/berkeley/fleet/interpreter/Interpreter.java
@@ -130,12 +130,12 @@ public class Interpreter extends Fleet implements Fleet.WithDynamicShips {
 
     // Instruction Encoding /////////////////////////////////////////////////////////////////////////
 
-    private InterpreterInstructionEncoder iie = new InterpreterInstructionEncoder();
+    public final InterpreterInstructionEncoder iie = new InterpreterInstructionEncoder();
     public Instruction readInstruction(DataInputStream is) throws IOException { return iie.readInstruction(is); }
     public Instruction readInstruction(long instr) { return iie.readInstruction(instr); }
     public long writeInstruction(Instruction d) { return writeInstruction(d); }
     public void writeInstruction(DataOutputStream os, Instruction d) throws IOException { iie.writeInstruction(os, d); }
-    private class InterpreterInstructionEncoder extends InstructionEncoder {
+    public class InterpreterInstructionEncoder extends InstructionEncoder {
         public long getDestAddr(Destination box) { return ((InterpreterDestination)box).getDestAddr(); }
         public long getBoxInstAddr(BenkoBox box) { return ((InterpreterBenkoBox)box).getDestAddr(); }
         public Destination getDestByAddr(long dest) {
diff --git a/src/edu/berkeley/fleet/interpreter/Outbox.java b/src/edu/berkeley/fleet/interpreter/Outbox.java
index b6f76eb..1f80d0e 100644
--- a/src/edu/berkeley/fleet/interpreter/Outbox.java
+++ b/src/edu/berkeley/fleet/interpreter/Outbox.java
@@ -1,6 +1,7 @@
 package edu.berkeley.fleet.interpreter;
 import edu.berkeley.sbp.util.ANSI;
 import edu.berkeley.fleet.api.*;
+import edu.berkeley.fleet.ies44.*;
 import edu.berkeley.fleet.api.Instruction;
 
 public class Outbox extends InstructionBenkoBox {
@@ -47,7 +48,14 @@ public class Outbox extends InstructionBenkoBox {
         if (instruction.dataOut) {
 
             // if item to be transmitted, send it
-            new Packet(getInterpreter(), this, register, (InterpreterDestination)instruction.dest).send();
+            InterpreterDestination dest = (InterpreterDestination)instruction.dest;
+            if (instruction.dataOutDest) {
+                long bits = BitManipulations.getField(InstructionEncoder.WIDTH_WORD-1,
+                                                      InstructionEncoder.WIDTH_WORD-InstructionEncoder.WIDTH_DEST_ADDR,
+                                                      register);
+                dest = (InterpreterDestination)(((Interpreter)getInterpreter()).iie.getDestByAddr(bits));
+            }
+            new Packet(getInterpreter(), this, register, dest).send();
             if (instruction.tokenOut)
                 throw new RuntimeException("outboxes may not send acks!");
 
-- 
1.7.10.4