blob: 37209b3c3c6934a7bfbb058b0b6c8cbb4b1887c2 [file] [log] [blame]
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -07001/* -*- 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>
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080019 * Alexander Afanasyev <alexander.afanasyev@ucla.edu>
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070020 */
21
22#include "ccnx-producer.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080023#include "ns3/log.h"
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080024#include "ns3/ccnx-interest-header.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080025#include "ns3/ccnx-content-object-header.h"
Alexander Afanasyev8e0d2812012-01-19 22:38:14 -080026// #include "ns3/ccnx-path-stretch-tag.h"
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080027#include "ns3/string.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080028#include "ns3/uinteger.h"
29#include "ns3/packet.h"
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070030
Alexander Afanasyevf9f4eb02011-12-16 01:51:14 -080031#include "../model/ccnx-local-face.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080032#include "ns3/ccnx-fib.h"
33
34#include <boost/ref.hpp>
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080035#include <boost/lambda/lambda.hpp>
36#include <boost/lambda/bind.hpp>
37namespace ll = boost::lambda;
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070038
39NS_LOG_COMPONENT_DEFINE ("CcnxProducer");
40
41namespace ns3
42{
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080043
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070044NS_OBJECT_ENSURE_REGISTERED (CcnxProducer);
45
46TypeId
47CcnxProducer::GetTypeId (void)
48{
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080049 static TypeId tid = TypeId ("ns3::CcnxProducer")
50 .SetParent<CcnxApp> ()
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070051 .AddConstructor<CcnxProducer> ()
Ilya Moiseenkob62c7402011-10-28 13:02:18 -070052 .AddAttribute ("Prefix","Prefix, for which producer has the data",
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080053 StringValue ("/"),
Ilya Moiseenkob62c7402011-10-28 13:02:18 -070054 MakeCcnxNameComponentsAccessor (&CcnxProducer::m_prefix),
55 MakeCcnxNameComponentsChecker ())
56 .AddAttribute ("PayloadSize", "Virtual payload size for Content packets",
Alexander Afanasyevc39f0b42011-11-28 12:51:12 -080057 UintegerValue (1024),
Ilya Moiseenkob62c7402011-10-28 13:02:18 -070058 MakeUintegerAccessor(&CcnxProducer::m_virtualPayloadSize),
59 MakeUintegerChecker<uint32_t>())
Alexander Afanasyevbdc0d982011-12-16 01:15:26 -080060
61 .AddTraceSource ("TransmittedContentObjects", "TransmittedContentObjects",
62 MakeTraceSourceAccessor (&CcnxProducer::m_transmittedContentObjects))
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070063 ;
64
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080065 return tid;
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070066}
67
68CcnxProducer::CcnxProducer ()
69{
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080070 // NS_LOG_FUNCTION_NOARGS ();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070071}
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080072
73// inherited from Application base class.
74void
75CcnxProducer::StartApplication ()
76{
77 NS_LOG_FUNCTION_NOARGS ();
78 NS_ASSERT (GetNode ()->GetObject<CcnxFib> () != 0);
79
80 CcnxApp::StartApplication ();
81
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080082 Ptr<CcnxFib> fib = GetNode ()->GetObject<CcnxFib> ();
83 CcnxFibEntryContainer::type::iterator fibEntry = fib->Add (m_prefix, m_face, 0);
84
85 // make face green, so it will be used primarily
86 fib->m_fib.modify (fibEntry,
87 ll::bind (&CcnxFibEntry::UpdateStatus,
88 ll::_1, m_face, CcnxFibFaceMetric::NDN_FIB_GREEN));
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080089}
90
91void
92CcnxProducer::StopApplication ()
93{
94 NS_LOG_FUNCTION_NOARGS ();
95 NS_ASSERT (GetNode ()->GetObject<CcnxFib> () != 0);
96
97 CcnxApp::StopApplication ();
98}
99
100
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700101void
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -0800102CcnxProducer::OnInterest (const Ptr<const CcnxInterestHeader> &interest, Ptr<Packet> origPacket)
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700103{
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -0800104 CcnxApp::OnInterest (interest, origPacket); // tracing inside
Alexander Afanasyevbdc0d982011-12-16 01:15:26 -0800105
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800106 NS_LOG_FUNCTION (this << interest);
Ilya Moiseenkob62c7402011-10-28 13:02:18 -0700107
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800108 if (!m_active) return;
Ilya Moiseenkob62c7402011-10-28 13:02:18 -0700109
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800110 static CcnxContentObjectTail tail;
111 Ptr<CcnxContentObjectHeader> header = Create<CcnxContentObjectHeader> ();
112 header->SetName (Create<CcnxNameComponents> (interest->GetName ()));
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800113
Lucasa3295ab2012-02-04 13:36:31 -0800114 NS_LOG_INFO ("node("<< GetNode()->GetId() <<") respodning with ContentObject:\n" << boost::cref(*header));
Ilya Moiseenkob62c7402011-10-28 13:02:18 -0700115
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800116 Ptr<Packet> packet = Create<Packet> (m_virtualPayloadSize);
Alexander Afanasyev8e0d2812012-01-19 22:38:14 -0800117 // Ptr<const WeightsPathStretchTag> tag = origPacket->RemovePacketTag<WeightsPathStretchTag> ();
118 // if (tag != 0)
119 // {
120 // // std::cout << Simulator::Now () << ", " << m_app->GetInstanceTypeId ().GetName () << "\n";
Alexander Afanasyevbdc0d982011-12-16 01:15:26 -0800121
Alexander Afanasyev8e0d2812012-01-19 22:38:14 -0800122 // // echo back WeightsPathStretchTag
123 // packet->AddPacketTag (CreateObject<WeightsPathStretchTag> (*tag));
Alexander Afanasyev6bff0df2012-01-19 17:51:52 -0800124
Alexander Afanasyev8e0d2812012-01-19 22:38:14 -0800125 // // \todo
126 // // packet->AddPacketTag should actually accept Ptr<const WeightsPathStretchTag> instead of
127 // // Ptr<WeightsPathStretchTag>. Echoing will be simplified after change is done
128 // }
Alexander Afanasyev6bff0df2012-01-19 17:51:52 -0800129
Alexander Afanasyevbdc0d982011-12-16 01:15:26 -0800130 m_transmittedContentObjects (header, packet, this, m_face);
131
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800132 packet->AddHeader (*header);
133 packet->AddTrailer (tail);
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800134
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800135 m_protocolHandler (packet);
Ilya Moiseenkob62c7402011-10-28 13:02:18 -0700136}
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800137
138} // namespace ns3