30 #include <ndn-cxx/lp/tags.hpp> 31 #include <ndn-cxx/util/concepts.hpp> 40 static unique_ptr<Policy>
51 m_policy->setLimit(nMaxPackets);
57 if (!m_shouldAdmit || m_policy->getLimit() == 0) {
63 shared_ptr<lp::CachePolicyTag> tag = data.getTag<lp::CachePolicyTag>();
65 lp::CachePolicyType policy = tag->get().getPolicy();
66 if (policy == lp::CachePolicyType::NO_CACHE) {
72 bool isNewEntry =
false;
73 std::tie(it, isNewEntry) = m_table.emplace(data.shared_from_this(), isUnsolicited);
84 m_policy->afterRefresh(it);
87 m_policy->afterInsert(it);
94 BOOST_ASSERT(static_cast<bool>(cb));
96 iterator first = m_table.lower_bound(prefix);
98 if (prefix.size() > 0) {
99 last = m_table.lower_bound(prefix.getSuccessor());
103 while (first != last && nErased < limit) {
104 m_policy->beforeErase(first);
105 first = m_table.erase(first);
119 BOOST_ASSERT(static_cast<bool>(hitCallback));
120 BOOST_ASSERT(static_cast<bool>(missCallback));
122 if (!m_shouldServe || m_policy->getLimit() == 0) {
123 missCallback(interest);
126 const Name& prefix = interest.getName();
127 bool isRightmost = interest.getChildSelector() == 1;
128 NFD_LOG_DEBUG(
"find " << prefix << (isRightmost ?
" R" :
" L"));
130 iterator first = m_table.lower_bound(prefix);
132 if (prefix.size() > 0) {
133 last = m_table.lower_bound(prefix.getSuccessor());
138 match = this->findRightmost(interest, first, last);
141 match = this->findLeftmost(interest, first, last);
146 missCallback(interest);
150 m_policy->beforeUse(match);
151 hitCallback(interest, match->getData());
155 Cs::findLeftmost(
const Interest& interest,
iterator first,
iterator last)
const 157 return std::find_if(first, last, [&interest] (
const auto& entry) {
return entry.canSatisfy(interest); });
161 Cs::findRightmost(
const Interest& interest,
iterator first,
iterator last)
const 167 size_t interestNameLength = interest.getName().size();
168 for (
iterator right = last; right != first;) {
172 if (prev->getName().size() == interestNameLength) {
174 iterator matchExact = this->findRightmostAmongExact(interest, first, right);
175 return matchExact == right ? last : matchExact;
178 Name prefix = prev->getName().getPrefix(interestNameLength + 1);
179 iterator left = m_table.lower_bound(prefix);
183 iterator match = this->findLeftmost(interest, left, right);
184 if (match != right) {
193 Cs::findRightmostAmongExact(
const Interest& interest,
iterator first,
iterator last)
const 195 return find_last_if(first, last, [&interest] (
const auto& entry) {
return entry.canSatisfy(interest); });
210 BOOST_ASSERT(policy !=
nullptr);
211 BOOST_ASSERT(m_policy !=
nullptr);
212 size_t limit = m_policy->getLimit();
213 this->setPolicyImpl(std::move(policy));
214 m_policy->setLimit(limit);
218 Cs::setPolicyImpl(unique_ptr<Policy> policy)
221 m_policy = std::move(policy);
222 m_beforeEvictConnection = m_policy->beforeEvict.connect([
this] (
iterator it) {
226 m_policy->setCs(
this);
227 BOOST_ASSERT(m_policy->getCs() ==
this);
233 if (m_shouldAdmit == shouldAdmit) {
237 NFD_LOG_INFO((shouldAdmit ?
"Enabling" :
"Disabling") <<
" Data admittance");
243 if (m_shouldServe == shouldServe) {
247 NFD_LOG_INFO((shouldServe ?
"Enabling" :
"Disabling") <<
" Data serving");
void updateStaleTime()
refreshes stale time relative to current time
It find_last_if(It first, It last, Pred p)
finds the last element satisfying a predicate
static unique_ptr< Policy > makeDefaultPolicy()
bool shouldServe() const
get CS_ENABLE_SERVE flag
void enableAdmit(bool shouldAdmit)
set CS_ENABLE_ADMIT flag
std::function< void(size_t nErased)> AfterEraseCallback
static unique_ptr< Policy > create(const std::string &policyName)
NDN_CXX_ASSERT_FORWARD_ITERATOR(Cs::const_iterator)
Table::const_iterator iterator
void erase(const Name &prefix, size_t limit, const AfterEraseCallback &cb)
asynchronously erases entries under prefix
std::function< void(const Interest &)> MissCallback
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
void insert(const Data &data, bool isUnsolicited=false)
inserts a Data packet
boost::transform_iterator< EntryFromEntryImpl, iterator, const Entry & > const_iterator
ContentStore iterator (public API)
void enableServe(bool shouldServe)
set CS_ENABLE_SERVE flag
void setPolicy(unique_ptr< Policy > policy)
change replacement policy
an Entry in ContentStore implementation
#define NFD_LOG_INIT(name)
bool isUnsolicited() const
void find(const Interest &interest, const HitCallback &hitCallback, const MissCallback &missCallback) const
finds the best matching Data packet
Cs(size_t nMaxPackets=10)
std::function< void(const Interest &, const Data &)> HitCallback
bool shouldAdmit() const
get CS_ENABLE_ADMIT flag