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-2024, 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::fw {
30 
31 NFD_LOG_INIT(ProcessNackTraits);
32 
33 void
34 ProcessNackTraitsBase::processNack(const lp::Nack& nack, const Face& inFace,
35  const shared_ptr<pit::Entry>& pitEntry)
36 {
37  int nOutRecordsNotNacked = 0;
38  Face* lastFaceNotNacked = nullptr;
39  lp::NackReason leastSevereReason = lp::NackReason::NONE;
40  for (const pit::OutRecord& outR : pitEntry->getOutRecords()) {
41  const lp::NackHeader* inNack = outR.getIncomingNack();
42  if (inNack == nullptr) {
43  ++nOutRecordsNotNacked;
44  lastFaceNotNacked = &outR.getFace();
45  continue;
46  }
47 
48  if (isLessSevere(inNack->getReason(), leastSevereReason)) {
49  leastSevereReason = inNack->getReason();
50  }
51  }
52 
53  lp::NackHeader outNack;
54  outNack.setReason(leastSevereReason);
55 
56  if (nOutRecordsNotNacked == 1) {
57  BOOST_ASSERT(lastFaceNotNacked != nullptr);
58  auto inR = pitEntry->findInRecord(*lastFaceNotNacked);
59  if (inR != pitEntry->in_end()) {
60  // one out-record not Nacked, which is also a downstream
61  NFD_LOG_NACK_FROM(nack, inFace.getId(), "bidirectional nack-to=" << lastFaceNotNacked->getId()
62  << " out-nack=" << outNack.getReason());
63  this->sendNackForProcessNackTraits(pitEntry, *lastFaceNotNacked, outNack);
64  return;
65  }
66  }
67 
68  if (nOutRecordsNotNacked > 0) {
69  NFD_LOG_NACK_FROM(nack, inFace.getId(), "waiting=" << nOutRecordsNotNacked);
70  // continue waiting
71  return;
72  }
73 
74  NFD_LOG_NACK_FROM(nack, inFace.getId(), "nack-to=all out-nack=" << outNack.getReason());
75  this->sendNacksForProcessNackTraits(pitEntry, outNack);
76 }
77 
78 } // namespace nfd::fw
Generalization of a network interface.
Definition: face.hpp:118
FaceId getId() const noexcept
Returns the face ID.
Definition: face.hpp:195
void processNack(const lp::Nack &nack, const Face &inFace, const shared_ptr< pit::Entry > &pitEntry)
Contains information about an Interest toward an outgoing face.
Definition: pit-entry.hpp:129
#define NFD_LOG_INIT(name)
Definition: logger.hpp:31
#define NFD_LOG_NACK_FROM(nack, ingress, msg)
Logs the reception of nack on ingress, followed by msg, at DEBUG level.
Definition: strategy.hpp:555