process-nack-traits.cpp
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2 /*
3  * Copyright (c) 2014-2019, Regents of the University of California,
4  * Arizona Board of Regents,
5  * Colorado State University,
6  * University Pierre & Marie Curie, Sorbonne University,
7  * Washington University in St. Louis,
8  * Beijing Institute of Technology,
9  * The University of Memphis.
10  *
11  * This file is part of NFD (Named Data Networking Forwarding Daemon).
12  * See AUTHORS.md for complete list of NFD authors and contributors.
13  *
14  * NFD is free software: you can redistribute it and/or modify it under the terms
15  * of the GNU General Public License as published by the Free Software Foundation,
16  * either version 3 of the License, or (at your option) any later version.
17  *
18  * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
19  * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
20  * PURPOSE. See the GNU General Public License for more details.
21  *
22  * You should have received a copy of the GNU General Public License along with
23  * NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
24  */
25 
26 #include "process-nack-traits.hpp"
27 #include "common/logger.hpp"
28 
29 namespace nfd {
30 namespace fw {
31 
32 NFD_LOG_INIT(ProcessNackTraits);
33 
34 void
35 ProcessNackTraitsBase::processNack(const Face& inFace, const lp::Nack& nack,
36  const shared_ptr<pit::Entry>& pitEntry)
37 {
38  int nOutRecordsNotNacked = 0;
39  Face* lastFaceNotNacked = nullptr;
40  lp::NackReason leastSevereReason = lp::NackReason::NONE;
41  for (const pit::OutRecord& outR : pitEntry->getOutRecords()) {
42  const lp::NackHeader* inNack = outR.getIncomingNack();
43  if (inNack == nullptr) {
44  ++nOutRecordsNotNacked;
45  lastFaceNotNacked = &outR.getFace();
46  continue;
47  }
48 
49  if (isLessSevere(inNack->getReason(), leastSevereReason)) {
50  leastSevereReason = inNack->getReason();
51  }
52  }
53 
54  lp::NackHeader outNack;
55  outNack.setReason(leastSevereReason);
56 
57  if (nOutRecordsNotNacked == 1) {
58  BOOST_ASSERT(lastFaceNotNacked != nullptr);
59  pit::InRecordCollection::iterator inR = pitEntry->getInRecord(*lastFaceNotNacked);
60  if (inR != pitEntry->in_end()) {
61  // one out-record not Nacked, which is also a downstream
62  NFD_LOG_DEBUG(nack.getInterest() << " nack-from=" << inFace.getId() <<
63  " nack=" << nack.getReason() <<
64  " nack-to(bidirectional)=" << lastFaceNotNacked->getId() <<
65  " out-nack=" << outNack.getReason());
66  this->sendNackForProcessNackTraits(pitEntry, *lastFaceNotNacked, outNack);
67  return;
68  }
69  }
70 
71  if (nOutRecordsNotNacked > 0) {
72  NFD_LOG_DEBUG(nack.getInterest() << " nack-from=" << inFace.getId() <<
73  " nack=" << nack.getReason() <<
74  " waiting=" << nOutRecordsNotNacked);
75  // continue waiting
76  return;
77  }
78 
79  NFD_LOG_DEBUG(nack.getInterest() << " nack-from=" << inFace.getId() <<
80  " nack=" << nack.getReason() <<
81  " nack-to=all out-nack=" << outNack.getReason());
82  this->sendNacksForProcessNackTraits(pitEntry, outNack);
83 }
84 
85 } // namespace fw
86 } // namespace nfd
Contains information about an Interest toward an outgoing face.
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
Definition: algorithm.hpp:32
generalization of a network interface
Definition: face.hpp:54
FaceId getId() const
Definition: face.hpp:239
#define NFD_LOG_DEBUG
Definition: logger.hpp:38
#define NFD_LOG_INIT(name)
Definition: logger.hpp:31
void processNack(const Face &inFace, const lp::Nack &nack, const shared_ptr< pit::Entry > &pitEntry)