#include <notification-subscriber.hpp>
Public Member Functions | |
virtual | ~NotificationSubscriberBase () |
time::milliseconds | getInterestLifetime () const |
bool | isRunning () const |
void | start () |
start or resume receiving notifications More... | |
void | stop () |
stop receiving notifications More... | |
Public Attributes | |
signal::Signal< NotificationSubscriberBase, lp::Nack > | onNack |
fires when a NACK is received More... | |
signal::Signal< NotificationSubscriberBase > | onTimeout |
fires when no Notification is received within .getInterestLifetime period More... | |
signal::Signal< NotificationSubscriberBase, Data > | onDecodeError |
fires when a Data packet in the Notification Stream cannot be decoded as Notification More... | |
Protected Member Functions | |
NotificationSubscriberBase (Face &face, const Name &prefix, time::milliseconds interestLifetime) | |
construct a NotificationSubscriber More... | |
Definition at line 40 of file notification-subscriber.hpp.
|
virtualdefault |
Referenced by NotificationSubscriberBase().
|
protected |
construct a NotificationSubscriber
Definition at line 36 of file notification-subscriber.cpp.
References ~NotificationSubscriberBase().
Referenced by isRunning().
|
inline |
This must be greater than FreshnessPeriod of Notification Data packets, to ensure correct operation of this subscriber implementation.
Definition at line 52 of file notification-subscriber.hpp.
|
inline |
Definition at line 58 of file notification-subscriber.hpp.
References NotificationSubscriberBase(), start(), and stop().
void ndn::util::NotificationSubscriberBase::start | ( | ) |
start or resume receiving notifications
Definition at line 52 of file notification-subscriber.cpp.
Referenced by isRunning(), and nfd::RibManager::registerWithNfd().
void ndn::util::NotificationSubscriberBase::stop | ( | ) |
stop receiving notifications
Definition at line 62 of file notification-subscriber.cpp.
References ndn::Name::appendSequenceNumber(), ndn::detail::ScopedCancelHandle< HandleT >::cancel(), delay(), ndn::Face::expressInterest(), ndn::random::generateWord32(), ndn::Name::get(), ndn::lp::Nack::getInterest(), ndn::Data::getName(), ndn::Interest::getName(), onDecodeError, onNack, onTimeout, ndn::scheduler::Scheduler::schedule(), and ndn::name::Component::toSequenceNumber().
Referenced by isRunning().
signal::Signal<NotificationSubscriberBase, lp::Nack> ndn::util::NotificationSubscriberBase::onNack |
fires when a NACK is received
Definition at line 123 of file notification-subscriber.hpp.
Referenced by stop().
signal::Signal<NotificationSubscriberBase> ndn::util::NotificationSubscriberBase::onTimeout |
fires when no Notification is received within .getInterestLifetime period
Definition at line 127 of file notification-subscriber.hpp.
Referenced by stop().
signal::Signal<NotificationSubscriberBase, Data> ndn::util::NotificationSubscriberBase::onDecodeError |
fires when a Data packet in the Notification Stream cannot be decoded as Notification
Definition at line 131 of file notification-subscriber.hpp.
Referenced by stop().