event_engine.cpp

Go to the documentation of this file.

 
 
 
#include "event_engine.hpp"
 
using namespace hls;
 
 
#ifndef __SYNTHESIS__
  extern bool gTraceEvent;
#endif
 
#define THIS_NAME "TOE/EVe"
 
#define TRACE_OFF  0x0000
#define TRACE_EVE 1 <<  1
#define TRACE_ALL  0xFFFF
 
#define DEBUG_LEVEL (TRACE_OFF)
 
 
 
void event_engine(
        stream<Event>           &siTAi_Event,
        stream<ExtendedEvent>   &siRXe_Event,
        stream<Event>           &siTIm_Event,
        stream<ExtendedEvent>   &soAKd_Event,
        stream<SigBit>          &siAKd_RxEventSig,
        stream<SigBit>          &siAKd_TxEventSig,
        stream<SigBit>          &siTXe_RxEventSig)
{
    //-- DIRECTIVES FOR THIS PROCESS -------------------------------------------
    #pragma HLS PIPELINE II=1 enable_flush
 
    const char *myName  = THIS_NAME;
 
    //-- STATIC CONTROL VARIABLES (with RESET) ---------------------------------
    //---- Warning: the following counters depend on the FiFo depth between EVe and AKd
    static ap_uint<8>            eve_eve2akd_WrCnt; // #events forwarded by [EVe] to   [AKd]
    #pragma HLS RESET variable = eve_eve2akd_WrCnt
    static ap_uint<8>            eve_eve2akd_RdCnt; // #events received  by [AKd] from [EVe].
    #pragma HLS RESET variable = eve_eve2akd_RdCnt
    static ap_uint<8>            eve_akd2txe_WrCnt; // #events forwarded by [AKd] to  [TXe]
    #pragma HLS RESET variable = eve_akd2txe_WrCnt
    static ap_uint<8>            eve_akd2txe_RdCnt; // #events received  by [TXe] from [Akd]
    #pragma HLS RESET variable = eve_akd2txe_RdCnt
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    ExtendedEvent ev;
 
    //------------------------------------------
    // Handle input from [RxEngine]
    //------------------------------------------
    if (!siRXe_Event.empty() and !soAKd_Event.full()) {
        siRXe_Event.read(ev);
        soAKd_Event.write(ev);
        if (DEBUG_LEVEL & TRACE_EVE) {
            printInfo(myName, "S%d - Received '%s' from [RXe] (WrCnt=%3d|RdCnt=%3d).\n",
                      ev.sessionID.to_int(), getEventName(ev.type), eve_eve2akd_WrCnt.to_uint(), eve_eve2akd_RdCnt.to_uint());
        }
        eve_eve2akd_WrCnt++;
    }
    else if (eve_eve2akd_WrCnt == eve_eve2akd_RdCnt and
             eve_akd2txe_WrCnt == eve_akd2txe_RdCnt) {
        //------------------------------------------
        // Handle input from [Timers]
        //   RetransmitTimer and ProbeTimer events have priority
        //------------------------------------------
        if (!siTIm_Event.empty()) {
            siTIm_Event.read(ev);
            soAKd_Event.write(ev);
            if (DEBUG_LEVEL & TRACE_EVE) {
                printInfo(myName, "S%d - Received '%s' from [TIm] (WrCnt=%3d|RdCnt=%3d).\n",
                        ev.sessionID.to_int(), getEventName(ev.type), eve_eve2akd_WrCnt.to_uint(), eve_eve2akd_RdCnt.to_uint());
            }
            eve_eve2akd_WrCnt++;
        }
        //--------------------------------------------
        // Handle input from [TcpApplicationInterface]
        //--------------------------------------------
        else if (!siTAi_Event.empty()) {
            siTAi_Event.read(ev);
            assessSize(myName, soAKd_Event, "soAKd_Event", cDepth_EVeToAKd_Event);
            soAKd_Event.write(ev);
            if (DEBUG_LEVEL & TRACE_EVE) {
                printInfo(myName, "S%d - Received '%s' from [TAi] (WrCnt=%3d|RdCnt=%3d).\n",
                        ev.sessionID.to_int(), getEventName(ev.type), eve_eve2akd_WrCnt.to_uint(), eve_eve2akd_RdCnt.to_uint());
            }
            eve_eve2akd_WrCnt++;
        }
    }
 
    //------------------------------------------
    // Handle inputs from [AckDelayer]
    //------------------------------------------
    if (!siAKd_RxEventSig.empty()) {
        // Remote [AKd] just received an event from [EVe]
        siAKd_RxEventSig.read();
        eve_eve2akd_RdCnt++;
    }
 
    if (!siAKd_TxEventSig.empty()) {
        // Remote [AKd] just forwarded an event to [TXe]
        siAKd_TxEventSig.read();
        eve_akd2txe_WrCnt++;
    }
 
    //------------------------------------------
    // Handle input from [TxEngine]
    //------------------------------------------
    if (!siTXe_RxEventSig.empty()) {
        siTXe_RxEventSig.read();
        eve_akd2txe_RdCnt++;
    }
}