blob: 1727bcdc9933edff554730ba8bd5c97f69ede3ee [file] [log] [blame]
Alexander Afanasyev029d38d2012-01-09 13:50:50 -08001/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil; -*- */
2/*
3 * Copyright (c) 2011 University of California, Los Angeles
4 *
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 2 as
7 * published by the Free Software Foundation;
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 *
18 * Author: Ilya Moiseenko <iliamo@cs.ucla.edu>
19 */
20
21#include "ccnx-consumer-cbr.h"
22#include "ns3/ptr.h"
23#include "ns3/log.h"
24#include "ns3/simulator.h"
25#include "ns3/packet.h"
26#include "ns3/callback.h"
27#include "ns3/string.h"
28#include "ns3/boolean.h"
29#include "ns3/uinteger.h"
30#include "ns3/double.h"
31
32#include "ns3/ccnx.h"
33#include "../model/ccnx-local-face.h"
34#include "ns3/ccnx-interest-header.h"
35#include "ns3/ccnx-content-object-header.h"
36
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080037NS_LOG_COMPONENT_DEFINE ("CcnxConsumerCbr");
38
39namespace ns3
40{
41
42NS_OBJECT_ENSURE_REGISTERED (CcnxConsumerCbr);
43
44TypeId
45CcnxConsumerCbr::GetTypeId (void)
46{
47 static TypeId tid = TypeId ("ns3::CcnxConsumerCbr")
48 .SetParent<CcnxConsumer> ()
49 .AddConstructor<CcnxConsumerCbr> ()
50
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080051 .AddAttribute ("Frequency", "Frequency of interest packets",
52 StringValue ("1.0"),
53 MakeDoubleAccessor (&CcnxConsumerCbr::m_frequency),
54 MakeDoubleChecker<double> ())
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080055 ;
56
57 return tid;
58}
59
60CcnxConsumerCbr::CcnxConsumerCbr ()
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080061 : m_frequency (1.0)
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080062{
63 NS_LOG_FUNCTION_NOARGS ();
Alexander Afanasyev18750bb2012-02-02 23:11:30 -080064 m_seqMax = std::numeric_limits<uint32_t>::max ();
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080065}
66
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080067void
68CcnxConsumerCbr::ScheduleNextPacket ()
69{
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080070 // double mean = 8.0 * m_payloadSize / m_desiredRate.GetBitRate ();
Alexander Afanasyev94cebd02012-01-16 12:22:34 -080071 // std::cout << "next: " << Simulator::Now().ToDouble(Time::S) + mean << "s\n";
Alexander Afanasyev359bfb72012-01-09 18:42:50 -080072
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080073 if (!m_sendEvent.IsRunning ())
74 m_sendEvent = Simulator::Schedule (
Alexander Afanasyev94cebd02012-01-16 12:22:34 -080075 // Seconds(m_randExp.GetValue ()),
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080076 Seconds(1.0 / m_frequency),
Alexander Afanasyev029d38d2012-01-09 13:50:50 -080077 &CcnxConsumer::SendPacket, this);
78}
79
80///////////////////////////////////////////////////
81// Process incoming packets //
82///////////////////////////////////////////////////
83
84// void
85// CcnxConsumer::OnContentObject (const Ptr<const CcnxContentObjectHeader> &contentObject,
86// const Ptr<const Packet> &payload)
87// {
88// CcnxConsumer::OnContentObject (contentObject, payload); // tracing inside
89// }
90
91// void
92// CcnxConsumer::OnNack (const Ptr<const CcnxInterestHeader> &interest)
93// {
94// CcnxConsumer::OnNack (interest); // tracing inside
95// }
96
97} // namespace ns3