devPktGen.cpp

Go to the documentation of this file.

#include <list>
#include "SlottedAloha.h"

#include "devPktGen.h"

DevPktGen::DevPktGen(SysSAloha *_System, DevAP* _theAP)
: DEDevice(_System), System(_System), theAP(_theAP), counter(0)
{
  the_SG_Probe = 0;
};

void DevPktGen::setup(ParamManager *Param, GlobalProbeManager *Results)
{
  Param->addClass ("Dev_Test_PktGen", "Data Terminal generator");
  Param->addParameter ("Dev_Test_PktGen", new DETimeParameter("MsgInterarrTime",  "Mean message interarrival time", "10.0", "(0,inf)" ));
}

void DevPktGen::Initialize()
{
  DETime MsgInterarrTime = get<DETimeParameter,DETime>(Param, "MsgInterarrTime", "Dev_Test_PktGen", "");
  MsgInterarrTimeGen = ExponentialDETimeRndGen(MsgInterarrTime);

  if( the_SG_Probe )
    delete( the_SG_Probe );
  the_SG_Probe = new ProbeSG( "the_SG" );
  
  list<DevPkt*>::iterator dtListIter;
  for(  dtListIter=dtList.begin(); dtListIter!=dtList.end(); dtListIter++)
    delete (*dtListIter);
  dtList.clear();
  
  DevPkt* newPkt = new DevPkt( System, this, theAP, counter++);
  the_SG_Probe->Observe_S(1);
  newPkt->Initialize();
  dtList.push_back(newPkt);
  
  newEvent(new Ev_PktGen_Generation(this), MsgInterarrTimeGen.get());  
}

/*
 Packet generation function. We create a new packet and we reschedule another generation.
 */
void DevPktGen::HEv_PktGen_Generation()
{
  DevPkt* newPkt = new DevPkt( System, this, theAP, counter++);
  the_SG_Probe->Observe_S(1);
  newPkt->Initialize();
  dtList.push_back(newPkt);
  
  newEvent(new Ev_PktGen_Generation(this), MsgInterarrTimeGen.get());  
}

/*
 A backlogged packet is recorded in the appropriate probe.
 */
void DevPktGen::AddBacklogged()
{
  the_SG_Probe->Observe_G(1);
}

/*
 A packet has been successfully sent. Note that it is not mandatory to store each generated instance
 somewhere. The simulation could work without this, but we need it in case of multiple runs.
 
 In a multiple run, the Packet Generator \e could be destoyed, so we need to track down what has been
 created in order to destroy it.
 */
void DevPktGen::RemoveTerminal(DevPkt* dt)
{
  list<DevPkt*>::iterator dtListIter;
  dtListIter = find(dtList.begin(), dtList.end(), dt);
  dtList.erase(dtListIter);
}

/*
 As in RemoveTerminal(), it is better to clean up the gerated packets.
 */
DevPktGen::~DevPktGen()
{
  list<DevPkt*>::iterator dtListIter;
  for(  dtListIter=dtList.begin(); dtListIter!=dtList.end(); dtListIter++)
    delete (*dtListIter);
  dtList.clear();
}

---