inet::EthernetPauseCommandProcessor Class Reference

#include <EthernetPauseCommandProcessor.h>

Inheritance diagram for inet::EthernetPauseCommandProcessor:

Protected Member Functions
virtual void	initialize () override
virtual void	handleMessage (cMessage *msg) override
void	handleSendPause (Request *msg, Ieee802PauseCommand *etherctrl)

Protected Attributes
int	seqNum = 0

Static Protected Attributes
static simsignal_t	pauseSentSignal = registerSignal("pauseSent")

Member Function Documentation

handleMessage()

void inet::EthernetPauseCommandProcessor::handleMessage ( cMessage *  msg )

overrideprotectedvirtual

{
    if (auto rq = dynamic_cast<Request *>(msg)) {
        auto ctrl = msg->getControlInfo();
        if (auto cmd = dynamic_cast<Ieee802PauseCommand *>(ctrl)) {
            handleSendPause(rq, cmd);
            return;
        }
    }
    send(msg, "out");
}

handleSendPause()

void inet::EthernetPauseCommandProcessor::handleSendPause ( Request *  msg, Ieee802PauseCommand *  etherctrl  )

protected

{
    MacAddress dest = etherctrl->getDestinationAddress();
    int pauseUnits = etherctrl->getPauseUnits();
    delete msg;
 
    EV_DETAIL << "Creating and sending PAUSE frame, with duration = " << pauseUnits << " units\n";
 
    // create Ethernet frame
    char framename[40];
    sprintf(framename, "pause-%d-%d", getId(), seqNum++);
    auto packet = new Packet(framename);
    const auto& frame = makeShared<EthernetPauseFrame>();
    frame->setPauseTime(pauseUnits);
    packet->insertAtFront(frame);
    if (dest.isUnspecified())
        dest = MacAddress::MULTICAST_PAUSE_ADDRESS;
    packet->addTag<MacAddressReq>()->setDestAddress(dest);
    packet->addTag<PacketProtocolTag>()->setProtocol(&Protocol::ethernetFlowCtrl);
 
    EV_INFO << "Sending Pause command " << frame << " to lower layer.\n";
    send(packet, "out");
 
    emit(pauseSentSignal, pauseUnits);
}

Referenced by handleMessage().

initialize()

void inet::EthernetPauseCommandProcessor::initialize ( )

overrideprotectedvirtual

{
    seqNum = 0;
}

Member Data Documentation

pauseSentSignal

simsignal_t inet::EthernetPauseCommandProcessor::pauseSentSignal = registerSignal("pauseSent")

staticprotected

Referenced by handleSendPause().

seqNum

int inet::EthernetPauseCommandProcessor::seqNum = 0

protected

Referenced by handleSendPause(), and initialize().

---

The documentation for this class was generated from the following files:

• EthernetPauseCommandProcessor.h
• EthernetPauseCommandProcessor.cc