AEMyPing.cc

Go to the documentation of this file.

// The MIT License (MIT)
//
// Copyright (c) 2014-2016 Brno University of Technology, PRISTINE project
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.

#include "AEMyPing.h"

Define_Module(AEMyPing);

void AEMyPing::initialize() {
    initPing();
}

void AEMyPing::handleMessage(cMessage* msg) {
    if ( msg->isSelfMessage() ) {
        this->handleSelfMessage(msg);
    }
}

void AEMyPing::afterOnStart() {
    Enter_Method("afterOnStart()");
    //Prepare flow's source and destination
    APNamingInfo src = this->getApni();
    APNamingInfo dst = APNamingInfo( APN(this->dstApName), this->dstApInstance,
                                     this->dstAeName, this->dstAeInstance);

    //Create a flow
    FlowObject = new Flow(src, dst);
    FlowObject->setQosRequirements(this->getQoSRequirements());

    //Notify IRM about a new flow
    insertFlow();

    //Call flow allocation request
    sendAllocationRequest(FlowObject);
}

void AEMyPing::onPing() {
    //Create PING messsage
    CDAP_M_Read* ping = new CDAP_M_Read("ping");

    //Prepare timestamp structure that is going to be carried via ping/pong
    timestamps_t* ts = new timestamps_t;
    ts->t1 = simTime();

    //Prepare object and put timestamp structure inside
    object_t obj;
    obj.objectName = "ping_time";
    obj.objectClass = "timestamps_t";
    obj.objectInstance = -1;
    obj.objectVal = (cObject*)(ts);
    ping->setObjectItem(obj);
    ping->setByteLength(size);

    //Send message
    sendData(FlowObject, ping);
}

void AEMyPing::onStop() {
    //Call flow deallocation submit
    sendDeallocationRequest(FlowObject);
}

void AEMyPing::processMRead(CDAPMessage* msg) {
    CDAP_M_Read* msg1 = check_and_cast<CDAP_M_Read*>(msg);
    object_t object = msg1->getObjectItem();

    //Produce message to the console
    EV << "Received M_Read with object '" << object.objectName
            << "' of class '" << object.objectClass << "'" << endl;

    //Based on object inside do something
    if ( strstr(object.objectName.c_str(), "ping_time") ) {
        //Get timestamp structure inside and update it
        timestamps_t* ts = (timestamps_t*)(object.objectVal);
        ts->t2 = simTime();

        //Produce message to the console
        EV << "PING sent at " << ts->t1
                << "s, received at " << ts->t2
                << "s, OWT1: " << (ts->t2 - ts->t1) << "s" << endl;

        //Create PING response
        CDAP_M_Read_R* pong = new CDAP_M_Read_R("pong");

        //Prepare object and put timestamp structure inside
        object_t obj;
        obj.objectName = "pong_time";
        obj.objectClass = "timestamps_t";
        obj.objectInstance = -1;
        obj.objectVal = (cObject*)(ts);
        pong->setObjectItem(obj);
        pong->setByteLength(msg1->getByteLength());

        //Send message
        sendData(FlowObject, pong);
    }
}


void AEMyPing::processMReadR(CDAPMessage* msg) {
    CDAP_M_Read_R* msg1 = check_and_cast<CDAP_M_Read_R*>(msg);
    object_t object = msg1->getObjectItem();

    EV << "Received M_Read with object '" << object.objectName
            << "' of class '" << object.objectClass << "'" << endl;

    //Based on object inside do something
    if ( strstr(object.objectName.c_str(), "pong_time") ) {
        //Get timestamp structure inside and update it
        timestamps_t* ts = (timestamps_t*)(object.objectVal);
        ts->t3 = simTime();

        //Produce message to the console
        EV << "PING sent at " << ts->t1
                << "s, received at " << ts->t2
                << "s, responded at " << ts->t3
                << "s, OWT1: " << (ts->t2 - ts->t1)
                << "s, OWT2: " << (ts->t3 - ts->t2)
                << "s, RTT: " << (ts->t3 - ts->t1) << "s" << endl;
    }
}