1 package edu.berkeley.fleet.loops;
2 import edu.berkeley.fleet.api.*;
8 * A program is a collection of CodeBags resident in a particular Memory.
10 * FIXME: should every Program have an associated ShipPool?
12 public class Program {
14 public final Fleet fleet;
15 public final Ship memoryShip;
17 private CodeBag end = null;
19 private long leastUnallocatedAddress;
20 private long startAddress;
22 private ArrayList<CodeBag> codeBags = new ArrayList<CodeBag>();
23 private ArrayList<Instruction> all_instructions = new ArrayList<Instruction>();
25 public Program(Ship memoryShip) { this(memoryShip, 0); }
26 public Program(Ship memoryShip, long startAddress) {
27 this.fleet = memoryShip.getFleet();
28 this.memoryShip = memoryShip;
29 this.startAddress = startAddress;
30 this.leastUnallocatedAddress = startAddress;
33 public Destination getCBDDestination() {
34 return memoryShip.getDock("inCBD").getDataDestination();
37 public long run(FleetProcess fp, CodeBag run, ShipPool pool) {
38 Ship timer = pool.allocateShip("Timer");
39 Ship debug = pool.allocateShip("Debug");
40 Dock debugIn = debug.getDock("in");
44 CodeBag start = new CodeBag(fleet, this);
45 lf = start.loopFactory(timer.getDock("out"), 1);
47 lf.sendWord(debugIn.getDataDestination());
48 lf = start.loopFactory(debugIn, 1);
53 start.sendWord(run.getDescriptor(), getCBDDestination());
56 lf = done.loopFactory(timer.getDock("out"), 1);
58 lf.sendWord(debugIn.getDataDestination());
65 MemoryUtils.putMemoryShipInDispatchMode(fp, memoryShip);
66 fp.sendWord(getCBDDestination(), start.getDescriptor().getBitVector());
68 long now = System.currentTimeMillis();
69 System.out.println("waiting for timestamps to come back...");
70 BitVector bv1 = fp.recvWord();
72 System.out.println("got start time (bv="+bv1+" = "+bv1.toLong()+")");
73 BitVector bv2 = fp.recvWord();
74 System.out.println("got end time (bv="+bv2+" = "+bv2.toLong()+")");
75 long ret = (bv2.toLong()-bv1.toLong());
76 long simtime = (System.currentTimeMillis()-now)/1000;
77 System.out.println("total run time = " + ret + " gate delays, " + (ret/40) + "ns (simulation time="+simtime+"sec)");
78 MemoryUtils.removeMemoryShipFromDispatchMode(fp, memoryShip);
83 public void dump(String file) {
85 FileOutputStream fos = new FileOutputStream(file);
86 PrintWriter pw = new PrintWriter(new OutputStreamWriter(fos));
87 for(int i=0; i<codeBags.size(); i++)
88 for(Instruction in : codeBags.get(i).emit())
92 } catch (Exception e) { throw new RuntimeException(e); }
95 public CodeBag getEndProgramCodeBag() {
96 if (end != null) return end;
97 end = new CodeBag(fleet, this);
101 /** the provided pool should be a sibling of the one which holds this Program's instructions */
102 public void install(FleetProcess fp, ShipPool pool) {
103 for(int i=0; i<codeBags.size(); i++)
104 codeBags.get(i).emit();
105 BitVector[] bvs = new BitVector[(int)(leastUnallocatedAddress-startAddress)];
106 for(int i=0; i<bvs.length; i++) {
107 bvs[i] = fleet.encodeInstruction(all_instructions.get(i), memoryShip.getDock("out"));
109 MemoryUtils.writeMem(fp, pool, memoryShip, startAddress, bvs);
112 BitVector addInstructions(Instruction[] instructions) {
114 // CodeBags are "daisy chained" to eliminate any possibility
115 // of cloggage at the inCBD port as a result of more CBD's
116 // being dispatched than the maximum number that fit in the
117 // data fifo at that dock.
119 int MAX_BAG_SIZE = (1<<6)-1;
121 // FUZZ is an estimate of the number of instructions required
122 // to dispatch a code bag descriptor
125 if (instructions.length <= MAX_BAG_SIZE) {
126 BitVector descriptor = new BitVector(fleet.getWordWidth());
127 descriptor.set( (leastUnallocatedAddress<<6) | instructions.length );
128 leastUnallocatedAddress += instructions.length;
129 for(Instruction i : instructions)
130 all_instructions.add(i);
134 System.out.println("warning: code bag size is "+instructions.length+
135 ", which exceeds maximum of "+MAX_BAG_SIZE+
136 "; breaking into multiple bags");
138 Instruction[] rest = new Instruction[instructions.length - (MAX_BAG_SIZE-FUZZ)];
139 System.arraycopy(instructions, MAX_BAG_SIZE-FUZZ, rest, 0, rest.length);
141 DeferredBitVector restbag = addInstructions(rest);
142 CodeBag ctx = new CodeBag(fleet);
143 ctx.sendWord(restbag, getCBDDestination());
144 Instruction[] fuzz = ctx.emit();
145 if (fuzz.length > FUZZ) throw new RuntimeException("FUZZ="+FUZZ+", fuzz.length="+fuzz.length);
146 Instruction[] self = new Instruction[fuzz.length+MAX_BAG_SIZE-FUZZ];
147 System.arraycopy(instructions, 0, self, 0, MAX_BAG_SIZE-FUZZ);
148 System.arraycopy(fuzz, 0, self, MAX_BAG_SIZE-FUZZ, fuzz.length);
149 return addInstructions(self);