blob: df398c8d071b5e314b5e866968a12d88a6d7bc9c [file] [log] [blame]
Alexander Afanasyevc74a6022011-08-15 20:01:35 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */
Alexander Afanasyev98256102011-08-14 01:00:02 -07002/*
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -07003 * Copyright (c) 2011 University of California, Los Angeles
Alexander Afanasyev98256102011-08-14 01:00:02 -07004 *
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
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070017 *
18 * Author: Alexander Afanasyev <alexander.afanasyev@ucla.edu>
19 * Ilya Moiseenko <iliamo@cs.ucla.edu>
Alexander Afanasyev98256102011-08-14 01:00:02 -070020 */
21
22#include "ns3/assert.h"
23
Alexander Afanasyevc74a6022011-08-15 20:01:35 -070024#include "ccnx-forwarding-strategy.h"
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -080025#include "ns3/ptr.h"
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080026#include "ns3/log.h"
27#include "ns3/simulator.h"
Alexander Afanasyevf377b332011-12-16 15:32:12 -080028
29#include "ccnx-pit.h"
30#include "ccnx-pit-entry.h"
31
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080032#include "ccnx-interest-header.h"
33
34#include <boost/ref.hpp>
35#include <boost/foreach.hpp>
36#include <boost/lambda/lambda.hpp>
37#include <boost/lambda/bind.hpp>
38namespace ll = boost::lambda;
39
40NS_LOG_COMPONENT_DEFINE ("CcnxForwardingStrategy");
Alexander Afanasyev98256102011-08-14 01:00:02 -070041
42namespace ns3 {
43
Alexander Afanasyev23d2b542011-12-07 18:54:46 -080044using namespace __ccnx_private;
45
Alexander Afanasyevc74a6022011-08-15 20:01:35 -070046NS_OBJECT_ENSURE_REGISTERED (CcnxForwardingStrategy);
Alexander Afanasyev98256102011-08-14 01:00:02 -070047
Alexander Afanasyevc74a6022011-08-15 20:01:35 -070048TypeId CcnxForwardingStrategy::GetTypeId (void)
Alexander Afanasyev98256102011-08-14 01:00:02 -070049{
Alexander Afanasyevc74a6022011-08-15 20:01:35 -070050 static TypeId tid = TypeId ("ns3::CcnxForwardingStrategy")
Alexander Afanasyev070aa482011-08-20 00:38:25 -070051 .SetGroupName ("Ccnx")
Alexander Afanasyev98256102011-08-14 01:00:02 -070052 .SetParent<Object> ()
Alexander Afanasyevf377b332011-12-16 15:32:12 -080053
54 .AddTraceSource ("OutInterests", "Interests that were transmitted",
55 MakeTraceSourceAccessor (&CcnxForwardingStrategy::m_transmittedInterestsTrace))
56
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080057 ;
Alexander Afanasyev98256102011-08-14 01:00:02 -070058 return tid;
59}
60
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070061CcnxForwardingStrategy::CcnxForwardingStrategy ()
Alexander Afanasyev98256102011-08-14 01:00:02 -070062{
Alexander Afanasyev98256102011-08-14 01:00:02 -070063}
64
Alexander Afanasyev4fa5e842011-11-21 13:38:39 -080065CcnxForwardingStrategy::~CcnxForwardingStrategy ()
66{
67}
68
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070069void
Alexander Afanasyev3a4a0b32012-06-28 14:14:22 -070070CcnxForwardingStrategy::NotifyNewAggregate ()
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070071{
Alexander Afanasyev3a4a0b32012-06-28 14:14:22 -070072 if (m_pit == 0)
73 {
74 m_pit = GetObject<CcnxPit> ();
75 }
76}
77
78void
79CcnxForwardingStrategy::DoDispose ()
80{
81 // nothing to do...
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070082}
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080083
84bool
Alexander Afanasyev30f60e32012-07-10 14:21:16 -070085CcnxForwardingStrategy::PropagateInterestViaGreen (Ptr<CcnxPitEntry> pitEntry,
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080086 const Ptr<CcnxFace> &incomingFace,
87 Ptr<CcnxInterestHeader> &header,
88 const Ptr<const Packet> &packet)
89{
Alexander Afanasyev120bf312011-12-19 01:24:47 -080090 NS_LOG_FUNCTION (this);
Alexander Afanasyev3a4a0b32012-06-28 14:14:22 -070091 NS_ASSERT_MSG (m_pit != 0, "PIT should be aggregated with forwarding strategy");
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080092
93 int propagatedCount = 0;
94
Alexander Afanasyev36b45772012-07-10 16:57:42 -070095 BOOST_FOREACH (const CcnxFibFaceMetric &metricFace, pitEntry->GetFibEntry ()->m_faces.get<i_metric> ())
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080096 {
97 if (metricFace.m_status == CcnxFibFaceMetric::NDN_FIB_RED ||
98 metricFace.m_status == CcnxFibFaceMetric::NDN_FIB_YELLOW)
99 break; //propagate only to green faces
100
Alexander Afanasyev36b45772012-07-10 16:57:42 -0700101 if (pitEntry->GetIncoming ().find (metricFace.m_face) != pitEntry->GetIncoming ().end ())
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800102 continue; // don't forward to face that we received interest from
103
104 CcnxPitEntryOutgoingFaceContainer::type::iterator outgoing =
Alexander Afanasyev36b45772012-07-10 16:57:42 -0700105 pitEntry->GetOutgoing ().find (metricFace.m_face);
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800106
Alexander Afanasyev36b45772012-07-10 16:57:42 -0700107 if (outgoing != pitEntry->GetOutgoing ().end () &&
108 outgoing->m_retxCount >= pitEntry->GetMaxRetxCount ())
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800109 {
Alexander Afanasyev36b45772012-07-10 16:57:42 -0700110 NS_LOG_DEBUG ("retxCount: " << outgoing->m_retxCount << ", maxRetxCount: " << pitEntry->GetMaxRetxCount ());
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800111 continue;
112 }
113
114 bool faceAvailable = metricFace.m_face->IsBelowLimit ();
115 if (!faceAvailable) // huh...
116 {
117 // let's try different green face
118 continue;
119 }
120
Alexander Afanasyev30f60e32012-07-10 14:21:16 -0700121 pitEntry->AddOutgoing (metricFace.m_face);
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800122
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -0800123 Ptr<Packet> packetToSend = packet->Copy ();
Ilya Moiseenko1a8be032012-01-18 12:51:09 -0800124
125 //transmission
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -0800126 metricFace.m_face->Send (packetToSend);
Alexander Afanasyevf377b332011-12-16 15:32:12 -0800127 m_transmittedInterestsTrace (header, metricFace.m_face);
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800128
129 propagatedCount++;
130 break; // propagate only one interest
131 }
132
133 return propagatedCount > 0;
134}
135
Alexander Afanasyev98256102011-08-14 01:00:02 -0700136} //namespace ns3