blob: 2522928e7923c64ec7363cb92e1799660067d064 [file] [log] [blame]
akmhoque3d06e792014-05-27 16:23:20 -05001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (c) 2014 University of Memphis,
4 * Regents of the University of California
5 *
6 * This file is part of NLSR (Named-data Link State Routing).
7 * See AUTHORS.md for complete list of NLSR authors and contributors.
8 *
9 * NLSR is free software: you can redistribute it and/or modify it under the terms
10 * of the GNU General Public License as published by the Free Software Foundation,
11 * either version 3 of the License, or (at your option) any later version.
12 *
13 * NLSR is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
14 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
15 * PURPOSE. See the GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License along with
18 * NLSR, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
19 *
20 * \author A K M Mahmudul Hoque <ahoque1@memphis.edu>
21 *
22 **/
akmhoque53353462014-04-22 08:43:45 -050023#ifndef NLSR_FIB_HPP
24#define NLSR_FIB_HPP
25
26#include <list>
akmhoquefdbddb12014-05-02 18:35:19 -050027#include <boost/cstdint.hpp>
28
29#include <ndn-cxx/management/nfd-controller.hpp>
akmhoquec7a79b22014-05-26 08:06:19 -050030#include <ndn-cxx/util/time.hpp>
akmhoque157b0a42014-05-13 00:26:37 -050031#include "face-map.hpp"
akmhoque53353462014-04-22 08:43:45 -050032#include "fib-entry.hpp"
33
34namespace nlsr {
35
akmhoquec04e7272014-07-02 11:00:14 -050036typedef ndn::function<void(const ndn::nfd::ControlParameters&)> CommandSucceedCallback;
37typedef ndn::function<void(uint32_t/*code*/,const std::string&/*reason*/)> CommandFailCallback;
38
akmhoque53353462014-04-22 08:43:45 -050039class Nlsr;
40
akmhoque53353462014-04-22 08:43:45 -050041
42class Fib
43{
44public:
akmhoque31d1d4b2014-05-05 22:08:14 -050045 Fib(Nlsr& nlsr, ndn::Face& face)
46 : m_nlsr(nlsr)
47 , m_table()
akmhoque53353462014-04-22 08:43:45 -050048 , m_refreshTime(0)
akmhoquefdbddb12014-05-02 18:35:19 -050049 , m_controller(face)
akmhoque157b0a42014-05-13 00:26:37 -050050 , m_faceMap()
akmhoquefdbddb12014-05-02 18:35:19 -050051 {
52 }
53 ~Fib()
akmhoque53353462014-04-22 08:43:45 -050054 {
55 }
56
57 void
akmhoque31d1d4b2014-05-05 22:08:14 -050058 remove(const ndn::Name& name);
akmhoque53353462014-04-22 08:43:45 -050059
60 void
akmhoque31d1d4b2014-05-05 22:08:14 -050061 update(const ndn::Name& name, NexthopList& nextHopList);
akmhoque53353462014-04-22 08:43:45 -050062
63 void
akmhoque31d1d4b2014-05-05 22:08:14 -050064 clean();
akmhoque53353462014-04-22 08:43:45 -050065
66 void
akmhoquefdbddb12014-05-02 18:35:19 -050067 setEntryRefreshTime(int32_t fert)
akmhoque53353462014-04-22 08:43:45 -050068 {
69 m_refreshTime = fert;
70 }
71
akmhoque53353462014-04-22 08:43:45 -050072private:
akmhoque393d4ff2014-07-16 14:27:03 -050073 bool
74 isPrefixUpdatable(const ndn::Name& name);
75
akmhoque53353462014-04-22 08:43:45 -050076 void
akmhoque157b0a42014-05-13 00:26:37 -050077 removeHop(NexthopList& nl, const std::string& doNotRemoveHopFaceUri,
akmhoque31d1d4b2014-05-05 22:08:14 -050078 const ndn::Name& name);
akmhoque53353462014-04-22 08:43:45 -050079
80 int
akmhoquefdbddb12014-05-02 18:35:19 -050081 getNumberOfFacesForName(NexthopList& nextHopList, uint32_t maxFacesPerPrefix);
akmhoque53353462014-04-22 08:43:45 -050082
83 ndn::EventId
akmhoque31d1d4b2014-05-05 22:08:14 -050084 scheduleEntryRefreshing(const ndn::Name& name, int32_t feSeqNum,
akmhoquec7a79b22014-05-26 08:06:19 -050085 const ndn::time::seconds& expTime);
akmhoque53353462014-04-22 08:43:45 -050086
87 void
akmhoque31d1d4b2014-05-05 22:08:14 -050088 cancelScheduledExpiringEvent(ndn::EventId eid);
akmhoquefdbddb12014-05-02 18:35:19 -050089
90 void
akmhoque31d1d4b2014-05-05 22:08:14 -050091 refreshEntry(const ndn::Name& name, int32_t feSeqNum);
akmhoquefdbddb12014-05-02 18:35:19 -050092
akmhoque157b0a42014-05-13 00:26:37 -050093public:
akmhoquefdbddb12014-05-02 18:35:19 -050094 void
akmhoque157b0a42014-05-13 00:26:37 -050095 registerPrefix(const ndn::Name& namePrefix, const std::string& faceUri,
akmhoquebf11c5f2014-07-21 14:49:47 -050096 uint64_t faceCost,
akmhoque060d3022014-08-12 13:35:06 -050097 const ndn::time::milliseconds& timeout,
98 uint64_t flags, uint8_t times);
akmhoquefdbddb12014-05-02 18:35:19 -050099
100 void
akmhoquec04e7272014-07-02 11:00:14 -0500101 registerPrefix(const ndn::Name& namePrefix,
102 const std::string& faceUri,
akmhoquebf11c5f2014-07-21 14:49:47 -0500103 uint64_t faceCost,
104 const ndn::time::milliseconds& timeout,
akmhoque060d3022014-08-12 13:35:06 -0500105 uint64_t flags,
akmhoque102aea42014-08-04 10:22:12 -0500106 uint8_t times,
akmhoquec04e7272014-07-02 11:00:14 -0500107 const CommandSucceedCallback& onSuccess,
108 const CommandFailCallback& onFailure);
akmhoque060d3022014-08-12 13:35:06 -0500109
akmhoque157b0a42014-05-13 00:26:37 -0500110 void
akmhoque393d4ff2014-07-16 14:27:03 -0500111 setStrategy(const ndn::Name& name, const std::string& strategy, uint32_t count);
akmhoque157b0a42014-05-13 00:26:37 -0500112
akmhoque674b0b12014-05-20 14:33:28 -0500113 void
114 writeLog();
115
akmhoquec04e7272014-07-02 11:00:14 -0500116 void
117 destroyFace(const std::string& faceUri,
118 const CommandSucceedCallback& onSuccess,
119 const CommandFailCallback& onFailure);
120
akmhoque157b0a42014-05-13 00:26:37 -0500121private:
122 void
akmhoquec04e7272014-07-02 11:00:14 -0500123 createFace(const std::string& faceUri,
124 const CommandSucceedCallback& onSuccess,
125 const CommandFailCallback& onFailure);
126
127 void
akmhoque060d3022014-08-12 13:35:06 -0500128 registerPrefixInNfd(ndn::nfd::ControlParameters& parameters,
akmhoque102aea42014-08-04 10:22:12 -0500129 const std::string& faceUri,
130 uint8_t times);
akmhoquec04e7272014-07-02 11:00:14 -0500131
132 void
133 registerPrefixInNfd(const ndn::nfd::ControlParameters& faceCreateResult,
akmhoque060d3022014-08-12 13:35:06 -0500134 const ndn::nfd::ControlParameters& parameters,
akmhoque102aea42014-08-04 10:22:12 -0500135 uint8_t times,
akmhoquec04e7272014-07-02 11:00:14 -0500136 const CommandSucceedCallback& onSuccess,
137 const CommandFailCallback& onFailure);
138
139 void
140 destroyFaceInNfd(const ndn::nfd::ControlParameters& faceDestroyResult,
141 const CommandSucceedCallback& onSuccess,
142 const CommandFailCallback& onFailure);
143
144 void
akmhoque157b0a42014-05-13 00:26:37 -0500145 unregisterPrefix(const ndn::Name& namePrefix, const std::string& faceUri);
146
147 void
148 onRegistration(const ndn::nfd::ControlParameters& commandSuccessResult,
149 const std::string& message, const std::string& faceUri);
akmhoque31d1d4b2014-05-05 22:08:14 -0500150
akmhoquefdbddb12014-05-02 18:35:19 -0500151 void
akmhoqueb5b3b4f2014-07-23 16:36:51 -0500152 onUnregistration(const ndn::nfd::ControlParameters& commandSuccessResult,
153 const std::string& message);
akmhoquefdbddb12014-05-02 18:35:19 -0500154
155 void
akmhoque102aea42014-08-04 10:22:12 -0500156 onRegistrationFailure(uint32_t code, const std::string& error,
157 const std::string& message,
akmhoque060d3022014-08-12 13:35:06 -0500158 const ndn::nfd::ControlParameters& parameters,
159 const std::string& faceUri,
akmhoque102aea42014-08-04 10:22:12 -0500160 uint8_t times);
161
162 void
163 onUnregistrationFailure(uint32_t code, const std::string& error,
164 const std::string& message);
akmhoque53353462014-04-22 08:43:45 -0500165
akmhoque393d4ff2014-07-16 14:27:03 -0500166 void
167 onSetStrategySuccess(const ndn::nfd::ControlParameters& commandSuccessResult,
168 const std::string& message);
169
170 void
171 onSetStrategyFailure(uint32_t code, const std::string& error,
172 const ndn::nfd::ControlParameters& parameters,
173 uint32_t count,
174 const std::string& message);
175
akmhoque53353462014-04-22 08:43:45 -0500176private:
akmhoque31d1d4b2014-05-05 22:08:14 -0500177 Nlsr& m_nlsr;
akmhoque53353462014-04-22 08:43:45 -0500178 std::list<FibEntry> m_table;
akmhoquefdbddb12014-05-02 18:35:19 -0500179 int32_t m_refreshTime;
180 ndn::nfd::Controller m_controller;
akmhoque157b0a42014-05-13 00:26:37 -0500181 FaceMap m_faceMap;
akmhoque393d4ff2014-07-16 14:27:03 -0500182
183 static const uint64_t GRACE_PERIOD;
akmhoque53353462014-04-22 08:43:45 -0500184};
185
186}//namespace nlsr
187#endif //NLSR_FIB_HPP