| /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ |
| /* |
| * Copyright (c) 2013-2017 Regents of the University of California. |
| * |
| * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions). |
| * |
| * ndn-cxx library is free software: you can redistribute it and/or modify it under the |
| * terms of the GNU Lesser General Public License as published by the Free Software |
| * Foundation, either version 3 of the License, or (at your option) any later version. |
| * |
| * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY |
| * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A |
| * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. |
| * |
| * You should have received copies of the GNU General Public License and GNU Lesser |
| * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see |
| * <http://www.gnu.org/licenses/>. |
| * |
| * See AUTHORS.md for complete list of ndn-cxx authors and contributors. |
| */ |
| |
| #ifndef NDN_INTEREST_HPP |
| #define NDN_INTEREST_HPP |
| |
| #include "delegation-list.hpp" |
| #include "link.hpp" |
| #include "name.hpp" |
| #include "selectors.hpp" |
| #include "tag-host.hpp" |
| #include "util/time.hpp" |
| |
| namespace ndn { |
| |
| class Data; |
| |
| /** @var const unspecified_duration_type DEFAULT_INTEREST_LIFETIME; |
| * @brief default value for InterestLifetime |
| */ |
| const time::milliseconds DEFAULT_INTEREST_LIFETIME = time::milliseconds(4000); |
| |
| /** @brief represents an Interest packet |
| */ |
| class Interest : public TagHost, public enable_shared_from_this<Interest> |
| { |
| public: |
| class Error : public tlv::Error |
| { |
| public: |
| explicit |
| Error(const std::string& what) |
| : tlv::Error(what) |
| { |
| } |
| }; |
| |
| /** @brief Create a new Interest with the given name and interest lifetime |
| * @throw std::invalid_argument InterestLifetime is negative |
| * @warning In certain contexts that use Interest::shared_from_this(), Interest must be created |
| * using `make_shared`. Otherwise, .shared_from_this() will trigger undefined behavior. |
| */ |
| explicit |
| Interest(const Name& name = Name(), time::milliseconds interestLifetime = DEFAULT_INTEREST_LIFETIME); |
| |
| /** @brief Create from wire encoding |
| * @warning In certain contexts that use Interest::shared_from_this(), Interest must be created |
| * using `make_shared`. Otherwise, .shared_from_this() will trigger undefined behavior. |
| */ |
| explicit |
| Interest(const Block& wire); |
| |
| /** |
| * @brief Fast encoding or block size estimation |
| */ |
| template<encoding::Tag TAG> |
| size_t |
| wireEncode(EncodingImpl<TAG>& encoder) const; |
| |
| /** |
| * @brief Encode to a wire format |
| */ |
| const Block& |
| wireEncode() const; |
| |
| /** |
| * @brief Decode from the wire format |
| */ |
| void |
| wireDecode(const Block& wire); |
| |
| /** |
| * @brief Check if already has wire |
| */ |
| bool |
| hasWire() const |
| { |
| return m_wire.hasWire(); |
| } |
| |
| /** |
| * @brief Encode the name according to the NDN URI Scheme |
| * |
| * If there are interest selectors, this method will append "?" and add the selectors as |
| * a query string. For example, "/test/name?ndn.ChildSelector=1" |
| */ |
| std::string |
| toUri() const; |
| |
| public: // matching |
| /** @brief Check if Interest, including selectors, matches the given @p name |
| * @param name The name to be matched. If this is a Data name, it shall contain the |
| * implicit digest component |
| */ |
| bool |
| matchesName(const Name& name) const; |
| |
| /** |
| * @brief Check if Interest can be satisfied by @p data. |
| * |
| * This method considers Name, MinSuffixComponents, MaxSuffixComponents, |
| * PublisherPublicKeyLocator, and Exclude. |
| * This method does not consider ChildSelector and MustBeFresh. |
| */ |
| bool |
| matchesData(const Data& data) const; |
| |
| /** |
| * @brief Check if Interest matches @p other interest |
| * |
| * Interest matches @p other if both have the same name, selectors, and link. Other fields |
| * (e.g., Nonce) may be different. |
| * |
| * @todo Implement distinguishing interests by link. The current implementation checks only |
| * name+selectors (Issue #3162). |
| */ |
| bool |
| matchesInterest(const Interest& other) const; |
| |
| public: // Name, Nonce, and Guiders |
| const Name& |
| getName() const |
| { |
| return m_name; |
| } |
| |
| Interest& |
| setName(const Name& name) |
| { |
| m_name = name; |
| m_wire.reset(); |
| return *this; |
| } |
| |
| /** @brief Check if Nonce set |
| */ |
| bool |
| hasNonce() const |
| { |
| return m_nonce.hasWire(); |
| } |
| |
| /** @brief Get Interest's nonce |
| * |
| * If nonce was not set before this call, it will be automatically assigned to a random value |
| */ |
| uint32_t |
| getNonce() const; |
| |
| /** @brief Set Interest's nonce |
| * |
| * If wire format already exists, this call simply replaces nonce in the |
| * existing wire format, without resetting and recreating it. |
| */ |
| Interest& |
| setNonce(uint32_t nonce); |
| |
| /** @brief Refresh nonce |
| * |
| * It's guaranteed that new nonce value differs from the existing one. |
| * |
| * If nonce is already set, it will be updated to a different random value. |
| * If nonce is not set, this method does nothing. |
| */ |
| void |
| refreshNonce(); |
| |
| time::milliseconds |
| getInterestLifetime() const |
| { |
| return m_interestLifetime; |
| } |
| |
| /** |
| * @brief Set Interest's lifetime |
| * @throw std::invalid_argument specified lifetime is < 0 |
| */ |
| Interest& |
| setInterestLifetime(time::milliseconds interestLifetime); |
| |
| const DelegationList& |
| getForwardingHint() const |
| { |
| return m_forwardingHint; |
| } |
| |
| Interest& |
| setForwardingHint(const DelegationList& value); |
| |
| /** @brief modify ForwardingHint in-place |
| * @tparam Modifier a unary function that accepts DelegationList& |
| * |
| * This is equivalent to, but more efficient (avoids copying) than: |
| * @code |
| * auto fh = interest.getForwardingHint(); |
| * modifier(fh); |
| * interest.setForwardingHint(fh); |
| * @endcode |
| */ |
| template<typename Modifier> |
| Interest& |
| modifyForwardingHint(const Modifier& modifier) |
| { |
| modifier(m_forwardingHint); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| public: // Selectors |
| /** |
| * @return true if Interest has any selector present |
| */ |
| bool |
| hasSelectors() const |
| { |
| return !m_selectors.empty(); |
| } |
| |
| const Selectors& |
| getSelectors() const |
| { |
| return m_selectors; |
| } |
| |
| Interest& |
| setSelectors(const Selectors& selectors) |
| { |
| m_selectors = selectors; |
| m_wire.reset(); |
| return *this; |
| } |
| |
| int |
| getMinSuffixComponents() const |
| { |
| return m_selectors.getMinSuffixComponents(); |
| } |
| |
| Interest& |
| setMinSuffixComponents(int minSuffixComponents) |
| { |
| m_selectors.setMinSuffixComponents(minSuffixComponents); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| int |
| getMaxSuffixComponents() const |
| { |
| return m_selectors.getMaxSuffixComponents(); |
| } |
| |
| Interest& |
| setMaxSuffixComponents(int maxSuffixComponents) |
| { |
| m_selectors.setMaxSuffixComponents(maxSuffixComponents); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| const KeyLocator& |
| getPublisherPublicKeyLocator() const |
| { |
| return m_selectors.getPublisherPublicKeyLocator(); |
| } |
| |
| Interest& |
| setPublisherPublicKeyLocator(const KeyLocator& keyLocator) |
| { |
| m_selectors.setPublisherPublicKeyLocator(keyLocator); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| const Exclude& |
| getExclude() const |
| { |
| return m_selectors.getExclude(); |
| } |
| |
| Interest& |
| setExclude(const Exclude& exclude) |
| { |
| m_selectors.setExclude(exclude); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| int |
| getChildSelector() const |
| { |
| return m_selectors.getChildSelector(); |
| } |
| |
| Interest& |
| setChildSelector(int childSelector) |
| { |
| m_selectors.setChildSelector(childSelector); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| int |
| getMustBeFresh() const |
| { |
| return m_selectors.getMustBeFresh(); |
| } |
| |
| Interest& |
| setMustBeFresh(bool mustBeFresh) |
| { |
| m_selectors.setMustBeFresh(mustBeFresh); |
| m_wire.reset(); |
| return *this; |
| } |
| |
| public: // Link and SelectedDelegation |
| /** |
| * @brief Check whether the Interest contains a Link object |
| * @return True if there is a link object, otherwise false |
| */ |
| bool |
| hasLink() const; |
| |
| /** |
| * @brief Get the link object for this interest |
| * @return The link object if there is one contained in this interest |
| * @throws Interest::Error if there is no link object contained in the interest |
| * @throws tlv::Error if the incorporated link object is malformed |
| */ |
| const Link& |
| getLink() const; |
| |
| /** |
| * @brief Set the link object for this interest |
| * @param link The link object that will be included in this interest (in wire format) |
| * @post !hasSelectedDelegation() |
| */ |
| void |
| setLink(const Block& link); |
| |
| /** |
| * @brief Delete the link object for this interest |
| * @post !hasLink() |
| */ |
| void |
| unsetLink(); |
| |
| /** |
| * @brief Check whether the Interest includes a selected delegation |
| * @return True if there is a selected delegation, otherwise false |
| */ |
| bool |
| hasSelectedDelegation() const; |
| |
| /** |
| * @brief Get the name of the selected delegation |
| * @return The name of the selected delegation |
| * @throw Error SelectedDelegation is not set. |
| */ |
| Name |
| getSelectedDelegation() const; |
| |
| /** |
| * @brief Set the selected delegation |
| * @param delegationName The name of the selected delegation |
| * @throw Error Link is not set. |
| * @throw std::invalid_argument @p delegationName does not exist in Link. |
| */ |
| void |
| setSelectedDelegation(const Name& delegationName); |
| |
| /** |
| * @brief Set the selected delegation |
| * @param delegationIndex The index of the selected delegation |
| * @throw Error Link is not set. |
| * @throw std::out_of_range @p delegationIndex is out of bound in Link. |
| */ |
| void |
| setSelectedDelegation(size_t delegationIndex); |
| |
| /** |
| * @brief Unset the selected delegation |
| */ |
| void |
| unsetSelectedDelegation(); |
| |
| private: |
| Name m_name; |
| Selectors m_selectors; |
| mutable Block m_nonce; |
| time::milliseconds m_interestLifetime; |
| DelegationList m_forwardingHint; |
| |
| mutable Block m_link; |
| mutable shared_ptr<Link> m_linkCached; |
| size_t m_selectedDelegationIndex; |
| mutable Block m_wire; |
| }; |
| |
| std::ostream& |
| operator<<(std::ostream& os, const Interest& interest); |
| |
| inline std::string |
| Interest::toUri() const |
| { |
| std::ostringstream os; |
| os << *this; |
| return os.str(); |
| } |
| |
| inline bool |
| operator==(const Interest& lhs, const Interest& rhs) |
| { |
| return lhs.wireEncode() == rhs.wireEncode(); |
| } |
| |
| inline bool |
| operator!=(const Interest& lhs, const Interest& rhs) |
| { |
| return !(lhs == rhs); |
| } |
| |
| } // namespace ndn |
| |
| #endif // NDN_INTEREST_HPP |