cloudFPGA (cF) API  1.0
The documentation of the source code of cloudFPGA (cF)
•All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Modules Pages
toe.hpp
Go to the documentation of this file.
1 
17 
43 
71 #ifndef _TOE_H_
72 #define _TOE_H_
73 
74 #include <stdint.h>
75 #include "ap_int.h"
76 
77 #include "../../../NTS/nts.hpp"
78 #include "../../../NTS/nts_utils.hpp"
79 #include "../../../NTS/SimNtsUtils.hpp"
80 #include "../../../MEM/mem.hpp"
81 
82 
83 
87 //-- The Maximum Segment Size (MSS) that can be received and processed by TOE
88 //-- FYI: MSS is rounded modulo 8 bytes for better efficiency.
89 static const TcpSegLen MY_MSS = (MTU - IP4_HEADER_LEN - TCP_HEADER_LEN) & ~0x7; // 1456
90 
91 //-- The Maximum Segment Size (MSS) that can be transmitted by TOE
92 //-- FYI: This MSS is advertised by the remote host during the 3-may handshake.
93 static const TcpSegLen THEIR_MSS = ZYC2_MSS; // 1352
94 
95 
96 
99 #define TOE_SIZEOF_LISTEN_PORT_TABLE 0x8000
100 #define TOE_SIZEOF_ACTIVE_PORT_TABLE 0x8000
101 #define TOE_FIRST_EPHEMERAL_PORT_NUM 0x8000 // Dynamic ports are in the range 32768..65535
102 
103 #define TOE_FEATURE_USED_FOR_DEBUGGING 0
104 
105 
106 extern uint32_t packetCounter; // [FIXME] Remove
107 extern uint32_t idleCycCnt; // [FIXME] Remove
108 extern unsigned int gSimCycCnt; // [FIXME] Remove
109 
110 #ifndef __SYNTHESIS__
111  // HowTo - You should adjust the value of 'TIME_1s' such that the testbench
112  // works with your longest segment. In other words, if 'TIME_1s' is too short
113  // and/or your segment is too long, you may experience retransmission events
114  // (RT) which will break the test. You may want to use 'siIPRX_OneSeg.dat' or
115  // 'siIPRX_TwoSeg.dat' to tune this parameter.
116  static const ap_uint<32> TIME_1s = 250;
117 
118  static const ap_uint<32> TIME_1us = (((ap_uint<32>)(TIME_1s/1000000) > 1) ? (ap_uint<32>)(TIME_1s/1000000) : (ap_uint<32>)1);
119  static const ap_uint<32> TIME_64us = (((ap_uint<32>)(TIME_1s/ 15625) > 1) ? (ap_uint<32>)(TIME_1s/ 15625) : (ap_uint<32>)1);
120  static const ap_uint<32> TIME_128us = (((ap_uint<32>)(TIME_1s/ 31250) > 1) ? (ap_uint<32>)(TIME_1s/ 31250) : (ap_uint<32>)1);
121  static const ap_uint<32> TIME_256us = (((ap_uint<32>)(TIME_1s/ 62500) > 1) ? (ap_uint<32>)(TIME_1s/ 62500) : (ap_uint<32>)1);
122  static const ap_uint<32> TIME_512us = (((ap_uint<32>)(TIME_1s/ 125000) > 1) ? (ap_uint<32>)(TIME_1s/ 125000) : (ap_uint<32>)1);
123 
124  static const ap_uint<32> ACKD_1us = ( 1.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
125  static const ap_uint<32> ACKD_2us = ( 2.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
126  static const ap_uint<32> ACKD_4us = ( 4.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
127  static const ap_uint<32> ACKD_8us = ( 8.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
128  static const ap_uint<32> ACKD_16us = ( 16.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
129  static const ap_uint<32> ACKD_32us = ( 32.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
130  static const ap_uint<32> ACKD_64us = ( 64.0/0.0064/TOE_MAX_SESSIONS/10) + 1;
131 
132  static const ap_uint<32> TIME_1ms = (((ap_uint<32>)(TIME_1s/1000) > 1) ? (ap_uint<32>)(TIME_1s/1000) : (ap_uint<32>)1);
133  static const ap_uint<32> TIME_5ms = (((ap_uint<32>)(TIME_1s/ 200) > 1) ? (ap_uint<32>)(TIME_1s/ 200) : (ap_uint<32>)1);
134  static const ap_uint<32> TIME_25ms = (((ap_uint<32>)(TIME_1s/ 40) > 1) ? (ap_uint<32>)(TIME_1s/ 40) : (ap_uint<32>)1);
135  static const ap_uint<32> TIME_50ms = (((ap_uint<32>)(TIME_1s/ 20) > 1) ? (ap_uint<32>)(TIME_1s/ 20) : (ap_uint<32>)1);
136  static const ap_uint<32> TIME_100ms = (((ap_uint<32>)(TIME_1s/ 10) > 1) ? (ap_uint<32>)(TIME_1s/ 10) : (ap_uint<32>)1);
137  static const ap_uint<32> TIME_250ms = (((ap_uint<32>)(TIME_1s/ 4) > 1) ? (ap_uint<32>)(TIME_1s/ 4) : (ap_uint<32>)1);
138 
139  static const ap_uint<32> TIME_3s = ( 3*TIME_1s);
140  static const ap_uint<32> TIME_5s = ( 5*TIME_1s);
141  static const ap_uint<32> TIME_6s = ( 6*TIME_1s);
142  static const ap_uint<32> TIME_7s = ( 7*TIME_1s);
143  static const ap_uint<32> TIME_10s = ( 10*TIME_1s);
144  static const ap_uint<32> TIME_12s = ( 12*TIME_1s);
145  static const ap_uint<32> TIME_15s = ( 15*TIME_1s);
146  static const ap_uint<32> TIME_20s = ( 20*TIME_1s);
147  static const ap_uint<32> TIME_30s = ( 30*TIME_1s);
148  static const ap_uint<32> TIME_60s = ( 60*TIME_1s);
149  static const ap_uint<32> TIME_120s = (120*TIME_1s);
150 #else
151  static const ap_uint<32> ACKD_1us = ( 1.0/0.0064/TOE_MAX_SESSIONS) + 1;
152  static const ap_uint<32> ACKD_2us = ( 2.0/0.0064/TOE_MAX_SESSIONS) + 1;
153  static const ap_uint<32> ACKD_4us = ( 4.0/0.0064/TOE_MAX_SESSIONS) + 1;
154  static const ap_uint<32> ACKD_8us = ( 8.0/0.0064/TOE_MAX_SESSIONS) + 1;
155  static const ap_uint<32> ACKD_16us = ( 16.0/0.0064/TOE_MAX_SESSIONS) + 1;
156  static const ap_uint<32> ACKD_32us = ( 32.0/0.0064/TOE_MAX_SESSIONS) + 1;
157  static const ap_uint<32> ACKD_64us = ( 64.0/0.0064/TOE_MAX_SESSIONS) + 1;
158  static const ap_uint<32> TIME_128us = (128.0/0.0064/TOE_MAX_SESSIONS) + 1;
159  static const ap_uint<32> TIME_256us = (256.0/0.0064/TOE_MAX_SESSIONS) + 1;
160  static const ap_uint<32> TIME_512us = (512.0/0.0064/TOE_MAX_SESSIONS) + 1;
161 
162  static const ap_uint<32> TIME_1ms = ( 1.0/0.0000064/TOE_MAX_SESSIONS) + 1;
163  static const ap_uint<32> TIME_5ms = ( 5.0/0.0000064/TOE_MAX_SESSIONS) + 1;
164  static const ap_uint<32> TIME_25ms = ( 25.0/0.0000064/TOE_MAX_SESSIONS) + 1;
165  static const ap_uint<32> TIME_50ms = ( 50.0/0.0000064/TOE_MAX_SESSIONS) + 1;
166  static const ap_uint<32> TIME_100ms = (100.0/0.0000064/TOE_MAX_SESSIONS) + 1;
167  static const ap_uint<32> TIME_250ms = (250.0/0.0000064/TOE_MAX_SESSIONS) + 1;
168 
169  static const ap_uint<32> TIME_1s = ( 1.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
170  static const ap_uint<32> TIME_3s = ( 3.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
171  static const ap_uint<32> TIME_5s = ( 5.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
172  static const ap_uint<32> TIME_6s = ( 6.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
173  static const ap_uint<32> TIME_7s = ( 7.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
174  static const ap_uint<32> TIME_10s = ( 10.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
175  static const ap_uint<32> TIME_12s = ( 12.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
176  static const ap_uint<32> TIME_15s = ( 15.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
177  static const ap_uint<32> TIME_20s = ( 20.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
178  static const ap_uint<32> TIME_30s = ( 30.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
179  static const ap_uint<32> TIME_60s = ( 60.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
180  static const ap_uint<32> TIME_120s = (120.0/0.0000000064/TOE_MAX_SESSIONS) + 1;
181 #endif
182 
183 
184 
187 #define cIP4_ADDR_WIDTH 32
188 
189 #define cTCP_PORT_WIDTH 16
190 
191 #define cSHL_TOE_SESS_ID_WIDTH 16 // [TODO - Move into a CFG file.]
192 #define cSHL_TOE_LSN_ACK_WIDTH 1 // [TODO - Move into a CFG file.]
193 #define cSHL_TOE_LSN_REQ_WIDTH cSHL_TOE_SESS_ID_WIDTH
194 #define cSHL_TOE_OPN_REQ_WIDTH (cIP4_ADDR_WIDTH + cTCP_PORT_WIDTH)
195 #define cSHL_TOE_CLS_REQ_WIDTH cSHL_TOE_SESS_ID_WIDTH
196 
197 typedef ap_uint<cSHL_TOE_SESS_ID_WIDTH> SessionId;
198 typedef ap_uint<cSHL_TOE_LSN_ACK_WIDTH> LsnAck;
199 typedef ap_uint<cSHL_TOE_LSN_REQ_WIDTH> LsnReq;
200 typedef ap_uint<cSHL_TOE_OPN_REQ_WIDTH> OpnReq;
201 typedef ap_uint<cSHL_TOE_CLS_REQ_WIDTH> ClsReq;
202 
203 
206 const int cDepth_AKdToEVe_Event = 8;
207 const int cDepth_AKdToTXe_Event = 16;
208 
209 const int cDepth_EVeToAKd_Event = 8;
210 
211 const int cDepth_RAiToRSt_Qry = 4;
212 
213 const int cDepth_RXeToEVe_Event = 64;
214 const int cDepth_RXeToRSt_Qry = 4;
215 const int cDepth_RXeToTSt_Qry = 4;
216 
217 const int cDepth_STtToRXe_Rep = 2;
218 const int cDepth_STtToTAi_Rep = 2;
219 
220 const int cDepth_TAiToEVe_Event = 8;
221 const int cDepth_TAiToTSt_Cmd = 4;
222 
223 const int cDepth_TStToRXe_Rep = 2;
224 const int cDepth_TStToTAi_Cmd = 4;
225 const int cDepth_TStToTXe_Rep = 2;
226 
227 const int cDepth_TImToEVe_Event = 4;
228 
229 const int cDepth_TXeToEVe_Event = 8;
230 const int cDepth_TXeToRSt_Req = 4;
231 const int cDepth_TXeToTSt_Qry = 4;
232 
233 
242 enum notificationType {PKG, CLOSE, TIME_OUT, RESET};
243 enum { WORD_0, WORD_1, WORD_2, WORD_3, WORD_4, WORD_5 };
244 enum { CHUNK_0, CHUNK_1, CHUNK_2, CHUNK_3, CHUNK_4, CHUNK_5 };
245 
246 
247 #define TLAST 1
248 
249 
253 typedef ap_uint<64> LE_tData; // [FIXME] Can be removed
254 typedef ap_uint< 8> LE_tKeep;
255 typedef ap_uint<64> tData;
256 typedef ap_uint<32> tDataHalf;
257 typedef ap_uint< 8> tKeep;
258 typedef ap_uint< 1> tLast;
259 
260 
261 
262 
270 //---------------------------------------------------------
271 //-- TOE - EVENT TYPES
272 //---------------------------------------------------------
273 enum EventType { TX_EVENT=0, RT_EVENT, ACK_EVENT, SYN_EVENT, \
274  SYN_ACK_EVENT, FIN_EVENT, RST_EVENT, ACK_NODELAY_EVENT };
275 
276 //---------------------------------------------------------
277 //-- TOE - SESSION STATE
278 //---------------------------------------------------------
279 typedef TcpAppOpnRep SessState; // TCP state according to RFC-793
280 
281 //---------------------------------------------------------
282 //-- TOE - TCP PORT RANGES (Static & Ephemeral)
283 //---------------------------------------------------------
284 typedef ap_uint<15> TcpStaPort; // TCP Static Port [0x0000..0x7FFF]
285 typedef ap_uint<15> TcpDynPort; // TCP Dynamic Port [0x8000..0xFFFF]
286 
287 //---------------------------------------------------------
288 //-- TOE - Some Rx & Tx SAR Types
289 //---------------------------------------------------------
290 typedef TcpSeqNum RxSeqNum; // A sequence number received from the network layer
291 typedef TcpAckNum TxAckNum; // An acknowledge number transmitted to the network layer
292 typedef TcpWindow RemotWinSize; // A remote window size
293 typedef TcpWindow LocalWinSize; // A local window size
294 
295 typedef ap_uint<32> RxMemPtr; // A pointer to RxMemBuff ( 4GB) [FIXME <33>]
296 typedef ap_uint<32> TxMemPtr; // A pointer to TxMemBuff ( 4GB) [FIXME <33>]
297 typedef ap_uint<TOE_WINDOW_BITS> TcpBufAdr; // A TCP buffer address (64KB)
298 typedef TcpBufAdr RxBufPtr; // A pointer to RxSessBuf (64KB)
299 typedef TcpBufAdr TxBufPtr; // A pointer to TxSessBuf (64KB)
300 
301 //---------------------------------------------------------
302 //-- SOCKET ADDRESS (alias ipTuple)
303 //---------------------------------------------------------
304 struct ipTuple // [TODO] - Replace w/ SockAddr
305 {
306  ap_uint<32> ip_address;
307  ap_uint<16> ip_port;
308 };
309 
310 
314 typedef bool HitState;
315 enum HitStates { SESSION_UNKNOWN = false, SESSION_EXISTS = true};
316 
317 //=========================================================
318 //== SLc - Session Lookup Query
319 //=========================================================
320 class SessionLookupQuery {
321  public:
322  LE_SocketPair tuple; // [FIXME - Name and type]
323  bool allowCreation;
324  SessionLookupQuery() {}
325  SessionLookupQuery(LE_SocketPair tuple, bool allowCreation) :
326  tuple(tuple), allowCreation(allowCreation) {}
327 };
328 
329 //=========================================================
330 //== SLc - Session Lookup Reply
331 //=========================================================
332 class SessionLookupReply {
333  public:
334  SessionId sessionID;
335  HitState hit;
336  SessionLookupReply() {}
337  SessionLookupReply(SessionId id, HitState hit) :
338  sessionID(id), hit(hit) {}
339 };
340 
341 
345 //=========================================================
346 //== STt - Session State Query
347 //=========================================================
348 class StateQuery {
349  public:
350  SessionId sessionID;
351  TcpState state;
352  RdWrBit write;
353  StateQuery() :
354  state(CLOSED) {}
355  // Read queries
356  StateQuery(SessionId id) :
357  sessionID(id), state(CLOSED), write(QUERY_RD) {}
358  StateQuery(SessionId id, RdWrBit wrBit) :
359  sessionID(id), state(CLOSED), write(QUERY_RD) {}
360  // Write query
361  StateQuery(SessionId id, TcpState state, RdWrBit write) :
362  sessionID(id), state(state), write(QUERY_WR) {}
363 };
364 
365 //=========================================================
366 //== RSt / Generic Reply (Same as RxSarEntry)
367 //=========================================================
368 class RxSarReply {
369  public:
370  RxBufPtr appd;
371  RxSeqNum rcvd; // Last received SeqNum
372  RxSeqNum oooHead;
373  RxSeqNum oooTail;
374  FlagBool ooo;
375  RxSarReply() {}
376  RxSarReply(RxBufPtr appd, RxSeqNum rcvd, StsBool ooo, RxSeqNum oooHead, RxSeqNum oooTail) :
377  appd(appd), rcvd(rcvd), ooo(ooo), oooHead(oooHead), oooTail(oooTail) {}
378 };
379 
380 //=========================================================
381 //== RSt / Query from RXe
382 //=========================================================
383 class RXeRxSarQuery {
384  public:
385  SessionId sessionID;
386  RxSeqNum rcvd; // Last received SeqNum
387  RxSeqNum oooHead;
388  RxSeqNum oooTail;
389  FlagBool ooo;
390  RdWrBit write;
391  CmdBit init;
392  RXeRxSarQuery() :
393  ooo(false) {}
394  // Read queries
395  RXeRxSarQuery(SessionId id) :
396  sessionID(id), rcvd(0), ooo(false), oooHead(0), oooTail(0), write(QUERY_RD), init(0) {}
397  RXeRxSarQuery(SessionId id, RdWrBit wrBit) :
398  sessionID(id), rcvd(0), ooo(FLAG_INO), oooHead(0), oooTail(0), write(QUERY_RD), init(0) {}
399  // Write query - When in order processing
400  RXeRxSarQuery(SessionId id, RxSeqNum rcvd, RdWrBit wrBit) :
401  sessionID(id), rcvd(rcvd), ooo(FLAG_INO), oooHead(0), oooTail(0), write(QUERY_WR), init(0) {}
402  // Init query
403  RXeRxSarQuery(SessionId id, RxSeqNum rcvd, RdWrBit wrBit, CmdBit iniBit) :
404  sessionID(id), rcvd(rcvd), ooo(FLAG_INO), oooHead(0), oooTail(0), write(QUERY_WR), init(CMD_INIT) {}
405  // Write query - When in out-of-order processing
406  RXeRxSarQuery(SessionId id, RxSeqNum rcvd, FlagBool ooo, RxSeqNum oooHead, RxSeqNum oooTail, RdWrBit wrBit) :
407  sessionID(id), rcvd(rcvd), ooo(ooo), oooHead(oooHead), oooTail(oooTail), write(QUERY_WR), init(0) {}
408 
409 };
410 
411 //=========================================================
412 //== RSt / Query from RAi
413 //=========================================================
414 class RAiRxSarQuery {
415  public:
416  SessionId sessionID;
417  RxBufPtr appd; // Next byte to be consumed by [APP]
418  RdWrBit write;
419  RAiRxSarQuery() {}
420  RAiRxSarQuery(SessionId id) :
421  sessionID(id), appd(0), write(0) {}
422  RAiRxSarQuery(SessionId id, RxBufPtr appd) :
423  sessionID(id), appd(appd), write(1) {}
424 };
425 
426 //=========================================================
427 //== RSt / Reply to RAi
428 //=========================================================
429 class RAiRxSarReply {
430  public:
431  SessionId sessionID;
432  RxBufPtr appd; // Next byte to be consumed by [APP]
433  RAiRxSarReply() {}
434  RAiRxSarReply(SessionId id, RxBufPtr appd) :
435  sessionID(id), appd(appd) {}
436 };
437 
438 
442 //=========================================================
443 //== TSt / Query from RXe
444 //=========================================================
445 class RXeTxSarQuery {
446  public:
447  SessionId sessionID;
448  TxAckNum ackd; // TX'ed and ACK'ed
449  RemotWinSize recv_window; // Remote receiver's buffer size (their)
450  LocalWinSize cong_window; // Local receiver's buffer size (my)
451  ap_uint<2> count;
452  CmdBool fastRetransmitted;
453  RdWrBit write;
454 
455  RXeTxSarQuery () :
456  fastRetransmitted(false) {}
457  // Read Query
458  RXeTxSarQuery(SessionId id, RdWrBit wrBit) :
459  sessionID(id), fastRetransmitted(false), write(QUERY_RD) {}
460  // Write Query
461  RXeTxSarQuery(SessionId id, TxAckNum ackd, RemotWinSize recv_win, LocalWinSize cong_win, ap_uint<2> count, CmdBool fastRetransmitted) :
462  sessionID(id), ackd(ackd), recv_window(recv_win), cong_window(cong_win), count(count), fastRetransmitted(fastRetransmitted), write(QUERY_WR) {}
463 };
464 
465 //=========================================================
466 //== TSt / Reply to RXe
467 //=========================================================
468 class RXeTxSarReply {
469  public:
470  TxAckNum prevAckd; // Bytes TX'ed and ACK'ed
471  TxAckNum prevUnak; // Bytes TX'ed but not ACK'ed
472  TcpWindow cong_window;
473  TcpWindow slowstart_threshold;
474  ap_uint<2> count;
475  CmdBool fastRetransmitted;
476  RXeTxSarReply() {}
477  RXeTxSarReply(TxAckNum ackd, TxAckNum unak, TcpWindow cong_win, TcpWindow sstresh, ap_uint<2> count, CmdBool fastRetransmitted) :
478  prevAckd(ackd), prevUnak(unak), cong_window(cong_win), slowstart_threshold(sstresh), count(count), fastRetransmitted(fastRetransmitted) {}
479 };
480 
481 //=========================================================
482 //== TSt / Query from TXe
483 //=========================================================
484 class TXeTxSarQuery {
485  public:
486  SessionId sessionID;
487  TxAckNum not_ackd; // TX'ed but not ACK'ed
488  RdWrBit write;
489  CmdBit init;
490  bool finReady;
491  bool finSent;
492  bool isRtQuery;
493 
494  TXeTxSarQuery() :
495  finReady(false), finSent(false), isRtQuery(false) {}
496  // Read Query
497  TXeTxSarQuery(SessionId id, RdWrBit wrBit) :
498  sessionID(id), write(QUERY_RD), finReady(false), finSent(false), isRtQuery(false) {}
499  // Write Queries
500  TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write) :
501  sessionID(id), not_ackd(not_ackd), write(QUERY_WR), init(0), finReady(false), finSent(false), isRtQuery(false) {}
502  TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write, CmdBit init) :
503  sessionID(id), not_ackd(not_ackd), write(QUERY_WR), init(init), finReady(false), finSent(false), isRtQuery(false) {}
504  TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write, CmdBit init, bool finReady, bool finSent) :
505  sessionID(id), not_ackd(not_ackd), write(QUERY_WR), init(init), finReady(finReady), finSent(finSent), isRtQuery(false) {}
506  TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write, CmdBit init, bool finReady, bool finSent, bool isRt) :
507  sessionID(id), not_ackd(not_ackd), write(QUERY_WR), init(init), finReady(finReady), finSent(finSent), isRtQuery(isRt) {}
508 };
509 
510 //=========================================================
511 //== TSt / Reply to TXe
512 //=========================================================
513 class TXeTxSarReply {
514  public:
515  TxAckNum ackd; // TX'ed and ACK'ed
516  TxAckNum not_ackd; // TX'ed but not ACK'ed
517  TcpWindow min_window; // Min(cong_window, recv_window)
518  TxBufPtr app; // Written by APP
519  bool finReady;
520  bool finSent;
521  TXeTxSarReply() {}
522  TXeTxSarReply(ap_uint<32> ack, ap_uint<32> nack, ap_uint<16> min_window, ap_uint<16> app, bool finReady, bool finSent) :
523  ackd(ack), not_ackd(nack), min_window(min_window), app(app), finReady(finReady), finSent(finSent) {}
524 };
525 
526 //=========================================================
527 //== TSt / Re-transmission Query from TXe
528 //=========================================================
529 class TXeTxSarRtQuery : public TXeTxSarQuery
530 {
531  public:
532  TXeTxSarRtQuery() {}
533  TXeTxSarRtQuery(const TXeTxSarQuery& q) :
534  TXeTxSarQuery(q.sessionID, q.not_ackd, q.write, q.init, q.finReady, q.finSent, q.isRtQuery) {}
535  TXeTxSarRtQuery(SessionId id, ap_uint<TOE_WINDOW_BITS> ssthresh) :
536  TXeTxSarQuery(id, ssthresh, 1, 0, false, false, true) {}
537  ap_uint<TOE_WINDOW_BITS> getThreshold() {
538  return not_ackd(TOE_WINDOW_BITS-1, 0);
539  }
540 };
541 
542 //=========================================================
543 //== TSt / Tx Application Interface
544 //=========================================================
545 class TAiTxSarPush {
546  public:
547  SessionId sessionID;
548  TxBufPtr app;
549  TAiTxSarPush() {}
550  TAiTxSarPush(SessionId id, TxBufPtr app) :
551  sessionID(id), app(app) {}
552 };
553 
554 //=========================================================
555 //== TSt / Command from TSt
556 //=========================================================
557 class TStTxSarPush {
558  public:
559  SessionId sessionID;
560  ap_uint<16> ackd;
561 #if (TCP_NODELAY)
562  ap_uint<16> min_window;
563 #endif
564  CmdBit init;
565  TStTxSarPush() {}
566 #if !(TCP_NODELAY)
567  TStTxSarPush(SessionId id, ap_uint<16> ackd) :
568  sessionID(id), ackd(ackd), init(0) {}
569  TStTxSarPush(SessionId id, ap_uint<16> ackd, CmdBit init) :
570  sessionID(id), ackd(ackd), init(init) {}
571 #else
572  TStTxSarPush(SessionId id, ap_uint<16> ackd, ap_uint<16> min_window) :
573  sessionID(id), ackd(ackd), min_window(min_window), init(0) {}
574  TStTxSarPush(SessionId id, ap_uint<16> ackd, ap_uint<16> min_window, CmdBit init) :
575  sessionID(id), ackd(ackd), min_window(min_window), init(init) {}
576 #endif
577 };
578 
579 
583 //=========================================================
584 //== TAI / Tx Application Table (Tat) Request
585 //=========================================================
586 class TxAppTableQuery {
587  public:
588  SessionId sessId;
589  TxBufPtr mempt;
590  bool write;
591  TxAppTableQuery() {}
592  TxAppTableQuery(SessionId id) :
593  sessId(id), mempt(0), write(false) {}
594  TxAppTableQuery(SessionId id, ap_uint<16> pt) :
595  sessId(id), mempt(pt), write(true) {}
596 };
597 
598 //=========================================================
599 //== TAI / Tx Application Table (Tat) Reply
600 //=========================================================
601 class TxAppTableReply {
602  public:
603  SessionId sessId;
604  ap_uint<16> ackd;
605  TxBufPtr mempt;
606  #if (TCP_NODELAY)
607  ap_uint<16> min_window;
608  #endif
609  TxAppTableReply() {}
610  #if !(TCP_NODELAY)
611  TxAppTableReply(SessionId id, ap_uint<16> ackd, TxBufPtr pt) :
612  sessId(id), ackd(ackd), mempt(pt) {}
613  #else
614  TxAppTableReply(SessionId id, ap_uint<16> ackd, TxBufPtr pt, ap_uint<16> min_window) :
615  sessionID(id), ackd(ackd), mempt(pt), min_window(min_window) {}
616  #endif
617 };
618 
619 
622 enum TimerCmd {LOAD_TIMER = false,
623  STOP_TIMER = true};
624 
625 //=========================================================
626 //== TIm / ReTransmit Timer Command from RXe
627 //=========================================================
628 class RXeReTransTimerCmd {
629  public:
630  SessionId sessionID;
631  TimerCmd command; // { LOAD=false; STOP=true}
632  RXeReTransTimerCmd() {}
633  RXeReTransTimerCmd(SessionId id) :
634  sessionID(id), command(STOP_TIMER) {}
635  RXeReTransTimerCmd(SessionId id, TimerCmd cmd) :
636  sessionID(id), command(cmd) {}
637 };
638 
639 //=========================================================
640 //== TIm / ReTransmit Timer Command from TXe
641 //=========================================================
642 class TXeReTransTimerCmd {
643  public:
644  SessionId sessionID;
645  EventType type;
646  TXeReTransTimerCmd() {}
647  TXeReTransTimerCmd(SessionId id) :
648  sessionID(id), type(RT_EVENT) {}
649  TXeReTransTimerCmd(SessionId id, EventType type) :
650  sessionID(id), type(type) {}
651 };
652 
653 
657 //=========================================================
658 //== EVe / Event
659 //=========================================================
660 class Event
661 {
662  public:
663  EventType type;
664  SessionId sessionID;
665  TcpBufAdr address;
666  TcpSegLen length;
667  ap_uint<3> rt_count; // [FIXME - Make this type configurable]
668  Event() {}
669  Event(EventType type, SessionId id) :
670  type(type), sessionID(id), address(0), length(0), rt_count(0) {}
671  Event(EventType type, SessionId id, ap_uint<3> rt_count) :
672  type(type), sessionID(id), address(0), length(0), rt_count(rt_count) {}
673  Event(EventType type, SessionId id, ap_uint<16> addr, ap_uint<16> len) :
674  type(type), sessionID(id), address(addr), length(len), rt_count(0) {}
675  Event(EventType type, SessionId id, ap_uint<16> addr, ap_uint<16> len, ap_uint<3> rt_count) :
676  type(type), sessionID(id), address(addr), length(len), rt_count(rt_count) {}
677 };
678 
679 //=========================================================
680 //== EVe / ExtendedEvent
681 //=========================================================
682 class ExtendedEvent : public Event
683 {
684  public:
685  LE_SocketPair tuple; // [FIXME - Rename and change type]
686  ExtendedEvent() {}
687  ExtendedEvent(const Event& ev) :
688  Event(ev.type, ev.sessionID, ev.address, ev.length, ev.rt_count) {}
689  ExtendedEvent(const Event& ev, LE_SocketPair tuple) :
690  Event(ev.type, ev.sessionID, ev.address, ev.length, ev.rt_count), tuple(tuple) {}
691 };
692 
693 //=========================================================
694 //== EVe / RstEvent // [FIXME- TODO]
695 //=========================================================
696 struct rstEvent : public Event // [FIXME - Class naming convention]
697 {
698  rstEvent() {}
699  rstEvent(const Event& ev) :
700  Event(ev.type, ev.sessionID, ev.address, ev.length, ev.rt_count) {}
701  rstEvent(RxSeqNum seq) : //:Event(RST, 0, false), seq(seq) {}
702  Event(RST_EVENT, 0, seq(31, 16), seq(15, 0), 0) {}
703  rstEvent(SessionId id, RxSeqNum seq) :
704  Event(RST_EVENT, id, seq(31, 16), seq(15, 0), 1) {} //:Event(RST, id, true), seq(seq) {}
705  rstEvent(SessionId id, RxSeqNum seq, bool hasSessionID) :
706  Event(RST_EVENT, id, seq(31, 16), seq(15, 0), hasSessionID) {} //:Event(RST, id, hasSessionID), seq(seq) {}
707  TxAckNum getAckNumb() {
708  RxSeqNum seq;
709  seq(31, 16) = address;
710  seq(15, 0) = length;
711  return seq;
712  }
713  bool hasSessionID() {
714  return (rt_count != 0);
715  }
716 };
717 
718 
719 
727 #define RXMEMBUF 65536 // 64KB = 2^16
728 #define TXMEMBUF 65536 // 64KB = 2^16
729 
730 //=========================================================
731 //== MUX / A 2-to-1 Stream multiplexer.
732 //=========================================================
733 template<typename T> void pStreamMux(
734  stream<T> &si1,
735  stream<T> &si2,
736  stream<T> &so);
737 
738 
743 #if HLS_VERSION == 2017
744 
745  void toe_top(
746  //------------------------------------------------------
747  //-- MMIO Interfaces
748  //------------------------------------------------------
749  Ip4Addr piMMIO_IpAddr,
750  stream<StsBit> &soMMIO_RxMemWrErr,
751  stream<ap_uint<8> > &soMMIO_NotifDropCnt,
752  stream<ap_uint<8> > &soMMIO_MetaDropCnt,
753  stream<ap_uint<8> > &soMMIO_DataDropCnt,
754  stream<ap_uint<8> > &soMMIO_CrcDropCnt,
755  stream<ap_uint<8> > &soMMIO_SessDropCnt,
756  stream<ap_uint<8> > &soMMIO_OooDropCnt,
757 
758  //------------------------------------------------------
759  //-- NTS Interfaces
760  //------------------------------------------------------
761  StsBit &poNTS_Ready,
762 
763  //------------------------------------------------------
764  //-- IPRX / IP Rx / Data Interface
765  //------------------------------------------------------
766  stream<AxisIp4> &siIPRX_Data,
767 
768  //------------------------------------------------------
769  //-- IPTX / IP Tx / Data Interface
770  //------------------------------------------------------
771  stream<AxisIp4> &soIPTX_Data,
772 
773  //------------------------------------------------------
774  //-- TAIF / Receive Data Interfaces
775  //------------------------------------------------------
776  stream<TcpAppNotif> &soTAIF_Notif,
777  stream<TcpAppRdReq> &siTAIF_DReq,
778  stream<TcpAppData> &soTAIF_Data,
779  stream<TcpAppMeta> &soTAIF_Meta,
780 
781  //------------------------------------------------------
782  //-- TAIF / Listen Interfaces
783  //------------------------------------------------------
784  stream<TcpAppLsnReq> &siTAIF_LsnReq,
785  stream<TcpAppLsnRep> &soTAIF_LsnRep,
786 
787  //------------------------------------------------------
788  //-- TAIF / Send Data Interfaces
789  //------------------------------------------------------
790  stream<TcpAppData> &siTAIF_Data,
791  stream<TcpAppSndReq> &siTAIF_SndReq,
792  stream<TcpAppSndRep> &soTAIF_SndRep,
793 
794  //------------------------------------------------------
795  //-- TAIF / Open Connection Interfaces
796  //------------------------------------------------------
797  stream<TcpAppOpnReq> &siTAIF_OpnReq,
798  stream<TcpAppOpnRep> &soTAIF_OpnRep,
799 
800  //------------------------------------------------------
801  //-- TAIF / Close Interfaces
802  //------------------------------------------------------
803  stream<TcpAppClsReq> &siTAIF_ClsReq,
804  //-- Not Used &soTAIF_ClsSts,
805 
806  //------------------------------------------------------
807  //-- MEM / Rx PATH / S2MM Interface
808  //------------------------------------------------------
809  //-- Not Used &siMEM_RxP_RdSts,
810  stream<DmCmd> &soMEM_RxP_RdCmd,
811  stream<AxisApp> &siMEM_RxP_Data,
812  stream<DmSts> &siMEM_RxP_WrSts,
813  stream<DmCmd> &soMEM_RxP_WrCmd,
814  stream<AxisApp> &soMEM_RxP_Data,
815 
816  //------------------------------------------------------
817  //-- MEM / Tx PATH / S2MM Interface
818  //------------------------------------------------------
819  //-- Not Used &siMEM_TxP_RdSts,
820  stream<DmCmd> &soMEM_TxP_RdCmd,
821  stream<AxisApp> &siMEM_TxP_Data,
822  stream<DmSts> &siMEM_TxP_WrSts,
823  stream<DmCmd> &soMEM_TxP_WrCmd,
824  stream<AxisApp> &soMEM_TxP_Data,
825 
826  //------------------------------------------------------
827  //-- CAM / Session Lookup & Update Interfaces
828  //------------------------------------------------------
829  stream<CamSessionLookupRequest> &soCAM_SssLkpReq,
830  stream<CamSessionLookupReply> &siCAM_SssLkpRep,
831  stream<CamSessionUpdateRequest> &soCAM_SssUpdReq,
832  stream<CamSessionUpdateReply> &siCAM_SssUpdRep,
833 
834  //------------------------------------------------------
835  //-- DEBUG / Interfaces
836  //------------------------------------------------------
837  stream<ap_uint<16> > &soDBG_SssRelCnt,
838  stream<ap_uint<16> > &soDBG_SssRegCnt,
839  stream<RxBufPtr> &soDBG_RxFreeSpace,
840  stream<ap_uint<32> > &soDBG_TcpIpRxByteCnt,
841  stream<ap_uint< 8> > &soDBG_OooDebug
842  #if TOE_FEATURE_USED_FOR_DEBUGGING
843  //-- DEBUG / SimCycCounter
844  ap_uint<32> &poSimCycCount
845  #endif
846  );
847 
848 #else
849 
850  void toe_top(
851  //------------------------------------------------------
852  //-- MMIO Interfaces
853  //------------------------------------------------------
854  Ip4Addr piMMIO_IpAddr,
855  stream<StsBit> &soMMIO_RxMemWrErr,
856  stream<ap_uint<8> > &soMMIO_NotifDropCnt,
857  stream<ap_uint<8> > &soMMIO_MetaDropCnt,
858  stream<ap_uint<8> > &soMMIO_DataDropCnt,
859  stream<ap_uint<8> > &soMMIO_CrcDropCnt,
860  stream<ap_uint<8> > &soMMIO_SessDropCnt,
861  stream<ap_uint<8> > &soMMIO_OooDropCnt,
862 
863  //------------------------------------------------------
864  //-- NTS Interfaces
865  //------------------------------------------------------
866  StsBit &poNTS_Ready,
867 
868  //------------------------------------------------------
869  //-- IPRX / IP Rx / Data Interface
870  //------------------------------------------------------
871  stream<AxisRaw> &siIPRX_Data,
872 
873  //------------------------------------------------------
874  //-- IPTX / IP Tx / Data Interface
875  //------------------------------------------------------
876  stream<AxisRaw> &soIPTX_Data,
877 
878  //------------------------------------------------------
879  //-- TAIF / Receive Data Interfaces
880  //------------------------------------------------------
881  stream<TcpAppNotif> &soTAIF_Notif,
882  stream<TcpAppRdReq> &siTAIF_DReq,
883  stream<TcpAppData> &soTAIF_Data,
884  stream<TcpAppMeta> &soTAIF_Meta,
885 
886  //------------------------------------------------------
887  //-- TAIF / Listen Interfaces
888  //------------------------------------------------------
889  stream<TcpAppLsnReq> &siTAIF_LsnReq,
890  stream<TcpAppLsnRep> &soTAIF_LsnRep,
891 
892  //------------------------------------------------------
893  //-- TAIF / Send Data Interfaces
894  //------------------------------------------------------
895  stream<TcpAppData> &siTAIF_Data,
896  stream<TcpAppSndReq> &siTAIF_SndReq,
897  stream<TcpAppSndRep> &soTAIF_SndRep,
898 
899  //------------------------------------------------------
900  //-- TAIF / Open Connection Interfaces
901  //------------------------------------------------------
902  stream<TcpAppOpnReq> &siTAIF_OpnReq,
903  stream<TcpAppOpnRep> &soTAIF_OpnRep,
904 
905  //------------------------------------------------------
906  //-- TAIF / Close Interfaces
907  //------------------------------------------------------
908  stream<TcpAppClsReq> &siTAIF_ClsReq,
909  //-- Not Used &soTAIF_ClsSts,
910 
911  //------------------------------------------------------
912  //-- MEM / Rx PATH / S2MM Interface
913  //------------------------------------------------------
914  //-- Not Used &siMEM_RxP_RdSts,
915  stream<DmCmd> &soMEM_RxP_RdCmd,
916  stream<AxisApp> &siMEM_RxP_Data,
917  stream<DmSts> &siMEM_RxP_WrSts,
918  stream<DmCmd> &soMEM_RxP_WrCmd,
919  stream<AxisApp> &soMEM_RxP_Data,
920 
921  //------------------------------------------------------
922  //-- MEM / Tx PATH / S2MM Interface
923  //------------------------------------------------------
924  //-- Not Used &siMEM_TxP_RdSts,
925  stream<DmCmd> &soMEM_TxP_RdCmd,
926  stream<AxisApp> &siMEM_TxP_Data,
927  stream<DmSts> &siMEM_TxP_WrSts,
928  stream<DmCmd> &soMEM_TxP_WrCmd,
929  stream<AxisApp> &soMEM_TxP_Data,
930 
931  //------------------------------------------------------
932  //-- CAM / Session Lookup & Update Interfaces
933  //------------------------------------------------------
934  stream<CamSessionLookupRequest> &soCAM_SssLkpReq,
935  stream<CamSessionLookupReply> &siCAM_SssLkpRep,
936  stream<CamSessionUpdateRequest> &soCAM_SssUpdReq,
937  stream<CamSessionUpdateReply> &siCAM_SssUpdRep,
938 
939  //------------------------------------------------------
940  //-- DEBUG / Interfaces
941  //------------------------------------------------------
942  stream<ap_uint<16> > &soDBG_SssRelCnt,
943  stream<ap_uint<16> > &soDBG_SssRegCnt,
944  stream<RxBufPtr> &soDBG_RxFreeSpace,
945  stream<ap_uint<32> > &soDBG_TcpIpRxByteCnt,
946  stream<ap_uint< 8> > &soDBG_OooDebug
947  #if TOE_FEATURE_USED_FOR_DEBUGGING
948  //-- DEBUG / SimCycCounter
949  ,
950  ap_uint<32> &poSimCycCount
951  #endif
952  );
953 
954 #endif // HLS_VERSION
955 
956 #endif
957 
Event
Definition: toe.hpp:661
Event::address
TcpBufAdr address
Definition: toe.hpp:665
Event::Event
Event(EventType type, SessionId id, ap_uint< 3 > rt_count)
Definition: toe.hpp:671
Event::Event
Event(EventType type, SessionId id)
Definition: toe.hpp:669
Event::Event
Event()
Definition: toe.hpp:668
Event::rt_count
ap_uint< 3 > rt_count
Definition: toe.hpp:667
Event::sessionID
SessionId sessionID
Definition: toe.hpp:664
Event::type
EventType type
Definition: toe.hpp:663
Event::length
TcpSegLen length
Definition: toe.hpp:666
Event::Event
Event(EventType type, SessionId id, ap_uint< 16 > addr, ap_uint< 16 > len)
Definition: toe.hpp:673
Event::Event
Event(EventType type, SessionId id, ap_uint< 16 > addr, ap_uint< 16 > len, ap_uint< 3 > rt_count)
Definition: toe.hpp:675
ExtendedEvent::ExtendedEvent
ExtendedEvent()
Definition: toe.hpp:686
ExtendedEvent::ExtendedEvent
ExtendedEvent(const Event &ev, LE_SocketPair tuple)
Definition: toe.hpp:689
ExtendedEvent::ExtendedEvent
ExtendedEvent(const Event &ev)
Definition: toe.hpp:687
ExtendedEvent::tuple
LE_SocketPair tuple
Definition: toe.hpp:685
LE_SocketPair
Definition: nts_types.hpp:260
RAiRxSarQuery::RAiRxSarQuery
RAiRxSarQuery(SessionId id, RxBufPtr appd)
Definition: toe.hpp:422
RAiRxSarQuery::sessionID
SessionId sessionID
Definition: toe.hpp:416
RAiRxSarQuery::RAiRxSarQuery
RAiRxSarQuery()
Definition: toe.hpp:419
RAiRxSarQuery::appd
RxBufPtr appd
Definition: toe.hpp:417
RAiRxSarQuery::RAiRxSarQuery
RAiRxSarQuery(SessionId id)
Definition: toe.hpp:420
RAiRxSarQuery::write
RdWrBit write
Definition: toe.hpp:418
RAiRxSarReply::sessionID
SessionId sessionID
Definition: toe.hpp:431
RAiRxSarReply::RAiRxSarReply
RAiRxSarReply()
Definition: toe.hpp:433
RAiRxSarReply::appd
RxBufPtr appd
Definition: toe.hpp:432
RAiRxSarReply::RAiRxSarReply
RAiRxSarReply(SessionId id, RxBufPtr appd)
Definition: toe.hpp:434
RXeReTransTimerCmd::RXeReTransTimerCmd
RXeReTransTimerCmd(SessionId id, TimerCmd cmd)
Definition: toe.hpp:635
RXeReTransTimerCmd::command
TimerCmd command
Definition: toe.hpp:631
RXeReTransTimerCmd::RXeReTransTimerCmd
RXeReTransTimerCmd(SessionId id)
Definition: toe.hpp:633
RXeReTransTimerCmd::sessionID
SessionId sessionID
Definition: toe.hpp:630
RXeRxSarQuery::init
CmdBit init
Definition: toe.hpp:391
RXeRxSarQuery::RXeRxSarQuery
RXeRxSarQuery(SessionId id, RxSeqNum rcvd, RdWrBit wrBit)
Definition: toe.hpp:400
RXeRxSarQuery::write
RdWrBit write
Definition: toe.hpp:390
RXeRxSarQuery::rcvd
RxSeqNum rcvd
Definition: toe.hpp:386
RXeRxSarQuery::oooTail
RxSeqNum oooTail
Definition: toe.hpp:388
RXeRxSarQuery::ooo
FlagBool ooo
Definition: toe.hpp:389
RXeRxSarQuery::RXeRxSarQuery
RXeRxSarQuery(SessionId id, RxSeqNum rcvd, FlagBool ooo, RxSeqNum oooHead, RxSeqNum oooTail, RdWrBit wrBit)
Definition: toe.hpp:406
RXeRxSarQuery::RXeRxSarQuery
RXeRxSarQuery(SessionId id)
Definition: toe.hpp:395
RXeRxSarQuery::sessionID
SessionId sessionID
Definition: toe.hpp:385
RXeRxSarQuery::RXeRxSarQuery
RXeRxSarQuery(SessionId id, RdWrBit wrBit)
Definition: toe.hpp:397
RXeRxSarQuery::RXeRxSarQuery
RXeRxSarQuery(SessionId id, RxSeqNum rcvd, RdWrBit wrBit, CmdBit iniBit)
Definition: toe.hpp:403
RXeRxSarQuery::oooHead
RxSeqNum oooHead
Definition: toe.hpp:387
RXeRxSarQuery::RXeRxSarQuery
RXeRxSarQuery()
Definition: toe.hpp:392
RXeTxSarQuery::recv_window
RemotWinSize recv_window
Definition: toe.hpp:449
RXeTxSarQuery::RXeTxSarQuery
RXeTxSarQuery(SessionId id, TxAckNum ackd, RemotWinSize recv_win, LocalWinSize cong_win, ap_uint< 2 > count, CmdBool fastRetransmitted)
Definition: toe.hpp:461
RXeTxSarQuery::RXeTxSarQuery
RXeTxSarQuery()
Definition: toe.hpp:455
RXeTxSarQuery::fastRetransmitted
CmdBool fastRetransmitted
Definition: toe.hpp:452
RXeTxSarQuery::ackd
TxAckNum ackd
Definition: toe.hpp:448
RXeTxSarQuery::RXeTxSarQuery
RXeTxSarQuery(SessionId id, RdWrBit wrBit)
Definition: toe.hpp:458
RXeTxSarQuery::write
RdWrBit write
Definition: toe.hpp:453
RXeTxSarQuery::count
ap_uint< 2 > count
Definition: toe.hpp:451
RXeTxSarQuery::cong_window
LocalWinSize cong_window
Definition: toe.hpp:450
RXeTxSarQuery::sessionID
SessionId sessionID
Definition: toe.hpp:447
RXeTxSarReply::prevUnak
TxAckNum prevUnak
Definition: toe.hpp:471
RXeTxSarReply::count
ap_uint< 2 > count
Definition: toe.hpp:474
RXeTxSarReply::RXeTxSarReply
RXeTxSarReply(TxAckNum ackd, TxAckNum unak, TcpWindow cong_win, TcpWindow sstresh, ap_uint< 2 > count, CmdBool fastRetransmitted)
Definition: toe.hpp:477
RXeTxSarReply::fastRetransmitted
CmdBool fastRetransmitted
Definition: toe.hpp:475
RXeTxSarReply::RXeTxSarReply
RXeTxSarReply()
Definition: toe.hpp:476
RXeTxSarReply::slowstart_threshold
TcpWindow slowstart_threshold
Definition: toe.hpp:473
RXeTxSarReply::cong_window
TcpWindow cong_window
Definition: toe.hpp:472
RXeTxSarReply::prevAckd
TxAckNum prevAckd
Definition: toe.hpp:470
RxSarReply::ooo
FlagBool ooo
Definition: toe.hpp:374
RxSarReply::oooTail
RxSeqNum oooTail
Definition: toe.hpp:373
RxSarReply::RxSarReply
RxSarReply()
Definition: toe.hpp:375
RxSarReply::RxSarReply
RxSarReply(RxBufPtr appd, RxSeqNum rcvd, StsBool ooo, RxSeqNum oooHead, RxSeqNum oooTail)
Definition: toe.hpp:376
RxSarReply::appd
RxBufPtr appd
Definition: toe.hpp:370
RxSarReply::oooHead
RxSeqNum oooHead
Definition: toe.hpp:372
RxSarReply::rcvd
RxSeqNum rcvd
Definition: toe.hpp:371
SessionLookupQuery::allowCreation
bool allowCreation
Definition: toe.hpp:323
SessionLookupQuery::SessionLookupQuery
SessionLookupQuery(LE_SocketPair tuple, bool allowCreation)
Definition: toe.hpp:325
SessionLookupQuery::tuple
LE_SocketPair tuple
Definition: toe.hpp:322
SessionLookupReply::SessionLookupReply
SessionLookupReply(SessionId id, HitState hit)
Definition: toe.hpp:337
SessionLookupReply::sessionID
SessionId sessionID
Definition: toe.hpp:334
SessionLookupReply::hit
HitState hit
Definition: toe.hpp:335
StateQuery::StateQuery
StateQuery(SessionId id, RdWrBit wrBit)
Definition: toe.hpp:358
StateQuery::write
RdWrBit write
Definition: toe.hpp:352
StateQuery::StateQuery
StateQuery(SessionId id)
Definition: toe.hpp:356
StateQuery::state
TcpState state
Definition: toe.hpp:351
StateQuery::StateQuery
StateQuery()
Definition: toe.hpp:353
StateQuery::sessionID
SessionId sessionID
Definition: toe.hpp:350
StateQuery::StateQuery
StateQuery(SessionId id, TcpState state, RdWrBit write)
Definition: toe.hpp:361
TAiTxSarPush::sessionID
SessionId sessionID
Definition: toe.hpp:547
TAiTxSarPush::TAiTxSarPush
TAiTxSarPush(SessionId id, TxBufPtr app)
Definition: toe.hpp:550
TAiTxSarPush::app
TxBufPtr app
Definition: toe.hpp:548
TAiTxSarPush::TAiTxSarPush
TAiTxSarPush()
Definition: toe.hpp:549
TStTxSarPush::TStTxSarPush
TStTxSarPush()
Definition: toe.hpp:565
TStTxSarPush::sessionID
SessionId sessionID
Definition: toe.hpp:559
TStTxSarPush::init
CmdBit init
Definition: toe.hpp:564
TStTxSarPush::TStTxSarPush
TStTxSarPush(SessionId id, ap_uint< 16 > ackd)
Definition: toe.hpp:567
TStTxSarPush::ackd
ap_uint< 16 > ackd
Definition: toe.hpp:560
TStTxSarPush::TStTxSarPush
TStTxSarPush(SessionId id, ap_uint< 16 > ackd, CmdBit init)
Definition: toe.hpp:569
TXeReTransTimerCmd::type
EventType type
Definition: toe.hpp:645
TXeReTransTimerCmd::TXeReTransTimerCmd
TXeReTransTimerCmd(SessionId id, EventType type)
Definition: toe.hpp:649
TXeReTransTimerCmd::sessionID
SessionId sessionID
Definition: toe.hpp:644
TXeReTransTimerCmd::TXeReTransTimerCmd
TXeReTransTimerCmd(SessionId id)
Definition: toe.hpp:647
TXeTxSarQuery::finReady
bool finReady
Definition: toe.hpp:490
TXeTxSarQuery::isRtQuery
bool isRtQuery
Definition: toe.hpp:492
TXeTxSarQuery::TXeTxSarQuery
TXeTxSarQuery(SessionId id, RdWrBit wrBit)
Definition: toe.hpp:497
TXeTxSarQuery::TXeTxSarQuery
TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write, CmdBit init, bool finReady, bool finSent)
Definition: toe.hpp:504
TXeTxSarQuery::TXeTxSarQuery
TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write, CmdBit init, bool finReady, bool finSent, bool isRt)
Definition: toe.hpp:506
TXeTxSarQuery::TXeTxSarQuery
TXeTxSarQuery()
Definition: toe.hpp:494
TXeTxSarQuery::TXeTxSarQuery
TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write, CmdBit init)
Definition: toe.hpp:502
TXeTxSarQuery::TXeTxSarQuery
TXeTxSarQuery(SessionId id, TxAckNum not_ackd, RdWrBit write)
Definition: toe.hpp:500
TXeTxSarQuery::finSent
bool finSent
Definition: toe.hpp:491
TXeTxSarQuery::sessionID
SessionId sessionID
Definition: toe.hpp:486
TXeTxSarQuery::not_ackd
TxAckNum not_ackd
Definition: toe.hpp:487
TXeTxSarQuery::write
RdWrBit write
Definition: toe.hpp:488
TXeTxSarQuery::init
CmdBit init
Definition: toe.hpp:489
TXeTxSarReply::min_window
TcpWindow min_window
Definition: toe.hpp:517
TXeTxSarReply::finReady
bool finReady
Definition: toe.hpp:519
TXeTxSarReply::TXeTxSarReply
TXeTxSarReply(ap_uint< 32 > ack, ap_uint< 32 > nack, ap_uint< 16 > min_window, ap_uint< 16 > app, bool finReady, bool finSent)
Definition: toe.hpp:522
TXeTxSarReply::not_ackd
TxAckNum not_ackd
Definition: toe.hpp:516
TXeTxSarReply::ackd
TxAckNum ackd
Definition: toe.hpp:515
TXeTxSarReply::TXeTxSarReply
TXeTxSarReply()
Definition: toe.hpp:521
TXeTxSarReply::finSent
bool finSent
Definition: toe.hpp:520
TXeTxSarReply::app
TxBufPtr app
Definition: toe.hpp:518
TXeTxSarRtQuery::TXeTxSarRtQuery
TXeTxSarRtQuery(const TXeTxSarQuery &q)
Definition: toe.hpp:533
TXeTxSarRtQuery::TXeTxSarRtQuery
TXeTxSarRtQuery(SessionId id, ap_uint< TOE_WINDOW_BITS > ssthresh)
Definition: toe.hpp:535
TXeTxSarRtQuery::TXeTxSarRtQuery
TXeTxSarRtQuery()
Definition: toe.hpp:532
TXeTxSarRtQuery::getThreshold
ap_uint< TOE_WINDOW_BITS > getThreshold()
Definition: toe.hpp:537
TxAppTableQuery::TxAppTableQuery
TxAppTableQuery(SessionId id, ap_uint< 16 > pt)
Definition: toe.hpp:594
TxAppTableQuery::write
bool write
Definition: toe.hpp:590
TxAppTableQuery::sessId
SessionId sessId
Definition: toe.hpp:588
TxAppTableQuery::TxAppTableQuery
TxAppTableQuery(SessionId id)
Definition: toe.hpp:592
TxAppTableQuery::mempt
TxBufPtr mempt
Definition: toe.hpp:589
TxAppTableQuery::TxAppTableQuery
TxAppTableQuery()
Definition: toe.hpp:591
TxAppTableReply::ackd
ap_uint< 16 > ackd
Definition: toe.hpp:604
TxAppTableReply::sessId
SessionId sessId
Definition: toe.hpp:603
TxAppTableReply::TxAppTableReply
TxAppTableReply()
Definition: toe.hpp:609
TxAppTableReply::TxAppTableReply
TxAppTableReply(SessionId id, ap_uint< 16 > ackd, TxBufPtr pt)
Definition: toe.hpp:611
TxAppTableReply::mempt
TxBufPtr mempt
Definition: toe.hpp:605
StsBool
bool StsBool
Definition: nal.hpp:246
SessState
TcpAppOpnRep SessState
Definition: toe.hpp:279
cDepth_STtToRXe_Rep
const int cDepth_STtToRXe_Rep
Definition: toe.hpp:217
pStreamMux
void pStreamMux(stream< T > &si1, stream< T > &si2, stream< T > &so)
A 2-to-1 generic Stream Multiplexer.
Definition: timers.cpp:90
idleCycCnt
uint32_t idleCycCnt
RemotWinSize
TcpWindow RemotWinSize
Definition: toe.hpp:292
TxMemPtr
ap_uint< 32 > TxMemPtr
Definition: toe.hpp:296
LE_tData
ap_uint< 64 > LE_tData
Definition: toe.hpp:253
tDataHalf
ap_uint< 32 > tDataHalf
Definition: toe.hpp:256
cDepth_AKdToTXe_Event
const int cDepth_AKdToTXe_Event
Definition: toe.hpp:207
EventType
EventType
Definition: toe.hpp:273
LocalWinSize
TcpWindow LocalWinSize
Definition: toe.hpp:293
cDepth_RXeToTSt_Qry
const int cDepth_RXeToTSt_Qry
Definition: toe.hpp:215
cDepth_RAiToRSt_Qry
const int cDepth_RAiToRSt_Qry
Definition: toe.hpp:211
cDepth_TImToEVe_Event
const int cDepth_TImToEVe_Event
Definition: toe.hpp:227
cDepth_TXeToEVe_Event
const int cDepth_TXeToEVe_Event
Definition: toe.hpp:229
RxSeqNum
TcpSeqNum RxSeqNum
Definition: toe.hpp:290
TimerCmd
TimerCmd
Definition: toe.hpp:622
cDepth_TStToTXe_Rep
const int cDepth_TStToTXe_Rep
Definition: toe.hpp:225
cDepth_TAiToTSt_Cmd
const int cDepth_TAiToTSt_Cmd
Definition: toe.hpp:221
TcpBufAdr
ap_uint< TOE_WINDOW_BITS > TcpBufAdr
Definition: toe.hpp:297
cDepth_TXeToRSt_Req
const int cDepth_TXeToRSt_Req
Definition: toe.hpp:230
tKeep
ap_uint< 8 > tKeep
Definition: toe.hpp:257
cDepth_RXeToEVe_Event
const int cDepth_RXeToEVe_Event
Definition: toe.hpp:213
cDepth_RXeToRSt_Qry
const int cDepth_RXeToRSt_Qry
Definition: toe.hpp:214
LsnAck
ap_uint< 1 > LsnAck
Definition: toe.hpp:198
gSimCycCnt
unsigned int gSimCycCnt
Definition: tb_nal.cpp:150
cDepth_TStToRXe_Rep
const int cDepth_TStToRXe_Rep
Definition: toe.hpp:223
TcpStaPort
ap_uint< 15 > TcpStaPort
Definition: toe.hpp:284
cDepth_AKdToEVe_Event
const int cDepth_AKdToEVe_Event
Definition: toe.hpp:206
ClsReq
ap_uint< 16 > ClsReq
Definition: toe.hpp:201
cDepth_EVeToAKd_Event
const int cDepth_EVeToAKd_Event
Definition: toe.hpp:209
TxBufPtr
TcpBufAdr TxBufPtr
Definition: toe.hpp:299
tLast
ap_uint< 1 > tLast
Definition: toe.hpp:258
LE_tKeep
ap_uint< 8 > LE_tKeep
Definition: toe.hpp:254
HitStates
HitStates
Definition: toe.hpp:315
TOE_FEATURE_USED_FOR_DEBUGGING
#define TOE_FEATURE_USED_FOR_DEBUGGING
Definition: toe.hpp:103
RxBufPtr
TcpBufAdr RxBufPtr
Definition: toe.hpp:298
toe_top
void toe_top(Ip4Addr piMMIO_IpAddr, stream< StsBit > &soMMIO_RxMemWrErr, stream< ap_uint< 8 > > &soMMIO_NotifDropCnt, stream< ap_uint< 8 > > &soMMIO_MetaDropCnt, stream< ap_uint< 8 > > &soMMIO_DataDropCnt, stream< ap_uint< 8 > > &soMMIO_CrcDropCnt, stream< ap_uint< 8 > > &soMMIO_SessDropCnt, stream< ap_uint< 8 > > &soMMIO_OooDropCnt, StsBit &poNTS_Ready, stream< AxisRaw > &siIPRX_Data, stream< AxisRaw > &soIPTX_Data, stream< TcpAppNotif > &soTAIF_Notif, stream< TcpAppRdReq > &siTAIF_DReq, stream< TcpAppData > &soTAIF_Data, stream< TcpAppMeta > &soTAIF_Meta, stream< TcpAppLsnReq > &siTAIF_LsnReq, stream< TcpAppLsnRep > &soTAIF_LsnRep, stream< TcpAppData > &siTAIF_Data, stream< TcpAppSndReq > &siTAIF_SndReq, stream< TcpAppSndRep > &soTAIF_SndRep, stream< TcpAppOpnReq > &siTAIF_OpnReq, stream< TcpAppOpnRep > &soTAIF_OpnRep, stream< TcpAppClsReq > &siTAIF_ClsReq, stream< DmCmd > &soMEM_RxP_RdCmd, stream< AxisApp > &siMEM_RxP_Data, stream< DmSts > &siMEM_RxP_WrSts, stream< DmCmd > &soMEM_RxP_WrCmd, stream< AxisApp > &soMEM_RxP_Data, stream< DmCmd > &soMEM_TxP_RdCmd, stream< AxisApp > &siMEM_TxP_Data, stream< DmSts > &siMEM_TxP_WrSts, stream< DmCmd > &soMEM_TxP_WrCmd, stream< AxisApp > &soMEM_TxP_Data, stream< CamSessionLookupRequest > &soCAM_SssLkpReq, stream< CamSessionLookupReply > &siCAM_SssLkpRep, stream< CamSessionUpdateRequest > &soCAM_SssUpdReq, stream< CamSessionUpdateReply > &siCAM_SssUpdRep, stream< ap_uint< 16 > > &soDBG_SssRelCnt, stream< ap_uint< 16 > > &soDBG_SssRegCnt, stream< RxBufPtr > &soDBG_RxFreeSpace, stream< ap_uint< 32 > > &soDBG_TcpIpRxByteCnt, stream< ap_uint< 8 > > &soDBG_OooDebug)
Top of TCP Offload Engine (TOE)
Definition: toe.cpp:1056
HitState
bool HitState
Definition: toe.hpp:314
LsnReq
ap_uint< 16 > LsnReq
Definition: toe.hpp:199
tData
ap_uint< 64 > tData
Definition: toe.hpp:255
SessionId
ap_uint< 16 > SessionId
Definition: toe.hpp:197
cDepth_STtToTAi_Rep
const int cDepth_STtToTAi_Rep
Definition: toe.hpp:218
OpnReq
ap_uint<(32+16) > OpnReq
Definition: toe.hpp:200
notificationType
notificationType
Definition: toe.hpp:242
RxMemPtr
ap_uint< 32 > RxMemPtr
Definition: toe.hpp:295
packetCounter
uint32_t packetCounter
TxAckNum
TcpAckNum TxAckNum
Definition: toe.hpp:291
cDepth_TAiToEVe_Event
const int cDepth_TAiToEVe_Event
Definition: toe.hpp:220
cDepth_TStToTAi_Cmd
const int cDepth_TStToTAi_Cmd
Definition: toe.hpp:224
TcpDynPort
ap_uint< 15 > TcpDynPort
Definition: toe.hpp:285
cDepth_TXeToTSt_Qry
const int cDepth_TXeToTSt_Qry
Definition: toe.hpp:231
RST_EVENT
@ RST_EVENT
Definition: toe.hpp:274
SYN_EVENT
@ SYN_EVENT
Definition: toe.hpp:273
ACK_EVENT
@ ACK_EVENT
Definition: toe.hpp:273
FIN_EVENT
@ FIN_EVENT
Definition: toe.hpp:274
TX_EVENT
@ TX_EVENT
Definition: toe.hpp:273
RT_EVENT
@ RT_EVENT
Definition: toe.hpp:273
ACK_NODELAY_EVENT
@ ACK_NODELAY_EVENT
Definition: toe.hpp:274
LOAD_TIMER
@ LOAD_TIMER
Definition: toe.hpp:622
STOP_TIMER
@ STOP_TIMER
Definition: toe.hpp:623
CHUNK_2
@ CHUNK_2
Definition: toe.hpp:244
CHUNK_1
@ CHUNK_1
Definition: toe.hpp:244
CHUNK_4
@ CHUNK_4
Definition: toe.hpp:244
CHUNK_5
@ CHUNK_5
Definition: toe.hpp:244
CHUNK_3
@ CHUNK_3
Definition: toe.hpp:244
CHUNK_0
@ CHUNK_0
Definition: toe.hpp:244
SESSION_EXISTS
@ SESSION_EXISTS
Definition: toe.hpp:315
SESSION_UNKNOWN
@ SESSION_UNKNOWN
Definition: toe.hpp:315
WORD_3
@ WORD_3
Definition: toe.hpp:243
WORD_1
@ WORD_1
Definition: toe.hpp:243
WORD_5
@ WORD_5
Definition: toe.hpp:243
WORD_2
@ WORD_2
Definition: toe.hpp:243
WORD_4
@ WORD_4
Definition: toe.hpp:243
WORD_0
@ WORD_0
Definition: toe.hpp:243
TIME_OUT
@ TIME_OUT
Definition: toe.hpp:242
RESET
@ RESET
Definition: toe.hpp:242
CLOSE
@ CLOSE
Definition: toe.hpp:242
PKG
@ PKG
Definition: toe.hpp:242
TcpSegLen
ap_uint< 16 > TcpSegLen
Definition: AxisTcp.hpp:121
TcpSeqNum
ap_uint< 32 > TcpSeqNum
Definition: AxisTcp.hpp:106
SessionId
ap_uint< 16 > SessionId
Definition: nts_types.hpp:136
CMD_INIT
#define CMD_INIT
Definition: nts_types.hpp:60
TcpState
TcpState
Definition: nts_types.hpp:296
StsBit
ap_uint< 1 > StsBit
Definition: nts_types.hpp:116
QUERY_RD
#define QUERY_RD
Definition: nts_types.hpp:65
Ip4Addr
ap_uint< 32 > Ip4Addr
Definition: AxisIp4.hpp:169
RdWrBit
ap_uint< 1 > RdWrBit
Definition: nts_types.hpp:111
TCP_HEADER_LEN
#define TCP_HEADER_LEN
Definition: AxisTcp.hpp:81
FlagBool
bool FlagBool
Definition: nts_types.hpp:124
QUERY_WR
#define QUERY_WR
Definition: nts_types.hpp:66
IP4_HEADER_LEN
#define IP4_HEADER_LEN
Definition: AxisIp4.hpp:133
CmdBit
ap_uint< 1 > CmdBit
Definition: nts_types.hpp:108
TcpWindow
ap_uint< 16 > TcpWindow
Definition: AxisTcp.hpp:112
TcpAckNum
ap_uint< 32 > TcpAckNum
Definition: AxisTcp.hpp:107
FLAG_INO
#define FLAG_INO
Definition: nts_types.hpp:74
CmdBool
bool CmdBool
Definition: nts_types.hpp:123
CLOSED
@ CLOSED
Definition: nts_types.hpp:296
tc_utils.ZYC2_MSS
tuple ZYC2_MSS
Definition: tc_utils.py:42
test_harris_standalone.stream
stream
Definition: test_harris_standalone.py:48
ipTuple
Definition: udp.hpp:91
ipTuple::ip_address
ap_uint< 32 > ip_address
Definition: toe.hpp:306
ipTuple::ip_port
ap_uint< 16 > ip_port
Definition: toe.hpp:307
rstEvent::getAckNumb
TxAckNum getAckNumb()
Definition: toe.hpp:707
rstEvent::hasSessionID
bool hasSessionID()
Definition: toe.hpp:713
rstEvent::rstEvent
rstEvent(SessionId id, RxSeqNum seq, bool hasSessionID)
Definition: toe.hpp:705
rstEvent::rstEvent
rstEvent()
Definition: toe.hpp:698
rstEvent::rstEvent
rstEvent(RxSeqNum seq)
Definition: toe.hpp:701
rstEvent::rstEvent
rstEvent(const Event &ev)
Definition: toe.hpp:699
rstEvent::rstEvent
rstEvent(SessionId id, RxSeqNum seq)
Definition: toe.hpp:703
MTU
#define MTU
Definition: udp.hpp:71