Ethernet application. More...

#include <EthernetApplication.h>

Inheritance diagram for inet::EthernetApplication:

Protected Member Functions
virtual void	initialize (int stage) override

virtual int	numInitStages () const override

virtual void	handleMessage (cMessage *msg) override

virtual void	finish () override

virtual MACAddress	resolveDestMACAddress ()

virtual void	sendPacket ()

void	sendPacket (cMessage *datapacket, const MACAddress &destAddr)

virtual void	receivePacket (cMessage *msg)

Protected Attributes
long	seqNum = 0

cPar *	reqLength = nullptr

cPar *	respLength = nullptr

cPar *	waitTime = nullptr

MACAddress	destMACAddress

long	packetsSent = 0

long	packetsReceived = 0

Static Protected Attributes
static simsignal_t	sentPkSignal = SIMSIGNAL_NULL

static simsignal_t	rcvdPkSignal = SIMSIGNAL_NULL

Detailed Description

Ethernet application.

Both, server and client side.

Member Function Documentation

void inet::EthernetApplication::finish ( )

overrideprotectedvirtual

158 {

159 }

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

overrideprotectedvirtual

 {
     if (msg->isSelfMessage()) {
         sendPacket();
         simtime_t d = waitTime->doubleValue();
         scheduleAt(simTime() + d, msg);
     }
     else {
         receivePacket(msg);
     }
 }

void inet::EthernetApplication::initialize ( int stage )

overrideprotectedvirtual

 {
     // we can only initialize in the 2nd stage (stage==1), because
     // assignment of "auto" MAC addresses takes place in stage 0
     if (stage == INITSTAGE_APPLICATION_LAYER) {
         reqLength = &par("reqLength");
         respLength = &par("respLength");
         waitTime = &par("waitTime");
 
         seqNum = 0;
         WATCH(seqNum);
 
         // statistics
         packetsSent = packetsReceived = 0;
         sentPkSignal = registerSignal("sentPk");
         rcvdPkSignal = registerSignal("rcvdPk");
         WATCH(packetsSent);
         WATCH(packetsReceived);
 
         destMACAddress = resolveDestMACAddress();
 
         // if no dest address is given, nothing to do
         if (destMACAddress.isUnspecified())
             return;
 
         cMessage *timermsg = new cMessage("generateNextPacket");
         simtime_t d = par("startTime").doubleValue();
         scheduleAt(simTime() + d, timermsg);
     }
 }

virtual int inet::EthernetApplication::numInitStages ( ) const

inlineoverrideprotectedvirtual

47 { return NUM_INIT_STAGES; }

inet::NUM_INIT_STAGES

The number of initialization stages.

Definition: InitStages.h:116

void inet::EthernetApplication::receivePacket ( cMessage * msg )

protectedvirtual

Referenced by handleMessage().

 {
     EV << "Received packet `" << msg->getName() << "'\n";
 
     packetsReceived++;
     // simtime_t lastEED = simTime() - msg->getCreationTime();
 
     if (dynamic_cast<EtherAppReq *>(msg)) {
         EtherAppReq *req = check_and_cast<EtherAppReq *>(msg);
         emit(rcvdPkSignal, req);
         Ieee802Ctrl *ctrl = check_and_cast<Ieee802Ctrl *>(req->removeControlInfo());
         MACAddress srcAddr = ctrl->getSrc();
         long requestId = req->getRequestId();
         long replyBytes = req->getResponseBytes();
         delete ctrl;
 
         // send back packets asked by EthernetApplication Client side
         for (int k = 0; replyBytes > 0; k++) {
             int l = replyBytes > MAX_REPLY_CHUNK_SIZE ? MAX_REPLY_CHUNK_SIZE : replyBytes;
             replyBytes -= l;
 
             std::ostringstream s;
             s << msg->getName() << "-resp-" << k;
 
             EV << "Generating packet `" << s.str().c_str() << "'\n";
 
             EtherAppResp *datapacket = new EtherAppResp(s.str().c_str(), IEEE802CTRL_DATA);
             datapacket->setRequestId(requestId);
             datapacket->setByteLength(l);
             sendPacket(datapacket, srcAddr);
             packetsSent++;
         }
     }
 
     delete msg;
 }

MACAddress inet::EthernetApplication::resolveDestMACAddress ( )

protectedvirtual

Referenced by initialize().

 {
     MACAddress destMACAddress;
     const char *destAddress = par("destAddress");
     if (destAddress[0]) {
         // try as mac address first, then as a module
         if (!destMACAddress.tryParse(destAddress)) {
             cModule *destStation = getModuleByPath(destAddress);
             if (!destStation)
                 throw cRuntimeError("cannot resolve MAC address '%s': not a 12-hex-digit MAC address or a valid module path name", destAddress);
             cModule *destMAC = destStation->getSubmodule("mac");
             if (!destMAC)
                 throw cRuntimeError("module '%s' has no 'mac' submodule", destAddress);
             destMACAddress.setAddress(destMAC->par("address"));
         }
     }
     return destMACAddress;
 }

void inet::EthernetApplication::sendPacket ( )

protectedvirtual

Referenced by handleMessage(), and receivePacket().

 {
     seqNum++;
 
     char msgname[30];
     sprintf(msgname, "req-%d-%ld", getId(), seqNum);
     EV << "Generating packet `" << msgname << "'\n";
 
     EtherAppReq *datapacket = new EtherAppReq(msgname, IEEE802CTRL_DATA);
 
     datapacket->setRequestId(seqNum);
 
     long len = reqLength->longValue();
     datapacket->setByteLength(len);
 
     long respLen = respLength->longValue();
     datapacket->setResponseBytes(respLen);
 
     Ieee802Ctrl *etherctrl = new Ieee802Ctrl();
     etherctrl->setDest(destMACAddress);
     datapacket->setControlInfo(etherctrl);
 
     send(datapacket, "out");
     packetsSent++;
 }

void inet::EthernetApplication::sendPacket	(	cMessage *	datapacket,
		const MACAddress &	destAddr
	)

protected

 {
     Ieee802Ctrl *etherctrl = new Ieee802Ctrl();
     etherctrl->setDest(destAddr);
     datapacket->setControlInfo(etherctrl);
     emit(sentPkSignal, datapacket);
     send(datapacket, "out");
 }