blob: 3ed935530e4eb5a437e124a94ba250e6d7eba16a [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
Mickey Sweatt89046c12014-11-16 20:32:27 -080035#include <boost/lexical_cast.hpp>
Alexander Afanasyev19426ef2011-11-23 20:55:28 -080036#include <boost/ref.hpp>
Alexander Afanasyev781ea812011-12-15 22:42:09 -080037
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080038NS_LOG_COMPONENT_DEFINE("ndn.Consumer");
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070039
Alexander Afanasyev2b4c9472012-08-09 15:00:38 -070040namespace ns3 {
41namespace ndn {
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -080042
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080043NS_OBJECT_ENSURE_REGISTERED(Consumer);
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -080044
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070045TypeId
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080046Consumer::GetTypeId(void)
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070047{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080048 static TypeId tid =
49 TypeId("ns3::ndn::Consumer")
50 .SetGroupName("Ndn")
51 .SetParent<App>()
52 .AddAttribute("StartSeq", "Initial sequence number", IntegerValue(0),
53 MakeIntegerAccessor(&Consumer::m_seq), MakeIntegerChecker<int32_t>())
Alexander Afanasyev011b8592011-12-21 14:45:27 -080054
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080055 .AddAttribute("Prefix", "Name of the Interest", StringValue("/"),
56 MakeNameAccessor(&Consumer::m_interestName), MakeNameChecker())
57 .AddAttribute("LifeTime", "LifeTime for interest packet", StringValue("2s"),
58 MakeTimeAccessor(&Consumer::m_interestLifeTime), MakeTimeChecker())
Alexander Afanasyev781ea812011-12-15 22:42:09 -080059
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080060 .AddAttribute("RetxTimer",
61 "Timeout defining how frequent retransmission timeouts should be checked",
62 StringValue("50ms"),
63 MakeTimeAccessor(&Consumer::GetRetxTimer, &Consumer::SetRetxTimer),
64 MakeTimeChecker())
Alexander Afanasyev781ea812011-12-15 22:42:09 -080065
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080066 .AddTraceSource("LastRetransmittedInterestDataDelay",
67 "Delay between last retransmitted Interest and received Data",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070068 MakeTraceSourceAccessor(&Consumer::m_lastRetransmittedInterestDataDelay),
69 "ns3::ndn::Consumer::LastRetransmittedInterestDataDelayCallback")
Alexander Afanasyevedf24d92013-01-18 13:35:06 -080070
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080071 .AddTraceSource("FirstInterestDataDelay",
72 "Delay between first transmitted Interest and received Data",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070073 MakeTraceSourceAccessor(&Consumer::m_firstInterestDataDelay),
74 "ns3::ndn::Consumer::FirstInterestDataDelayCallback");
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070075
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -080076 return tid;
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070077}
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -080078
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080079Consumer::Consumer()
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070080 : m_rand(CreateObject<UniformRandomVariable>())
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080081 , m_seq(0)
82 , m_seqMax(0) // don't request anything
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070083{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080084 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyev011b8592011-12-21 14:45:27 -080085
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080086 m_rtt = CreateObject<RttMeanDeviation>();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -070087}
Alexander Afanasyev781ea812011-12-15 22:42:09 -080088
89void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080090Consumer::SetRetxTimer(Time retxTimer)
Alexander Afanasyev781ea812011-12-15 22:42:09 -080091{
92 m_retxTimer = retxTimer;
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080093 if (m_retxEvent.IsRunning()) {
94 // m_retxEvent.Cancel (); // cancel any scheduled cleanup events
95 Simulator::Remove(m_retxEvent); // slower, but better for memory
96 }
Alexander Afanasyev781ea812011-12-15 22:42:09 -080097
98 // schedule even with new timeout
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080099 m_retxEvent = Simulator::Schedule(m_retxTimer, &Consumer::CheckRetxTimeout, this);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800100}
101
102Time
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800103Consumer::GetRetxTimer() const
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800104{
105 return m_retxTimer;
106}
107
108void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800109Consumer::CheckRetxTimeout()
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800110{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800111 Time now = Simulator::Now();
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800112
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800113 Time rto = m_rtt->RetransmitTimeout();
Alexander Afanasyev8a237522013-02-01 13:33:38 -0800114 // NS_LOG_DEBUG ("Current RTO: " << rto.ToDouble (Time::S) << "s");
Alexander Afanasyevbdc0d982011-12-16 01:15:26 -0800115
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800116 while (!m_seqTimeouts.empty()) {
117 SeqTimeoutsContainer::index<i_timestamp>::type::iterator entry =
118 m_seqTimeouts.get<i_timestamp>().begin();
119 if (entry->time + rto <= now) // timeout expired?
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800120 {
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800121 uint32_t seqNo = entry->seq;
122 m_seqTimeouts.get<i_timestamp>().erase(entry);
123 OnTimeout(seqNo);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800124 }
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800125 else
126 break; // nothing else to do. All later packets need not be retransmitted
127 }
Alexander Afanasyev3183b5a2011-12-23 20:48:20 -0800128
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800129 m_retxEvent = Simulator::Schedule(m_retxTimer, &Consumer::CheckRetxTimeout, this);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800130}
131
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700132// Application Methods
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800133void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800134Consumer::StartApplication() // Called at time specified by Start
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700135{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800136 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700137
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800138 // do base stuff
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800139 App::StartApplication();
Alexander Afanasyev011b8592011-12-21 14:45:27 -0800140
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800141 ScheduleNextPacket();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700142}
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800143
144void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800145Consumer::StopApplication() // Called at time specified by Stop
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700146{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800147 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700148
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800149 // cancel periodic packet generation
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800150 Simulator::Cancel(m_sendEvent);
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700151
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800152 // cleanup base stuff
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800153 App::StopApplication();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700154}
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800155
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700156void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800157Consumer::SendPacket()
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700158{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800159 if (!m_active)
160 return;
Alexander Afanasyev3183b5a2011-12-23 20:48:20 -0800161
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800162 NS_LOG_FUNCTION_NOARGS();
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800163
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800164 uint32_t seq = std::numeric_limits<uint32_t>::max(); // invalid
Alexander Afanasyev1ec705f2012-01-23 12:35:10 -0800165
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800166 while (m_retxSeqs.size()) {
167 seq = *m_retxSeqs.begin();
168 m_retxSeqs.erase(m_retxSeqs.begin());
169 break;
170 }
171
172 if (seq == std::numeric_limits<uint32_t>::max()) {
173 if (m_seqMax != std::numeric_limits<uint32_t>::max()) {
174 if (m_seq >= m_seqMax) {
175 return; // we are totally done
176 }
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800177 }
Alexander Afanasyev1ec705f2012-01-23 12:35:10 -0800178
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800179 seq = m_seq++;
180 }
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800181
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800182 //
Spyridon Mastorakis53e922f2014-10-17 17:29:26 -0700183 shared_ptr<Name> nameWithSequence = make_shared<Name>(m_interestName);
Mickey Sweatt89046c12014-11-16 20:32:27 -0800184 nameWithSequence->appendSequenceNumber(seq);
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800185 //
186
Mickey Sweatt89046c12014-11-16 20:32:27 -0800187 // shared_ptr<Interest> interest = make_shared<Interest> ();
Spyridon Mastorakis53e922f2014-10-17 17:29:26 -0700188 shared_ptr<Interest> interest = make_shared<Interest>();
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -0700189 interest->setNonce(m_rand->GetValue(0, std::numeric_limits<uint32_t>::max()));
Mickey Sweatt89046c12014-11-16 20:32:27 -0800190 interest->setName(*nameWithSequence);
191 time::milliseconds interestLifeTime(m_interestLifeTime.GetMilliSeconds());
192 interest->setInterestLifetime(interestLifeTime);
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800193
Alexander Afanasyevfaa01f92013-07-10 18:34:31 -0700194 // NS_LOG_INFO ("Requesting Interest: \n" << *interest);
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800195 NS_LOG_INFO("> Interest for " << seq);
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700196
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800197 WillSendOutInterest(seq);
Alexander Afanasyeve1aa9b92012-10-11 10:40:02 -0700198
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800199 m_transmittedInterests(interest, this, m_face);
Alexander Afanasyev50ea1a32016-09-08 15:44:08 -0700200 m_appLink->onReceiveInterest(*interest);
Alexander Afanasyeve1aa9b92012-10-11 10:40:02 -0700201
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800202 ScheduleNextPacket();
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700203}
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700204
Alexander Afanasyev011b8592011-12-21 14:45:27 -0800205///////////////////////////////////////////////////
206// Process incoming packets //
207///////////////////////////////////////////////////
208
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700209void
Spyridon Mastorakis53e922f2014-10-17 17:29:26 -0700210Consumer::OnData(shared_ptr<const Data> data)
Ilya Moiseenko8196d2e2011-08-29 13:03:22 -0700211{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800212 if (!m_active)
213 return;
Alexander Afanasyev3183b5a2011-12-23 20:48:20 -0800214
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800215 App::OnData(data); // tracing inside
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800216
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800217 NS_LOG_FUNCTION(this << data);
Alexander Afanasyev09c7deb2011-11-23 14:50:10 -0800218
Alexander Afanasyevfaa01f92013-07-10 18:34:31 -0700219 // NS_LOG_INFO ("Received content object: " << boost::cref(*data));
Alexander Afanasyev3a3ce1a2013-01-31 11:26:11 -0800220
Mickey Sweatt89046c12014-11-16 20:32:27 -0800221 // This could be a problem......
222 uint32_t seq = data->getName().at(-1).toSequenceNumber();
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800223 NS_LOG_INFO("< DATA for " << seq);
Alexander Afanasyev781ea812011-12-15 22:42:09 -0800224
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -0700225 int hopCount = 0;
Mickey Sweatt89046c12014-11-16 20:32:27 -0800226 auto ns3PacketTag = data->getTag<Ns3PacketTag>();
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -0700227 if (ns3PacketTag != nullptr) { // e.g., packet came from local node's cache
Mickey Sweatt89046c12014-11-16 20:32:27 -0800228 FwHopCountTag hopCountTag;
229 if (ns3PacketTag->getPacket()->PeekPacketTag(hopCountTag)) {
230 hopCount = hopCountTag.Get();
231 NS_LOG_DEBUG("Hop count: " << hopCount);
232 }
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800233 }
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