blob: 77fe130aebfc9ab4c4f84e48e13d1f1ebd2f3c30 [file] [log] [blame]
/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil; -*- */
/*
* Copyright (c) 2011 University of California, Los Angeles
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 2 as
* published by the Free Software Foundation;
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* Author: Ilya Moiseenko <iliamo@cs.ucla.edu>
*/
#include "ndn-consumer-cbr.h"
#include "ns3/ptr.h"
#include "ns3/log.h"
#include "ns3/simulator.h"
#include "ns3/packet.h"
#include "ns3/callback.h"
#include "ns3/string.h"
#include "ns3/boolean.h"
#include "ns3/uinteger.h"
#include "ns3/integer.h"
#include "ns3/double.h"
#include "ns3/ndn-app-face.h"
#include "ns3/ndn-interest.h"
#include "ns3/ndn-content-object.h"
NS_LOG_COMPONENT_DEFINE ("ndn.ConsumerCbr");
namespace ns3 {
namespace ndn {
NS_OBJECT_ENSURE_REGISTERED (ConsumerCbr);
TypeId
ConsumerCbr::GetTypeId (void)
{
static TypeId tid = TypeId ("ns3::ndn::ConsumerCbr")
.SetGroupName ("Ndn")
.SetParent<Consumer> ()
.AddConstructor<ConsumerCbr> ()
.AddAttribute ("Frequency", "Frequency of interest packets",
StringValue ("1.0"),
MakeDoubleAccessor (&ConsumerCbr::m_frequency),
MakeDoubleChecker<double> ())
.AddAttribute ("Randomize", "Type of send time randomization: none (default), uniform, exponential",
StringValue ("none"),
MakeStringAccessor (&ConsumerCbr::SetRandomize, &ConsumerCbr::GetRandomize),
MakeStringChecker ())
.AddAttribute ("MaxSeq",
"Maximum sequence number to request",
IntegerValue (std::numeric_limits<uint32_t>::max ()),
MakeIntegerAccessor (&ConsumerCbr::m_seqMax),
MakeIntegerChecker<uint32_t> ())
;
return tid;
}
ConsumerCbr::ConsumerCbr ()
: m_frequency (1.0)
, m_firstTime (true)
, m_random (0)
{
NS_LOG_FUNCTION_NOARGS ();
m_seqMax = std::numeric_limits<uint32_t>::max ();
}
ConsumerCbr::~ConsumerCbr ()
{
if (m_random)
delete m_random;
}
void
ConsumerCbr::ScheduleNextPacket ()
{
// double mean = 8.0 * m_payloadSize / m_desiredRate.GetBitRate ();
// std::cout << "next: " << Simulator::Now().ToDouble(Time::S) + mean << "s\n";
if (m_firstTime)
{
m_sendEvent = Simulator::Schedule (Seconds (0.0),
&Consumer::SendPacket, this);
m_firstTime = false;
}
else if (!m_sendEvent.IsRunning ())
m_sendEvent = Simulator::Schedule (
(m_random == 0) ?
Seconds(1.0 / m_frequency)
:
Seconds(m_random->GetValue ()),
&Consumer::SendPacket, this);
}
void
ConsumerCbr::SetRandomize (const std::string &value)
{
if (m_random)
delete m_random;
if (value == "uniform")
{
m_random = new UniformVariable (0.0, 2 * 1.0 / m_frequency);
}
else if (value == "exponential")
{
m_random = new ExponentialVariable (1.0 / m_frequency, 50 * 1.0 / m_frequency);
}
else
m_random = 0;
m_randomType = value;
}
std::string
ConsumerCbr::GetRandomize () const
{
return m_randomType;
}
///////////////////////////////////////////////////
// Process incoming packets //
///////////////////////////////////////////////////
// void
// Consumer::OnData (const Ptr<const Data> &contentObject,
// const Ptr<const Packet> &payload)
// {
// Consumer::OnData (contentObject, payload); // tracing inside
// }
// void
// Consumer::OnNack (const Ptr<const Interest> &interest)
// {
// Consumer::OnNack (interest); // tracing inside
// }
} // namespace ndn
} // namespace ns3