blob: 5448006777de630238c0d40443fbc089d6b50b69 [file] [log] [blame]
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -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>
19 */
20
21#include "ccnx-flooding-strategy.h"
Alexander Afanasyevf377b332011-12-16 15:32:12 -080022#include "ccnx-interest-header.h"
23#include "ccnx-pit.h"
24#include "ccnx-pit-entry.h"
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -080025#include "ccnx-path-stretch-tag.h"
Alexander Afanasyevf377b332011-12-16 15:32:12 -080026
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070027#include "ns3/assert.h"
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080028#include "ns3/log.h"
Alexander Afanasyeve67a97f2011-11-29 14:28:59 -080029#include "ns3/simulator.h"
Alexander Afanasyevbed75692012-04-06 13:01:25 -070030#include "ns3/boolean.h"
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070031
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080032#include <boost/ref.hpp>
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080033#include <boost/foreach.hpp>
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080034#include <boost/lambda/lambda.hpp>
35#include <boost/lambda/bind.hpp>
36namespace ll = boost::lambda;
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070037
38NS_LOG_COMPONENT_DEFINE ("CcnxFloodingStrategy");
39
40namespace ns3
41{
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080042
43using namespace __ccnx_private;
44
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070045NS_OBJECT_ENSURE_REGISTERED (CcnxFloodingStrategy);
46
47TypeId CcnxFloodingStrategy::GetTypeId (void)
48{
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080049 static TypeId tid = TypeId ("ns3::CcnxFloodingStrategy")
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070050 .SetGroupName ("Ccnx")
Alexander Afanasyev11453142011-11-25 16:13:33 -080051 .SetParent <CcnxForwardingStrategy> ()
52 .AddConstructor <CcnxFloodingStrategy> ()
Alexander Afanasyevbed75692012-04-06 13:01:25 -070053
54 .AddAttribute ("SmartFlooding",
55 "If true then if a GREEN face exists, Interests will be sent only to such face (!only to one green face!)",
56 BooleanValue (false),
57 MakeBooleanAccessor (&CcnxFloodingStrategy::m_smartFlooding),
58 MakeBooleanChecker ())
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070059 ;
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080060 return tid;
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070061}
62
63CcnxFloodingStrategy::CcnxFloodingStrategy ()
64{
65}
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080066
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070067bool
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080068CcnxFloodingStrategy::PropagateInterest (const CcnxPitEntry &pitEntry,
69 const Ptr<CcnxFace> &incomingFace,
70 Ptr<CcnxInterestHeader> &header,
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080071 const Ptr<const Packet> &packet)
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070072{
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080073 NS_LOG_FUNCTION (this);
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080074
Alexander Afanasyevbed75692012-04-06 13:01:25 -070075 if (m_smartFlooding)
76 {
77 // Try to work out with just green faces
78 bool greenOk = PropagateInterestViaGreen (pitEntry, incomingFace, header, packet);
79 if (greenOk)
80 return true;
81
82 // boo... :(
83 }
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080084
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080085 int propagatedCount = 0;
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080086
87 BOOST_FOREACH (const CcnxFibFaceMetric &metricFace, pitEntry.m_fibEntry.m_faces.get<i_metric> ())
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -070088 {
Alexander Afanasyev23d2b542011-12-07 18:54:46 -080089 NS_LOG_DEBUG ("Trying " << boost::cref(metricFace));
Alexander Afanasyevbed75692012-04-06 13:01:25 -070090 if (metricFace.m_status == CcnxFibFaceMetric::NDN_FIB_RED) // all non-read faces are in the front of the list
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080091 break;
92
Alexander Afanasyev5a595072011-11-25 14:49:07 -080093 if (metricFace.m_face == incomingFace)
Alexander Afanasyev23d2b542011-12-07 18:54:46 -080094 {
95 NS_LOG_DEBUG ("continue (same as incoming)");
96 continue; // same face as incoming, don't forward
97 }
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080098
Alexander Afanasyev5a595072011-11-25 14:49:07 -080099 if (pitEntry.m_incoming.find (metricFace.m_face) != pitEntry.m_incoming.end ())
Alexander Afanasyev23d2b542011-12-07 18:54:46 -0800100 {
101 NS_LOG_DEBUG ("continue (same as previous incoming)");
102 continue; // don't forward to face that we received interest from
103 }
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800104
105 CcnxPitEntryOutgoingFaceContainer::type::iterator outgoing =
106 pitEntry.m_outgoing.find (metricFace.m_face);
Alexander Afanasyev5a595072011-11-25 14:49:07 -0800107
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800108 if (outgoing != pitEntry.m_outgoing.end () &&
109 outgoing->m_retxCount >= pitEntry.m_maxRetxCount)
110 {
Alexander Afanasyev23d2b542011-12-07 18:54:46 -0800111 NS_LOG_DEBUG ("continue (same as previous outgoing)");
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800112 continue; // already forwarded before during this retransmission cycle
113 }
Alexander Afanasyev23d2b542011-12-07 18:54:46 -0800114 NS_LOG_DEBUG ("max retx count: " << pitEntry.m_maxRetxCount);
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -0800115
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800116 bool faceAvailable = metricFace.m_face->IsBelowLimit ();
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -0800117 if (!faceAvailable) // huh...
Alexander Afanasyeve67a97f2011-11-29 14:28:59 -0800118 {
Alexander Afanasyeve67a97f2011-11-29 14:28:59 -0800119 continue;
120 }
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800121
122 m_pit->modify (m_pit->iterator_to (pitEntry),
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800123 ll::bind(&CcnxPitEntry::AddOutgoing, ll::_1, metricFace.m_face));
124
Alexander Afanasyeve67a97f2011-11-29 14:28:59 -0800125 // if (Simulator::GetContext ()==2)
126 // {
127 // NS_LOG_ERROR ("new outgoing entry for " << boost::cref (*metricFace.m_face));
128 // NS_LOG_ERROR ("size: " << pitEntry.m_outgoing.size ());
129 // }
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800130
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -0800131 Ptr<Packet> packetToSend = packet->Copy ();
Ilya Moiseenko1a8be032012-01-18 12:51:09 -0800132
Ilya Moiseenko1a8be032012-01-18 12:51:09 -0800133 //transmission
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -0800134 metricFace.m_face->Send (packetToSend);
Alexander Afanasyevf377b332011-12-16 15:32:12 -0800135 m_transmittedInterestsTrace (header, metricFace.m_face);
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800136
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -0800137 propagatedCount++;
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -0700138 }
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -0800139
Alexander Afanasyev19426ef2011-11-23 20:55:28 -0800140 NS_LOG_INFO ("Propagated to " << propagatedCount << " faces");
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -0800141 return propagatedCount > 0;
Ilya Moiseenko25f7d4d2011-09-29 18:41:06 -0700142}
143
144} //namespace ns3