tx_engine.hpp

Go to the documentation of this file.

 
 
 
#ifndef _TOE_TXE_H_
#define _TOE_TXE_H_
 
 
#include "../../../../../NTS/nts.hpp"
#include "../../../../../NTS/nts_utils.hpp"
#include "../../../../../NTS/toe/src/toe.hpp"
#include "../../../../../NTS/toe/src/toe_utils.hpp"
#include "../../../../../NTS/SimNtsUtils.hpp"
#include "../../../../../NTS/AxisIp4.hpp"
#include "../../../../../NTS/AxisPsd4.hpp"
 
using namespace hls;
 
 
class TXeMeta {
  public:
    TcpSeqNum   seqNumb;
    TcpAckNum   ackNumb;
    TcpWindow   winSize;
    TcpSegLen   length;
    ap_uint<1>  ack;
    ap_uint<1>  rst;
    ap_uint<1>  syn;
    ap_uint<1>  fin;
    TXeMeta() {}
    TXeMeta(ap_uint<1> ack, ap_uint<1> rst, ap_uint<1> syn, ap_uint<1> fin)
        : seqNumb(0), ackNumb(0), winSize(0), length(0), ack(ack), rst(rst), syn(syn), fin(fin) {}
    TXeMeta(TcpSeqNum seqNumb, TcpAckNum ackNumb, ap_uint<1> ack, ap_uint<1> rst, ap_uint<1> syn, ap_uint<1> fin)
        : seqNumb(seqNumb), ackNumb(ackNumb), winSize(0), length(0), ack(ack), rst(rst), syn(syn), fin(fin) {}
    TXeMeta(TcpSeqNum seqNumb, TcpAckNum ackNumb, TcpWindow winSize, ap_uint<1> ack, ap_uint<1> rst, ap_uint<1> syn, ap_uint<1> fin)
        : seqNumb(seqNumb), ackNumb(ackNumb), winSize(winSize), length(0), ack(ack), rst(rst), syn(syn), fin(fin) {}
};
 
 
 
struct SubCSums
{
    ap_uint<17>     sum0;
    ap_uint<17>     sum1;
    ap_uint<17>     sum2;
    ap_uint<17>     sum3;
    SubCSums() {}
    SubCSums(ap_uint<17> sums[4]) :
        sum0(sums[0]), sum1(sums[1]), sum2(sums[2]), sum3(sums[3]) {}
    SubCSums(ap_uint<17> s0, ap_uint<17> s1, ap_uint<17> s2, ap_uint<17> s3) :
        sum0(s0), sum1(s1), sum2(s2), sum3(s3) {}
};
 
 
 
class IpAddrPair {
  public:
    Ip4Addr  src;
    Ip4Addr  dst;
    IpAddrPair() {}
    IpAddrPair(Ip4Addr src, Ip4Addr dst) :
        src(src), dst(dst) {}
};
 
 
void tx_engine(
        //-- Ack Delayer & Event Engine Interfaces
        stream<ExtendedEvent>           &siAKd_Event,
        stream<SigBit>                  &soEVe_RxEventSig,
        //-- Rx SAR Table Interface
        stream<SessionId>               &soRSt_RxSarReq,
        stream<RxSarReply>              &siRSt_RxSarRep,
        //-- Tx SAR Table Interface
        stream<TXeTxSarQuery>           &soTSt_TxSarQry,
        stream<TXeTxSarReply>           &siTSt_TxSarRep,
        //-- MEM / Tx Read Path Interface
        stream<DmCmd>                   &soMEM_Txp_RdCmd,
        stream<AxisApp>                 &siMEM_TxP_Data,
        //-- Timers Interface
        stream<TXeReTransTimerCmd>      &soTIm_ReTxTimerEvent,
        stream<ap_uint<16> >            &soTIm_SetProbeTimer,
        //-- Session Lookup Controller Interface
        stream<SessionId>               &soSLc_ReverseLkpReq,
        stream<fourTuple>               &siSLc_ReverseLkpRep,
        //-- IP Tx Interface
        stream<AxisIp4>                 &soIPTX_Data
);
 
#endif