Models a wiring hub. More...

#include <EtherHub.h>

Inheritance diagram for inet::EtherHub:

Protected Member Functions
virtual void	initialize () override

virtual void	handleMessage (cMessage *msg) override

virtual void	finish () override

virtual void	receiveSignal (cComponent source, simsignal_t signalID, cObject obj, cObject *details) override

virtual void	checkConnections (bool errorWhenAsymmetric)

Protected Attributes
int	numPorts

int	inputGateBaseId

int	outputGateBaseId

bool	dataratesDiffer

long	numMessages

Static Protected Attributes
static simsignal_t	pkSignal = registerSignal("pk")

Detailed Description

Models a wiring hub.

It simply broadcasts the received message on all other ports.

Member Function Documentation

void inet::EtherHub::checkConnections ( bool errorWhenAsymmetric )

protectedvirtual

Referenced by handleMessage(), initialize(), and receiveSignal().

 {
     int numActivePorts = 0;
     double datarate = 0.0;
     dataratesDiffer = false;
 
     for (int i = 0; i < numPorts; i++) {
         cGate *igate = gate(inputGateBaseId + i);
         cGate *ogate = gate(outputGateBaseId + i);
         if (!igate->isConnected() && !ogate->isConnected())
             continue;
 
         if (!igate->isConnected() || !ogate->isConnected()) {
             // half connected gate
             if (errorWhenAsymmetric)
                 throw cRuntimeError("The input or output gate not connected at port %i", i);
             dataratesDiffer = true;
             EV << "The input or output gate not connected at port " << i << ".\n";
             continue;
         }
 
         numActivePorts++;
         double drate = igate->getIncomingTransmissionChannel()->getNominalDatarate();
 
         if (numActivePorts == 1)
             datarate = drate;
         else if (datarate != drate) {
             if (errorWhenAsymmetric)
                 throw cRuntimeError("The input datarate at port %i differs from datarates of previous ports", i);
             dataratesDiffer = true;
             EV << "The input datarate at port " << i << " differs from datarates of previous ports.\n";
         }
 
         cChannel *outTrChannel = ogate->getTransmissionChannel();
         drate = outTrChannel->getNominalDatarate();
 
         if (datarate != drate) {
             if (errorWhenAsymmetric)
                 throw cRuntimeError("The output datarate at port %i differs from datarates of previous ports", i);
             dataratesDiffer = true;
             EV << "The output datarate at port " << i << " differs from datarates of previous ports.\n";
         }
 
         if (!outTrChannel->isSubscribed(POST_MODEL_CHANGE, this))
             outTrChannel->subscribe(POST_MODEL_CHANGE, this);
     }
 }

void inet::EtherHub::finish ( )

overrideprotectedvirtual

 {
     simtime_t t = simTime();
     recordScalar("simulated time", t);
 
     if (t > 0)
         recordScalar("messages/sec", numMessages / t);
 }

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

overrideprotectedvirtual

 {
     if (dataratesDiffer)
         checkConnections(true);
 
     // Handle frame sent down from the network entity: send out on every other port
     int arrivalPort = msg->getArrivalGate()->getIndex();
     EV << "Frame " << msg << " arrived on port " << arrivalPort << ", broadcasting on all other ports\n";
 
     numMessages++;
     emit(pkSignal, msg);
 
     if (numPorts <= 1) {
         delete msg;
         return;
     }
 
     for (int i = 0; i < numPorts; i++) {
         if (i != arrivalPort) {
             cGate *ogate = gate(outputGateBaseId + i);
             if (!ogate->isConnected())
                 continue;
 
             bool isLast = (arrivalPort == numPorts - 1) ? (i == numPorts - 2) : (i == numPorts - 1);
             cMessage *msg2 = isLast ? msg : msg->dup();
 
             // stop current transmission
             ogate->getTransmissionChannel()->forceTransmissionFinishTime(SIMTIME_ZERO);
 
             // send
             send(msg2, ogate);
 
             if (isLast)
                 msg = nullptr; // msg sent, do not delete it.
         }
     }
     delete msg;
 }

void inet::EtherHub::initialize ( )

overrideprotectedvirtual

 {
     numPorts = gateSize("ethg");
     inputGateBaseId = gateBaseId("ethg$i");
     outputGateBaseId = gateBaseId("ethg$o");
 
     numMessages = 0;
     WATCH(numMessages);
 
     // ensure we receive frames when their first bits arrive
     for (int i = 0; i < numPorts; i++)
         gate(inputGateBaseId + i)->setDeliverOnReceptionStart(true);
     subscribe(POST_MODEL_CHANGE, this);    // we'll need to do the same for dynamically added gates as well
 
     checkConnections(true);
 }

void inet::EtherHub::receiveSignal	(	cComponent *	source,
		simsignal_t	signalID,
		cObject *	obj,
		cObject *	details
	)

overrideprotectedvirtual

 {
     Enter_Method_Silent();
 
     ASSERT(signalID == POST_MODEL_CHANGE);
 
     // if new gates have been added, we need to call setDeliverOnReceptionStart(true) on them
     cPostGateVectorResizeNotification *notif = dynamic_cast<cPostGateVectorResizeNotification *>(obj);
     if (notif) {
         if (strcmp(notif->gateName, "ethg") == 0) {
             int newSize = gateSize("ethg");
             for (int i = notif->oldSize; i < newSize; i++)
                 gate(inputGateBaseId + i)->setDeliverOnReceptionStart(true);
         }
         return;
     }
 
     cPostPathCreateNotification *connNotif = dynamic_cast<cPostPathCreateNotification *>(obj);
     if (connNotif) {
         if ((this == connNotif->pathStartGate->getOwnerModule()) || (this == connNotif->pathEndGate->getOwnerModule()))
             checkConnections(false);
         return;
     }
 
     cPostPathCutNotification *cutNotif = dynamic_cast<cPostPathCutNotification *>(obj);
     if (cutNotif) {
         if ((this == cutNotif->pathStartGate->getOwnerModule()) || (this == cutNotif->pathEndGate->getOwnerModule()))
             checkConnections(false);
         return;
     }
 
     // note: we are subscribed to the channel object too
     cPostParameterChangeNotification *parNotif = dynamic_cast<cPostParameterChangeNotification *>(obj);
     if (parNotif) {
         cChannel *channel = dynamic_cast<cDatarateChannel *>(parNotif->par->getOwner());
         if (channel) {
             cGate *gate = channel->getSourceGate();
             if (gate->pathContains(this))
                 checkConnections(false);
         }
         return;
     }
 }