adjust ships to use fill/drain/full/empty macros
[fleet.git] / ships / Memory.ship
1 ship: Memory
2
3 == Ports ===========================================================
4 data  in:    inCBD
5 data  in:    inAddrRead
6 data  in:    inAddrWrite
7 data  in:    inDataWrite
8
9 data  out:   out
10
11 == TeX ==============================================================
12
13 The {\tt Memory} ship represents an interface to a storage space,
14 which can be used to read from it or write to it.  This storage space
15 might be a fast on-chip cache, off chip DRAM, or perhaps even a disk
16 drive.
17
18 Generally, distinct {\tt Memory} ships do not access the same backing
19 storage, although this is not strictly prohibited.
20
21 Each {\tt Memory} ship may have multiple {\it interfaces}, numbered
22 starting with {\tt 0}.  Each interface may have any subset of the
23 following docks: {\tt inCBD}, {\tt inAddrRead}, {\tt inAddrWrite},
24 {\tt inDataWrite}, and {\tt out}.  If {\tt inCBD} or {\tt inAddrRead}
25 is present on an interface, then {\tt out} must be present as well.
26 If {\tt inAddrWrite} is present then {\tt inDataWrite} must be present
27 as well.
28
29 Each interface serializes the operations presented to it; this means
30 that an interface with both read and write capabilities will not be
31 able to read and write concurrently.  Instead, a {\tt Memory} ship
32 with the ability to read and write concurrently should have two
33 interfaces, one which is read-only and one which is write-only.
34
35 There may be multiple {\tt Memory} ships which interface to the same
36 physical storage space.  An implementation of Fleet must provide
37 additional documentation to the programmer indicating which {\tt
38 Memory} ships correspond to which storage spaces.  A single {\tt
39 Memory} ship may also access a ``virtual storage space'' formed by
40 concatenating multiple physical storage spaces.
41
42 \subsection*{Code Bag Fetch}
43
44 When a word appears at the {\tt inCBD} port, it is treated as a {\it
45 code bag descriptor}, as shown below:
46
47 \begin{center}
48 \setlength{\bitwidth}{3mm}
49 {\tt
50 \begin{bytefield}{37}
51   \bitheader[b]{36,6,5,0}\\
52   \bitbox{31}{Address} 
53   \bitbox{6}{size} 
54 \end{bytefield}
55 }
56 \end{center}
57
58 When a word arrives at the {\tt inCBD} port, it is treated as a memory
59 read with {\tt inAddrRead=Address}, {\tt inStride=1}, and {\tt
60 inCount=size}.
61
62 \subsection*{Reading}
63
64 When a word is delivered to {\tt inAddrRead}, the word residing in
65 memory at that address is provided at {\tt out}.  The {\tt c-flag} at
66 the {\tt out} port is set to zero.
67
68 \subsection*{Writing}
69
70 When a word is delivered to {\tt inAddrWrite} and {\tt inDataWrite},
71 the word at {\tt inDataWrite} is written to the address specified by
72 {\tt inAddrWrite}.  Once the word is successfully committed to memory,
73 the value {\tt inAddr+inStride} is provided at {\tt out} (that is, the
74 address of the next word to be written).  The {\tt c-flag} at
75 the {\tt out} port is set to one.
76
77 \subsection*{To Do}
78
79 Stride and count are not implemented.
80
81 We need a way to do an ``unordered fetch'' -- a way to tell the memory
82 unit to retrieve some block of words in any order it likes.  This can
83 considerably accelerate fetches when the first word of the region is
84 not cached, but other parts are cached.  This can also be used for
85 dispatching codebags efficiently -- but how will we make sure that
86 instructions destined for a given pump are dispatched in the correct
87 order (source sequence guarantee)?
88
89 A more advanced form would be ``unordered fetch of ordered records''
90 -- the ability to specify a record size (in words), the offset of the
91 first record, and the number of records to be fetched.  The memory
92 unit would then fetch the records in any order it likes, but would be
93 sure to return the words comprising a record in the order in which
94 they appear in memory.  This feature could be used to solve the source
95 sequence guarantee problem mentioned in the previous paragraph.
96
97 == Fleeterpreter ====================================================
98     private long[] mem = new long[0];
99     public long readMem(int addr) { return addr >= mem.length ? 0 : mem[addr]; }
100     public void writeMem(int addr, long val) {
101         if (addr >= mem.length) {
102             long[] newmem = new long[addr * 2 + 1];
103             System.arraycopy(mem, 0, newmem, 0, mem.length);
104             mem = newmem;
105         }
106         mem[addr] = val;
107     }
108
109     private long stride = 0;
110     private long count = 0;
111     private long addr = 0;
112     private boolean writing = false;
113
114     private Queue<Long> toDispatch = new LinkedList<Long>();
115     public void service() {
116
117         if (toDispatch.size() > 0) {
118             //if (!box_out.readyForDataFromShip()) return;
119             //box_out.addDataFromShip(toDispatch.remove());
120             getInterpreter().dispatch(getInterpreter().readInstruction(toDispatch.remove(), getDock("out")));
121         }
122
123         if (box_inCBD.dataReadyForShip() && box_out.readyForDataFromShip()) {
124             long val = box_inCBD.removeDataForShip();
125             long addr = val >> 6;
126             long size = val & 0x3f;
127             for(int i=0; i<size; i++)
128               toDispatch.add(readMem((int)(addr+i)));
129         }
130         if (count > 0) {
131             if (writing) {
132               if (box_inDataWrite.dataReadyForShip() && box_out.readyForDataFromShip()) {
133                  writeMem((int)addr, box_inDataWrite.removeDataForShip());
134                  box_out.addDataFromShip(0);
135                  count--;
136                  addr += stride;
137               }
138             } else {
139               if (box_out.readyForDataFromShip()) {
140                  box_out.addDataFromShip(readMem((int)addr));
141                  count--;
142                  addr += stride;
143               }
144             }
145
146         } else if (box_inAddrRead.dataReadyForShip()) {
147             addr = box_inAddrRead.removeDataForShip();
148             stride = 0;
149             count = 1;
150             writing = false;
151
152         } else if (box_inAddrWrite.dataReadyForShip()) {
153             addr = box_inAddrWrite.removeDataForShip();
154             stride = 0;
155             count = 1;
156             writing = true;
157         }
158     }
159
160 == FleetSim ==============================================================
161
162 == FPGA ==============================================================
163
164   wire [(`DATAWIDTH-1):0] out1;
165   wire [(`DATAWIDTH-1):0] out2;
166
167   reg [(`CODEBAG_SIZE_BITS-1):0]   counter;
168   reg [(`BRAM_ADDR_WIDTH-1):0]     cursor;
169   initial cursor = 0;
170   initial counter = 0;
171
172   reg                              write_flag;
173   reg                              out_w;
174   reg                              dispatching_cbd;
175   initial write_flag = 0;
176   initial dispatching_cbd = 0;
177
178   wire [(`BRAM_ADDR_WIDTH-1):0]   addr1;
179   assign addr1 = write_flag ? inAddrWrite_d[(`DATAWIDTH-1):0] : inAddrRead_d[(`DATAWIDTH-1):0];
180   bram14 mybram(clk, rst, write_flag, addr1, cursor, inDataWrite_d, out1, out2);
181
182   assign out_d_ = { out_w , (dispatching_cbd ? out2 : out1) };
183
184   always @(posedge clk) begin
185
186     write_flag <= 0;
187
188     if (!rst) begin
189       `reset
190       cursor  <= 0;
191       counter <= 0;
192       write_flag <= 0;
193       dispatching_cbd <= 0;
194     end else begin
195       `flush
196       `cleanup
197       write_flag <= 0;
198
199       // assumes we never want a zero-length codebag
200       if (`inCBD_full && `out_empty) begin
201         if (!dispatching_cbd) begin
202           cursor          <= inCBD_d[(`DATAWIDTH-1):(`CODEBAG_SIZE_BITS)];
203           counter         <= 0;
204           dispatching_cbd <= 1;
205         end
206         `fill_out
207         out_w <= 0;
208       end else if (`inCBD_full && `out_draining) begin
209         if (counter != inCBD_d[(`CODEBAG_SIZE_BITS-1):0]) begin
210           cursor  <= cursor + 1;
211           counter <= counter + 1;
212         end else begin
213           `drain_inCBD
214           counter <= 0;
215           dispatching_cbd <= 0;
216         end
217       end else if (!dispatching_cbd && `out_empty && `inAddrRead_full) begin
218         `drain_inAddrRead
219         `fill_out
220
221       end else if (!dispatching_cbd && `out_empty && `inAddrWrite_full && `inDataWrite_full) begin
222         // timing note: it's okay to drain here because *_d will still
223         // be valid on the *very next* cycle, which is all we care about
224         `drain_inAddrWrite
225         `drain_inDataWrite
226         `fill_out
227         write_flag      <= 1;
228         out_w           <= 1;
229       end
230     end
231   end
232     
233
234
235
236 == Test ==============================================================
237 // FIXME: test c-flag at out dock
238 // FIXME: rename to inCBD0, inAddrWrite0, etc
239
240 // expected output
241 #expect 12
242 #expect 13
243 #expect 14
244
245 // ships required in order to run this code
246 #ship debug          : Debug
247 #ship memory         : Memory
248
249 // instructions not in any codebag are part of the "root codebag"
250 // which is dispatched when the code is loaded
251
252 memory.out:
253   set ilc=*;  collect packet, send;
254
255 memory.inCBD:
256   set word= BOB;
257   deliver;
258
259 BOB: {
260   debug.in:
261     set word= 12; deliver;
262     set word= 13; deliver;
263     set word= 14; deliver;
264 }
265
266
267 == Constants ========================================================
268
269 == Contributors =========================================================
270 Adam Megacz <megacz@cs.berkeley.edu>