inet::EtherAppSrv Class Reference

Server-side process EtherAppCli. More...

#include <EtherAppSrv.h>

Inheritance diagram for inet::EtherAppSrv:

Protected Member Functions
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	startApp ()
virtual void	stopApp ()
virtual void	handleMessage (cMessage *msg) override
virtual void	finish () override
virtual bool	handleOperationStage (LifecycleOperation *operation, int stage, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...
virtual bool	isNodeUp ()
void	registerDSAP (int dsap)
void	sendPacket (cPacket *datapacket, const MACAddress &destAddr, int destSap)

Protected Attributes
int	localSAP = 0
NodeStatus *	nodeStatus = nullptr
long	packetsSent = 0
long	packetsReceived = 0

Static Protected Attributes
static simsignal_t	sentPkSignal = registerSignal("sentPk")
static simsignal_t	rcvdPkSignal = registerSignal("rcvdPk")

Additional Inherited Members
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()

Detailed Description

Server-side process EtherAppCli.

Member Function Documentation

void inet::EtherAppSrv::finish ( )

overrideprotectedvirtual

{
}

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

overrideprotectedvirtual

{
    if (!isNodeUp())
        throw cRuntimeError("Application is not running");

    EV_INFO << "Received packet `" << msg->getName() << "'\n";
    EtherAppReq *req = check_and_cast<EtherAppReq *>(msg);
    packetsReceived++;
    emit(rcvdPkSignal, req);

    Ieee802Ctrl *ctrl = check_and_cast<Ieee802Ctrl *>(req->removeControlInfo());
    MACAddress srcAddr = ctrl->getSrc();
    int srcSap = ctrl->getSsap();
    long requestId = req->getRequestId();
    long replyBytes = req->getResponseBytes();
    delete ctrl;

    // send back packets asked by EtherAppCli 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;

        EtherAppResp *datapacket = new EtherAppResp(s.str().c_str(), IEEE802CTRL_DATA);
        datapacket->setRequestId(requestId);
        datapacket->setByteLength(l);

        EV_INFO << "Send response `" << datapacket->getName() << "' to " << srcAddr << " ssap=" << localSAP << " dsap=" << srcSap << " length=" << l << "B requestId=" << requestId << "\n";

        sendPacket(datapacket, srcAddr, srcSap);
    }

    delete msg;
}

bool inet::EtherAppSrv::handleOperationStage ( LifecycleOperation *  operation, int  stage, IDoneCallback *  doneCallback  )

overrideprotectedvirtual

Perform one stage of a lifecycle operation.

Processing may be done entirely within this method, or may be a longer process that involves nonzero simulation time or several events, and is triggered by this method call.

Return value: true = "done"; false = "not yet done, will invoke doneCallback when done"

Implements inet::ILifecycle.

{
    Enter_Method_Silent();
    if (dynamic_cast<NodeStartOperation *>(operation)) {
        if ((NodeStartOperation::Stage)stage == NodeStartOperation::STAGE_APPLICATION_LAYER)
            startApp();
    }
    else if (dynamic_cast<NodeShutdownOperation *>(operation)) {
        if ((NodeShutdownOperation::Stage)stage == NodeShutdownOperation::STAGE_APPLICATION_LAYER)
            stopApp();
    }
    else if (dynamic_cast<NodeCrashOperation *>(operation)) {
        if ((NodeCrashOperation::Stage)stage == NodeCrashOperation::STAGE_CRASH)
            stopApp();
    }
    else
        throw cRuntimeError("Unsupported lifecycle operation '%s'", operation->getClassName());
    return true;
}

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

overrideprotectedvirtual

{
    cSimpleModule::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        localSAP = par("localSAP");

        // statistics
        packetsSent = packetsReceived = 0;

        WATCH(packetsSent);
        WATCH(packetsReceived);
    }
    else if (stage == INITSTAGE_APPLICATION_LAYER) {
        nodeStatus = dynamic_cast<NodeStatus *>(findContainingNode(this)->getSubmodule("status"));

        if (isNodeUp())
            startApp();
    }
}

bool inet::EtherAppSrv::isNodeUp ( )

protectedvirtual

Referenced by handleMessage(), and initialize().

{
    return !nodeStatus || nodeStatus->getState() == NodeStatus::UP;
}

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

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

void inet::EtherAppSrv::registerDSAP ( int  dsap )

protected

Referenced by startApp().

{
    EV_DEBUG << getFullPath() << " registering DSAP " << dsap << "\n";

    Ieee802Ctrl *etherctrl = new Ieee802Ctrl();
    etherctrl->setDsap(dsap);
    cMessage *msg = new cMessage("register_DSAP", IEEE802CTRL_REGISTER_DSAP);
    msg->setControlInfo(etherctrl);

    send(msg, "out");
}

void inet::EtherAppSrv::sendPacket ( cPacket *  datapacket, const MACAddress &  destAddr, int  destSap  )

protected

Referenced by handleMessage().

{
    Ieee802Ctrl *etherctrl = new Ieee802Ctrl();
    etherctrl->setSsap(localSAP);
    etherctrl->setDsap(destSap);
    etherctrl->setDest(destAddr);
    datapacket->setControlInfo(etherctrl);
    emit(sentPkSignal, datapacket);
    send(datapacket, "out");
    packetsSent++;
}

void inet::EtherAppSrv::startApp ( )

protectedvirtual

Referenced by handleOperationStage(), and initialize().

{
    EV_INFO << "Starting application\n";
    bool registerSAP = par("registerSAP");
    if (registerSAP)
        registerDSAP(localSAP);
}

void inet::EtherAppSrv::stopApp ( )

protectedvirtual

Referenced by handleOperationStage().

{
    EV_INFO << "Stop the application\n";
}

Member Data Documentation

int inet::EtherAppSrv::localSAP = 0

protected

Referenced by handleMessage(), initialize(), sendPacket(), and startApp().

NodeStatus* inet::EtherAppSrv::nodeStatus = nullptr

protected

Referenced by initialize(), and isNodeUp().

long inet::EtherAppSrv::packetsReceived = 0

protected

Referenced by handleMessage(), and initialize().

long inet::EtherAppSrv::packetsSent = 0

protected

Referenced by initialize(), and sendPacket().

simsignal_t inet::EtherAppSrv::rcvdPkSignal = registerSignal("rcvdPk")

staticprotected

Referenced by handleMessage().

simsignal_t inet::EtherAppSrv::sentPkSignal = registerSignal("sentPk")

staticprotected

Referenced by sendPacket().

---

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

• EtherAppSrv.h
• EtherAppSrv.cc