blob: 80135fdcf6332d851ff675e6fa43dd42cdf810e5 [file] [log] [blame]
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -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: Alexander Afanasyev <alexander.afanasyev@ucla.edu>
19 */
20
21#include "ccnx-pit-entry.h"
22#include "ccnx-name-components.h"
23#include "ccnx-fib.h"
24
Alexander Afanasyev78cf0c92011-09-01 19:57:14 -070025#include "ns3/simulator.h"
Alexander Afanasyev5a595072011-11-25 14:49:07 -080026#include "ns3/log.h"
27
28#include <boost/lambda/lambda.hpp>
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080029#include <boost/lambda/bind.hpp>
Alexander Afanasyev5a595072011-11-25 14:49:07 -080030namespace ll = boost::lambda;
31
32NS_LOG_COMPONENT_DEFINE ("CcnxPitEntry");
Alexander Afanasyev78cf0c92011-09-01 19:57:14 -070033
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -070034namespace ns3
35{
36
Alexander Afanasyeva46844b2011-11-21 19:13:26 -080037CcnxPitEntry::CcnxPitEntry (Ptr<CcnxNameComponents> prefix,
38 const Time &expireTime,
39 const CcnxFibEntry &fibEntry)
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -070040 : m_prefix (prefix)
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -070041 , m_fibEntry (fibEntry)
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080042 , m_expireTime (Simulator::Now () + expireTime)
43 // , m_timerExpired (false)
44 // , m_counterExpirations (0)
45 , m_maxRetxCount (0)
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -070046{
47}
48
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080049void
50CcnxPitEntry::UpdateLifetime (const Time &offsetTime)
51{
52 Time newExpireTime = Simulator::Now () + offsetTime;
53 if (newExpireTime > m_expireTime)
54 m_expireTime = newExpireTime;
55}
56
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080057CcnxPitEntryIncomingFaceContainer::type::iterator
58CcnxPitEntry::AddIncoming (Ptr<CcnxFace> face)
59{
60 std::pair<CcnxPitEntryIncomingFaceContainer::type::iterator,bool> ret =
61 m_incoming.insert (CcnxPitEntryIncomingFace (face));
Alexander Afanasyeva46844b2011-11-21 19:13:26 -080062
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080063 NS_ASSERT_MSG (ret.second, "Something is wrong");
Alexander Afanasyeva46844b2011-11-21 19:13:26 -080064
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080065 return ret.first;
66}
67
Alexander Afanasyev9d313d42011-11-25 13:36:15 -080068void
69CcnxPitEntry::RemoveIncoming (Ptr<CcnxFace> face)
70{
71 m_incoming.erase (face);
72}
73
74
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080075CcnxPitEntryOutgoingFaceContainer::type::iterator
76CcnxPitEntry::AddOutgoing (Ptr<CcnxFace> face)
77{
78 std::pair<CcnxPitEntryOutgoingFaceContainer::type::iterator,bool> ret =
79 m_outgoing.insert (CcnxPitEntryOutgoingFace (face));
80
Alexander Afanasyev0a61c342011-12-06 12:48:55 -080081 if (!ret.second)
82 { // outgoing face already exists
83 m_outgoing.modify (ret.first,
84 ll::bind (&CcnxPitEntryOutgoingFace::UpdateOnRetransmit, ll::_1));
85 }
Alexander Afanasyeva5bbe0e2011-11-22 17:28:39 -080086
87 return ret.first;
88}
89
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080090void
91CcnxPitEntry::RemoveAllReferencesToFace (Ptr<CcnxFace> face)
92{
93 CcnxPitEntryIncomingFaceContainer::type::iterator incoming =
94 m_incoming.find (face);
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -070095
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080096 if (incoming != m_incoming.end ())
97 m_incoming.erase (incoming);
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -070098
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080099 CcnxPitEntryOutgoingFaceContainer::type::iterator outgoing =
100 m_outgoing.find (face);
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -0700101
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800102 if (outgoing != m_outgoing.end ())
103 m_outgoing.erase (outgoing);
104}
Alexander Afanasyeva98cdd22011-08-29 17:32:37 -0700105
Alexander Afanasyev5a595072011-11-25 14:49:07 -0800106void
107CcnxPitEntry::SetWaitingInVain (CcnxPitEntryOutgoingFaceContainer::type::iterator face)
108{
Alexander Afanasyev23d2b542011-12-07 18:54:46 -0800109 NS_LOG_DEBUG (boost::cref (*face->m_face));
110
Alexander Afanasyev5a595072011-11-25 14:49:07 -0800111 m_outgoing.modify (face,
112 (&ll::_1)->*&CcnxPitEntryOutgoingFace::m_waitingInVain = true);
113}
114
115bool
116CcnxPitEntry::AreAllOutgoingInVain () const
117{
Alexander Afanasyev23d2b542011-12-07 18:54:46 -0800118 NS_LOG_DEBUG (m_outgoing.size ());
119
Alexander Afanasyev5a595072011-11-25 14:49:07 -0800120 bool inVain = true;
121 std::for_each (m_outgoing.begin (), m_outgoing.end (),
122 ll::var(inVain) &= (&ll::_1)->*&CcnxPitEntryOutgoingFace::m_waitingInVain);
123
124 NS_LOG_DEBUG ("inVain " << inVain);
125 return inVain;
126}
127
Alexander Afanasyeva7a2b8b2011-11-28 18:19:09 -0800128bool
129CcnxPitEntry::AreTherePromisingOutgoingFacesExcept (Ptr<CcnxFace> face) const
130{
131 bool inVain = true;
132 std::for_each (m_outgoing.begin (), m_outgoing.end (),
133 ll::var(inVain) &=
134 ((&ll::_1)->*&CcnxPitEntryOutgoingFace::m_face == face ||
135 (&ll::_1)->*&CcnxPitEntryOutgoingFace::m_waitingInVain));
136
137 return !inVain;
138}
Alexander Afanasyev5a595072011-11-25 14:49:07 -0800139
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800140void
141CcnxPitEntry::IncreaseAllowedRetxCount ()
142{
Alexander Afanasyev120bf312011-12-19 01:24:47 -0800143 NS_LOG_ERROR (this);
Alexander Afanasyev0a61c342011-12-06 12:48:55 -0800144 m_maxRetxCount++;
145}
146
Alexander Afanasyeva95b7392012-03-09 10:54:10 -0800147std::ostream& operator<< (std::ostream& os, const CcnxPitEntry &entry)
148{
149 os << "Prefix: " << *entry.m_prefix << "\n";
150 os << "In: ";
151 bool first = true;
152 BOOST_FOREACH (const CcnxPitEntryIncomingFace &face, entry.m_incoming)
153 {
154 if (!first)
155 os << ",";
156 else
157 first = false;
158
159 os << *face.m_face;
160 }
161
162 os << "\nOut: ";
163 first = true;
164 BOOST_FOREACH (const CcnxPitEntryOutgoingFace &face, entry.m_outgoing)
165 {
166 if (!first)
167 os << ",";
168 else
169 first = false;
170
171 os << *face.m_face;
172 }
173
174 return os;
175}
176
177
Alexander Afanasyev5a595072011-11-25 14:49:07 -0800178}