blob: a7b848c752f1a562f0b6bfe5bfb6323a032c85e8 [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 "ccnx-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/double.h"
#include "ns3/ccnx.h"
#include "../model/ccnx-local-face.h"
#include "ns3/ccnx-interest-header.h"
#include "ns3/ccnx-content-object-header.h"
NS_LOG_COMPONENT_DEFINE ("CcnxConsumerCbr");
namespace ns3
{
NS_OBJECT_ENSURE_REGISTERED (CcnxConsumerCbr);
TypeId
CcnxConsumerCbr::GetTypeId (void)
{
static TypeId tid = TypeId ("ns3::CcnxConsumerCbr")
.SetParent<CcnxConsumer> ()
.AddConstructor<CcnxConsumerCbr> ()
.AddAttribute ("Frequency", "Frequency of interest packets",
StringValue ("1.0"),
MakeDoubleAccessor (&CcnxConsumerCbr::m_frequency),
MakeDoubleChecker<double> ())
;
return tid;
}
CcnxConsumerCbr::CcnxConsumerCbr ()
: m_frequency (1.0)
{
NS_LOG_FUNCTION_NOARGS ();
}
void
CcnxConsumerCbr::ScheduleNextPacket ()
{
// double mean = 8.0 * m_payloadSize / m_desiredRate.GetBitRate ();
// std::cout << "next: " << Simulator::Now().ToDouble(Time::S) + mean << "s\n";
if (!m_sendEvent.IsRunning ())
m_sendEvent = Simulator::Schedule (
// Seconds(m_randExp.GetValue ()),
Seconds(1.0 / m_frequency),
&CcnxConsumer::SendPacket, this);
}
///////////////////////////////////////////////////
// Process incoming packets //
///////////////////////////////////////////////////
// void
// CcnxConsumer::OnContentObject (const Ptr<const CcnxContentObjectHeader> &contentObject,
// const Ptr<const Packet> &payload)
// {
// CcnxConsumer::OnContentObject (contentObject, payload); // tracing inside
// }
// void
// CcnxConsumer::OnNack (const Ptr<const CcnxInterestHeader> &interest)
// {
// CcnxConsumer::OnNack (interest); // tracing inside
// }
} // namespace ns3