OptimalPacketAggregation/ADATransmissionManager.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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
//
//  ADATransmissionManager.cpp
//  AggregationNS3
//
//  Created by Alper Sinan Akyurek on 10/6/16.
//  Copyright © 2016 Alper Sinan Akyurek. All rights reserved.
//

#include "ADATransmissionManager.hpp"

#include "ApplicationConfigureHelper.hpp"

NS_LOG_COMPONENT_DEFINE("ADATransmissionManager");

NS_OBJECT_ENSURE_REGISTERED(ADATransmissionManager);

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

    return ( tid );
}

void
ADATransmissionManager::Start( void )
{
    GainFunction::TTransmissionTime x = ns3::Seconds( 0.1 * ((double)rand() / (double)RAND_MAX ) );
    ns3::Simulator::Schedule( this->m_checkTimer + x, &ADATransmissionManager::CheckWaitingTimer, this );
}

void
ADATransmissionManager::TransmitAllMeasurements( void )
{
    this->SendAllMeasurements();
    ns3::Simulator::Schedule( this->m_checkTimer, &ADATransmissionManager::CheckWaitingTimer, this );
}

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

    char comma;
    if ( !( conf >> this->m_timeConstant >> comma ) )
    {
        class ConfigurationFailed{};
        throw ConfigurationFailed();
    }

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

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

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

    ApplicationConfigureHelper::Configure( this );
}

void
ADATransmissionManager::CheckWaitingTimer( void )
{
    auto totalNumber = this->GetTotalNumberOfMeasurements();
    GainFunction::TTransmissionTime fireTimer = this->m_timeConstant * ( 1 - totalNumber / ( this->m_S * this->m_phi ) );
    if ( this->m_checkTimer > fireTimer )
    {
        if ( totalNumber > 0 )
        {
            this->TransmitAllMeasurements();
        }
        else
        {
            ns3::Simulator::Schedule( this->m_checkTimer, &ADATransmissionManager::CheckWaitingTimer, this );
        }
    }
    else
    {
        ns3::Simulator::Schedule( this->m_checkTimer, &ADATransmissionManager::CheckWaitingTimer, this );
    }
}