OptimalPacketAggregation/CascadingTransmissionManager.cpp at master · UCSD-SEELab/OptimalPacketAggregation · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
//
//  CascadingTransmissionManager.cpp
//  AggregationNS3
//
//  Created by Alper Sinan Akyurek on 8/27/16.
//  Copyright © 2016 Alper Sinan Akyurek. All rights reserved.
//

#include "CascadingTransmissionManager.hpp"

#include "ApplicationConfigureHelper.hpp"

NS_LOG_COMPONENT_DEFINE("CascadingTransmissionManager");

NS_OBJECT_ENSURE_REGISTERED(CascadingTransmissionManager);

ns3::TypeId
CascadingTransmissionManager::GetTypeId( void )
{
    static ns3::TypeId tid = ns3::TypeId( "CascadingTransmissionManager" )
    .SetParent<ns3::Object> ()
    .AddConstructor<CascadingTransmissionManager> ()
    ;

    return ( tid );
}

unsigned int hopNumber = 1;

void
CascadingTransmissionManager::Start( void )
{
    this->m_hopNumber = hopNumber;
    ++hopNumber;
    this->m_fixedTime = 2 * ( this->m_fixedTime - this->m_hopNumber * ns3::Seconds( 0.03 ) );
    GainFunction::TTransmissionTime x = ns3::Seconds( 0.1 * ((double)rand() / (double)RAND_MAX ) );
    ns3::Simulator::Schedule( this->m_fixedTime + x, &CascadingTransmissionManager::TransmitAllMeasurements, this );
}

void
CascadingTransmissionManager::TransmitAllMeasurements( void )
{
    this->SendAllMeasurements();
    ns3::Simulator::Schedule( this->m_fixedTime, &CascadingTransmissionManager::TransmitAllMeasurements, this );
}

void
CascadingTransmissionManager::ReadConfiguration( void )
{
    std::ifstream conf( "cascTM.txt" );
    if ( !conf )
    {
        class FileOpenFailed{};
        throw FileOpenFailed();
    }

    if ( !( conf >> this->m_fixedTime ) )
    {
        class ConfigurationFailed{};
        throw ConfigurationFailed();
    }

    ApplicationConfigureHelper::Configure( this );
}