blob: c1dc44e8996dfd065de10b622a8bc2007b9937f4 [file] [log] [blame]
Alexander Afanasyev60a7b622014-12-20 17:04:07 -08001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (c) 2011-2015 Regents of the University of California.
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -07004 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -08005 * This file is part of ndnSIM. See AUTHORS for complete list of ndnSIM authors and
6 * contributors.
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -07007 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -08008 * ndnSIM is free software: you can redistribute it and/or modify it under the terms
9 * of the GNU General Public License as published by the Free Software Foundation,
10 * either version 3 of the License, or (at your option) any later version.
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070011 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -080012 * ndnSIM is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
13 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
14 * PURPOSE. See the GNU General Public License for more details.
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070015 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -080016 * You should have received a copy of the GNU General Public License along with
17 * ndnSIM, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
18 **/
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070019
Alexander Afanasyev0c395372014-12-20 15:54:02 -080020#include "ndn-consumer.hpp"
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -070021#include "ns3/ptr.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080022#include "ns3/log.h"
23#include "ns3/simulator.h"
24#include "ns3/packet.h"
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -070025#include "ns3/callback.h"
Alexander Afanasyeva46844b2011-11-21 19:13:26 -080026#include "ns3/string.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080027#include "ns3/boolean.h"
28#include "ns3/uinteger.h"
Alexander Afanasyeva89bc102013-07-16 10:17:31 -070029#include "ns3/integer.h"
Alexander Afanasyevb3e4b852011-12-23 15:58:20 -080030#include "ns3/double.h"
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080031
Mickey Sweatt89046c12014-11-16 20:32:27 -080032#include "utils/ndn-ns3-packet-tag.hpp"
Mickey Sweatt89046c12014-11-16 20:32:27 -080033#include "utils/ndn-rtt-mean-deviation.hpp"
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070034
Spyridon Mastorakis73df9f52016-12-07 14:34:13 -080035#include <ndn-cxx/lp/tags.hpp>
36
Mickey Sweatt89046c12014-11-16 20:32:27 -080037#include <boost/lexical_cast.hpp>
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080038#include <boost/ref.hpp>
Alexander Afanasyev781ea812011-12-15 22:42:09 -080039
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080040NS_LOG_COMPONENT_DEFINE("ndn.Consumer");
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070041
Alexander Afanasyev2b4c9472012-08-09 15:00:38 -070042namespace ns3 {
43namespace ndn {
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -080044
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080045NS_OBJECT_ENSURE_REGISTERED(Consumer);
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -080046
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070047TypeId
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080048Consumer::GetTypeId(void)
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070049{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080050 static TypeId tid =
51 TypeId("ns3::ndn::Consumer")
52 .SetGroupName("Ndn")
53 .SetParent<App>()
54 .AddAttribute("StartSeq", "Initial sequence number", IntegerValue(0),
55 MakeIntegerAccessor(&Consumer::m_seq), MakeIntegerChecker<int32_t>())
Alexander Afanasyev011b8592011-12-21 14:45:27 -080056
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080057 .AddAttribute("Prefix", "Name of the Interest", StringValue("/"),
58 MakeNameAccessor(&Consumer::m_interestName), MakeNameChecker())
59 .AddAttribute("LifeTime", "LifeTime for interest packet", StringValue("2s"),
60 MakeTimeAccessor(&Consumer::m_interestLifeTime), MakeTimeChecker())
Alexander Afanasyev781ea812011-12-15 22:42:09 -080061
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080062 .AddAttribute("RetxTimer",
63 "Timeout defining how frequent retransmission timeouts should be checked",
64 StringValue("50ms"),
65 MakeTimeAccessor(&Consumer::GetRetxTimer, &Consumer::SetRetxTimer),
66 MakeTimeChecker())
Alexander Afanasyev781ea812011-12-15 22:42:09 -080067
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080068 .AddTraceSource("LastRetransmittedInterestDataDelay",
69 "Delay between last retransmitted Interest and received Data",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070070 MakeTraceSourceAccessor(&Consumer::m_lastRetransmittedInterestDataDelay),
71 "ns3::ndn::Consumer::LastRetransmittedInterestDataDelayCallback")
Alexander Afanasyevedf24d92013-01-18 13:35:06 -080072
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080073 .AddTraceSource("FirstInterestDataDelay",
74 "Delay between first transmitted Interest and received Data",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070075 MakeTraceSourceAccessor(&Consumer::m_firstInterestDataDelay),
76 "ns3::ndn::Consumer::FirstInterestDataDelayCallback");
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070077
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080078 return tid;
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070079}
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -080080
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080081Consumer::Consumer()
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070082 : m_rand(CreateObject<UniformRandomVariable>())
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080083 , m_seq(0)
84 , m_seqMax(0) // don't request anything
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070085{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080086 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyev011b8592011-12-21 14:45:27 -080087
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080088 m_rtt = CreateObject<RttMeanDeviation>();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070089}
Alexander Afanasyev781ea812011-12-15 22:42:09 -080090
91void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080092Consumer::SetRetxTimer(Time retxTimer)
Alexander Afanasyev781ea812011-12-15 22:42:09 -080093{
94 m_retxTimer = retxTimer;
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080095 if (m_retxEvent.IsRunning()) {
96 // m_retxEvent.Cancel (); // cancel any scheduled cleanup events
97 Simulator::Remove(m_retxEvent); // slower, but better for memory
98 }
Alexander Afanasyev781ea812011-12-15 22:42:09 -080099
100 // schedule even with new timeout
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800101 m_retxEvent = Simulator::Schedule(m_retxTimer, &Consumer::CheckRetxTimeout, this);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800102}
103
104Time
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800105Consumer::GetRetxTimer() const
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800106{
107 return m_retxTimer;
108}
109
110void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800111Consumer::CheckRetxTimeout()
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800112{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800113 Time now = Simulator::Now();
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800114
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800115 Time rto = m_rtt->RetransmitTimeout();
Alexander Afanasyev8a237522013-02-01 13:33:38 -0800116 // NS_LOG_DEBUG ("Current RTO: " << rto.ToDouble (Time::S) << "s");
Alexander Afanasyevbdc0d982011-12-16 01:15:26 -0800117
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800118 while (!m_seqTimeouts.empty()) {
119 SeqTimeoutsContainer::index<i_timestamp>::type::iterator entry =
120 m_seqTimeouts.get<i_timestamp>().begin();
121 if (entry->time + rto <= now) // timeout expired?
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800122 {
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800123 uint32_t seqNo = entry->seq;
124 m_seqTimeouts.get<i_timestamp>().erase(entry);
125 OnTimeout(seqNo);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800126 }
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800127 else
128 break; // nothing else to do. All later packets need not be retransmitted
129 }
Alexander Afanasyev3183b5a2011-12-23 20:48:20 -0800130
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800131 m_retxEvent = Simulator::Schedule(m_retxTimer, &Consumer::CheckRetxTimeout, this);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800132}
133
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700134// Application Methods
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800135void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800136Consumer::StartApplication() // Called at time specified by Start
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700137{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800138 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700139
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800140 // do base stuff
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800141 App::StartApplication();
Alexander Afanasyev011b8592011-12-21 14:45:27 -0800142
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800143 ScheduleNextPacket();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700144}
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800145
146void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800147Consumer::StopApplication() // Called at time specified by Stop
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700148{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800149 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700150
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800151 // cancel periodic packet generation
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800152 Simulator::Cancel(m_sendEvent);
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700153
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800154 // cleanup base stuff
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800155 App::StopApplication();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700156}
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800157
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700158void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800159Consumer::SendPacket()
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700160{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800161 if (!m_active)
162 return;
Alexander Afanasyev3183b5a2011-12-23 20:48:20 -0800163
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800164 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800165
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800166 uint32_t seq = std::numeric_limits<uint32_t>::max(); // invalid
Alexander Afanasyev1ec705f2012-01-23 12:35:10 -0800167
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800168 while (m_retxSeqs.size()) {
169 seq = *m_retxSeqs.begin();
170 m_retxSeqs.erase(m_retxSeqs.begin());
171 break;
172 }
173
174 if (seq == std::numeric_limits<uint32_t>::max()) {
175 if (m_seqMax != std::numeric_limits<uint32_t>::max()) {
176 if (m_seq >= m_seqMax) {
177 return; // we are totally done
178 }
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800179 }
Alexander Afanasyev1ec705f2012-01-23 12:35:10 -0800180
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800181 seq = m_seq++;
182 }
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800183
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800184 //
Spyridon Mastorakis53e922f2014-10-17 17:29:26 -0700185 shared_ptr<Name> nameWithSequence = make_shared<Name>(m_interestName);
Mickey Sweatt89046c12014-11-16 20:32:27 -0800186 nameWithSequence->appendSequenceNumber(seq);
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800187 //
188
Mickey Sweatt89046c12014-11-16 20:32:27 -0800189 // shared_ptr<Interest> interest = make_shared<Interest> ();
Spyridon Mastorakis53e922f2014-10-17 17:29:26 -0700190 shared_ptr<Interest> interest = make_shared<Interest>();
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -0700191 interest->setNonce(m_rand->GetValue(0, std::numeric_limits<uint32_t>::max()));
Mickey Sweatt89046c12014-11-16 20:32:27 -0800192 interest->setName(*nameWithSequence);
Alexander Afanasyevdc3c3a32019-02-17 20:17:32 -0500193 interest->setCanBePrefix(false);
Mickey Sweatt89046c12014-11-16 20:32:27 -0800194 time::milliseconds interestLifeTime(m_interestLifeTime.GetMilliSeconds());
195 interest->setInterestLifetime(interestLifeTime);
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800196
Alexander Afanasyevfaa01f92013-07-10 18:34:31 -0700197 // NS_LOG_INFO ("Requesting Interest: \n" << *interest);
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800198 NS_LOG_INFO("> Interest for " << seq);
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700199
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800200 WillSendOutInterest(seq);
Alexander Afanasyeve1aa9b92012-10-11 10:40:02 -0700201
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800202 m_transmittedInterests(interest, this, m_face);
Alexander Afanasyev50ea1a32016-09-08 15:44:08 -0700203 m_appLink->onReceiveInterest(*interest);
Alexander Afanasyeve1aa9b92012-10-11 10:40:02 -0700204
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800205 ScheduleNextPacket();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700206}
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700207
Alexander Afanasyev011b8592011-12-21 14:45:27 -0800208///////////////////////////////////////////////////
209// Process incoming packets //
210///////////////////////////////////////////////////
211
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700212void
Spyridon Mastorakis53e922f2014-10-17 17:29:26 -0700213Consumer::OnData(shared_ptr<const Data> data)
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700214{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800215 if (!m_active)
216 return;
Alexander Afanasyev3183b5a2011-12-23 20:48:20 -0800217
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800218 App::OnData(data); // tracing inside
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800219
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800220 NS_LOG_FUNCTION(this << data);
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800221
Alexander Afanasyevfaa01f92013-07-10 18:34:31 -0700222 // NS_LOG_INFO ("Received content object: " << boost::cref(*data));
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800223
Mickey Sweatt89046c12014-11-16 20:32:27 -0800224 // This could be a problem......
225 uint32_t seq = data->getName().at(-1).toSequenceNumber();
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800226 NS_LOG_INFO("< DATA for " << seq);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800227
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -0700228 int hopCount = 0;
Spyridon Mastorakis73df9f52016-12-07 14:34:13 -0800229 auto hopCountTag = data->getTag<lp::HopCountTag>();
230 if (hopCountTag != nullptr) { // e.g., packet came from local node's cache
231 hopCount = *hopCountTag;
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800232 }
Spyridon Mastorakis73df9f52016-12-07 14:34:13 -0800233 NS_LOG_DEBUG("Hop count: " << hopCount);
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800234
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800235 SeqTimeoutsContainer::iterator entry = m_seqLastDelay.find(seq);
236 if (entry != m_seqLastDelay.end()) {
237 m_lastRetransmittedInterestDataDelay(this, seq, Simulator::Now() - entry->time, hopCount);
238 }
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800239
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800240 entry = m_seqFullDelay.find(seq);
241 if (entry != m_seqFullDelay.end()) {
Mickey Sweatt89046c12014-11-16 20:32:27 -0800242 m_firstInterestDataDelay(this, seq, Simulator::Now() - entry->time, m_seqRetxCounts[seq], hopCount);
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800243 }
Alexander Afanasyev400aae12013-01-19 13:27:52 -0800244
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800245 m_seqRetxCounts.erase(seq);
246 m_seqFullDelay.erase(seq);
247 m_seqLastDelay.erase(seq);
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800248
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800249 m_seqTimeouts.erase(seq);
250 m_retxSeqs.erase(seq);
Alexander Afanasyev359bfb72012-01-09 18:42:50 -0800251
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800252 m_rtt->AckSeq(SequenceNumber32(seq));
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800253}
254
255void
Spyridon Mastorakis7f2fd422016-12-07 14:33:59 -0800256Consumer::OnNack(shared_ptr<const lp::Nack> nack)
257{
258 /// tracing inside
259 App::OnNack(nack);
260
261 NS_LOG_INFO("NACK received for: " << nack->getInterest().getName()
262 << ", reason: " << nack->getReason());
263}
264
265void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800266Consumer::OnTimeout(uint32_t sequenceNumber)
Alexander Afanasyev359bfb72012-01-09 18:42:50 -0800267{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800268 NS_LOG_FUNCTION(sequenceNumber);
269 // std::cout << Simulator::Now () << ", TO: " << sequenceNumber << ", current RTO: " <<
270 // m_rtt->RetransmitTimeout ().ToDouble (Time::S) << "s\n";
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -0800271
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800272 m_rtt->IncreaseMultiplier(); // Double the next RTO
273 m_rtt->SentSeq(SequenceNumber32(sequenceNumber),
274 1); // make sure to disable RTT calculation for this sample
275 m_retxSeqs.insert(sequenceNumber);
276 ScheduleNextPacket();
Alexander Afanasyev359bfb72012-01-09 18:42:50 -0800277}
278
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700279void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800280Consumer::WillSendOutInterest(uint32_t sequenceNumber)
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700281{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800282 NS_LOG_DEBUG("Trying to add " << sequenceNumber << " with " << Simulator::Now() << ". already "
283 << m_seqTimeouts.size() << " items");
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700284
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800285 m_seqTimeouts.insert(SeqTimeout(sequenceNumber, Simulator::Now()));
286 m_seqFullDelay.insert(SeqTimeout(sequenceNumber, Simulator::Now()));
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700287
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800288 m_seqLastDelay.erase(sequenceNumber);
289 m_seqLastDelay.insert(SeqTimeout(sequenceNumber, Simulator::Now()));
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700290
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800291 m_seqRetxCounts[sequenceNumber]++;
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700292
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800293 m_rtt->SentSeq(SequenceNumber32(sequenceNumber), 1);
Alexander Afanasyev79b2fb32013-04-12 11:24:55 -0700294}
295
Alexander Afanasyev2b4c9472012-08-09 15:00:38 -0700296} // namespace ndn
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800297} // namespace ns3