#include <BundleList.h>
Public Member Functions | |
BlockingBundleList (const std::string &name) | |
virtual | ~BlockingBundleList () |
BundleRef | pop_blocking (int timeout=-1) |
Remove (and return) the first bundle on the list, blocking (potentially limited by the given timeout) if there are none. | |
oasys::Notifier * | notifier () |
Accessor for the internal notifier. |
This allows one thread to block until another has added a bundle to the list.
Definition at line 330 of file bundling/BundleList.h.
dtn::BlockingBundleList::BlockingBundleList | ( | const std::string & | name | ) |
dtn::BlockingBundleList::~BlockingBundleList | ( | ) | [virtual] |
oasys::Notifier* dtn::BlockingBundleList::notifier | ( | ) | [inline] |
Accessor for the internal notifier.
Definition at line 348 of file bundling/BundleList.h.
References dtn::BundleList::notifier_.
Referenced by dtn::APIClient::wait_for_notify().
BundleRef dtn::BlockingBundleList::pop_blocking | ( | int | timeout = -1 |
) |
Remove (and return) the first bundle on the list, blocking (potentially limited by the given timeout) if there are none.
Definition at line 513 of file BundleList.cc.
References ASSERT, dtn::BundleList::empty(), dtn::BundleList::lock_, dtn::BundleList::name(), dtn::BundleList::notifier_, and dtn::BundleList::pop_front().