inet::EtherAppServer Class Reference

Server-side process EtherAppClient. More...

#include <EtherAppServer.h>

Inheritance diagram for inet::EtherAppServer:

Protected Member Functions
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	handleMessageWhenUp (cMessage *msg) override
virtual void	finish () override
virtual void	handleStartOperation (LifecycleOperation *operation) override
virtual void	handleStopOperation (LifecycleOperation *operation) override
virtual void	handleCrashOperation (LifecycleOperation *operation) override
void	registerDsap (int dsap)
void	sendPacket (Packet *datapacket, int interfaceId, const MacAddress &destAddr, int destSap)
virtual void	socketDataArrived (Ieee8022LlcSocket *, Packet *msg) override
virtual void	socketClosed (Ieee8022LlcSocket *socket) override
Protected Member Functions inherited from inet::ApplicationBase
virtual bool	isInitializeStage (int stage) const override
virtual bool	isModuleStartStage (int stage) const override
virtual bool	isModuleStopStage (int stage) const override
Protected Member Functions inherited from inet::OperationalMixin< cSimpleModule >
virtual int	numInitStages () const override
virtual void	refreshDisplay () const override
virtual void	handleMessage (cMessage *msg) override
virtual void	handleMessageWhenDown (cMessage *msg)
virtual bool	handleOperationStage (LifecycleOperation *operation, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...
virtual State	getInitialOperationalState () const
	Returns initial operational state: OPERATING or NOT_OPERATING. More...
virtual void	handleActiveOperationTimeout (cMessage *message)
virtual bool	isUp () const
	utility functions More...
virtual bool	isDown () const
virtual void	setOperationalState (State newState)
virtual void	scheduleOperationTimeout (simtime_t timeout)
virtual void	setupActiveOperation (LifecycleOperation *operation, IDoneCallback *doneCallback, State)
virtual void	delayActiveOperationFinish (simtime_t timeout)
virtual void	startActiveOperationExtraTime (simtime_t delay=SIMTIME_ZERO)
virtual void	startActiveOperationExtraTimeOrFinish (simtime_t extraTime)
virtual void	finishActiveOperation ()

Protected Attributes
int	localSap = 0
Ieee8022LlcSocket	llcSocket
long	packetsSent = 0
long	packetsReceived = 0
Protected Attributes inherited from inet::OperationalMixin< cSimpleModule >
State	operationalState
simtime_t	lastChange
Operation	activeOperation
cMessage *	activeOperationTimeout
cMessage *	activeOperationExtraTimer

Additional Inherited Members
Public Member Functions inherited from inet::ApplicationBase
	ApplicationBase ()
Public Member Functions inherited from inet::OperationalMixin< cSimpleModule >
virtual	~OperationalMixin ()
	}@ More...
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()
Public Member Functions inherited from inet::Ieee8022LlcSocket::ICallback
virtual	~ICallback ()
Protected Types inherited from inet::OperationalMixin< cSimpleModule >
enum	State

Detailed Description

Server-side process EtherAppClient.

Member Function Documentation

finish()

void inet::EtherAppServer::finish ( )

overrideprotectedvirtual

{
}

handleCrashOperation()

void inet::EtherAppServer::handleCrashOperation ( LifecycleOperation *  operation )

overrideprotectedvirtual

Implements inet::OperationalMixin< cSimpleModule >.

{
    EV_INFO << "Crash the application\n";
    if (operation->getRootModule() != getContainingNode(this))
        llcSocket.destroy();
}

handleMessageWhenUp()

void inet::EtherAppServer::handleMessageWhenUp ( cMessage *  msg )

overrideprotectedvirtual

Implements inet::OperationalMixin< cSimpleModule >.

{
    llcSocket.processMessage(msg);
}

handleStartOperation()

void inet::EtherAppServer::handleStartOperation ( LifecycleOperation *  operation )

overrideprotectedvirtual

Implements inet::OperationalMixin< cSimpleModule >.

{
    EV_INFO << "Starting application\n";
    registerDsap(localSap);
}

handleStopOperation()

void inet::EtherAppServer::handleStopOperation ( LifecycleOperation *  operation )

overrideprotectedvirtual

Implements inet::OperationalMixin< cSimpleModule >.

{
    EV_INFO << "Stop the application\n";
    llcSocket.close();
    delayActiveOperationFinish(par("stopOperationTimeout"));
}

initialize()

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

overrideprotectedvirtual

Reimplemented from inet::OperationalMixin< cSimpleModule >.

{
    ApplicationBase::initialize(stage);
 
    if (stage == INITSTAGE_LOCAL) {
        localSap = par("localSAP");
 
        // statistics
        packetsSent = packetsReceived = 0;
 
        // socket
        llcSocket.setOutputGate(gate("out"));
        llcSocket.setCallback(this);
 
        WATCH(packetsSent);
        WATCH(packetsReceived);
    }
}

numInitStages()

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

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

registerDsap()

void inet::EtherAppServer::registerDsap ( int  dsap )

protected

{
    EV_DEBUG << getFullPath() << " registering DSAP " << dsap << "\n";
 
    llcSocket.open(-1, dsap, -1);
}

Referenced by handleStartOperation().

sendPacket()

void inet::EtherAppServer::sendPacket ( Packet *  datapacket, int  interfaceId, const MacAddress &  destAddr, int  destSap  )

protected

{
    datapacket->addTag<InterfaceReq>()->setInterfaceId(interfaceId);
    datapacket->addTag<MacAddressReq>()->setDestAddress(destAddr);
    auto ieee802SapReq = datapacket->addTag<Ieee802SapReq>();
    ieee802SapReq->setSsap(localSap);
    ieee802SapReq->setDsap(destSap);
 
    emit(packetSentSignal, datapacket);
    llcSocket.send(datapacket);
    packetsSent++;
}

Referenced by socketDataArrived().

socketClosed()

void inet::EtherAppServer::socketClosed ( Ieee8022LlcSocket *  socket )

overrideprotectedvirtual

Implements inet::Ieee8022LlcSocket::ICallback.

{
    if (operationalState == State::STOPPING_OPERATION && !llcSocket.isOpen())
        startActiveOperationExtraTimeOrFinish(par("stopOperationExtraTime"));
}

socketDataArrived()

void inet::EtherAppServer::socketDataArrived ( Ieee8022LlcSocket *  , Packet *  msg  )

overrideprotectedvirtual

Implements inet::Ieee8022LlcSocket::ICallback.

{
    EV_INFO << "Received packet `" << msg->getName() << "'\n";
    const auto& req = msg->peekAtFront<EtherAppReq>();
    if (req == nullptr)
        throw cRuntimeError("data type error: not an EtherAppReq arrived in packet %s", msg->str().c_str());
    packetsReceived++;
    emit(packetReceivedSignal, msg);
 
    MacAddress srcAddr = msg->getTag<MacAddressInd>()->getSrcAddress();
    int srcInterfaceId = msg->getTag<InterfaceInd>()->getInterfaceId();
    int srcSap = msg->getTag<Ieee802SapInd>()->getSsap();
    long requestId = req->getRequestId();
    long replyBytes = req->getResponseBytes();
 
    // send back packets asked by EtherAppClient 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;
 
        Packet *outPacket = new Packet(s.str().c_str(), IEEE802CTRL_DATA);
        const auto& outPayload = makeShared<EtherAppResp>();
        outPayload->setRequestId(requestId);
        outPayload->setChunkLength(B(l));
        outPayload->addTag<CreationTimeTag>()->setCreationTime(simTime());
        outPacket->insertAtBack(outPayload);
 
        EV_INFO << "Send response `" << outPacket->getName() << "' to " << srcAddr << " ssap=" << localSap << " dsap=" << srcSap << " length=" << l << "B requestId=" << requestId << "\n";
 
        sendPacket(outPacket, srcInterfaceId, srcAddr, srcSap);
    }
 
    delete msg;
}

Member Data Documentation

llcSocket

Ieee8022LlcSocket inet::EtherAppServer::llcSocket

protected

Referenced by handleCrashOperation(), handleMessageWhenUp(), handleStopOperation(), initialize(), registerDsap(), sendPacket(), and socketClosed().

localSap

int inet::EtherAppServer::localSap = 0

protected

Referenced by handleStartOperation(), initialize(), sendPacket(), and socketDataArrived().

packetsReceived

long inet::EtherAppServer::packetsReceived = 0

protected

Referenced by initialize(), and socketDataArrived().

packetsSent

long inet::EtherAppServer::packetsSent = 0

protected

Referenced by initialize(), and sendPacket().

---

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

• EtherAppServer.h
• EtherAppServer.cc