|
IBR-DTNSuite
0.10
|
#include <BundleStreamBuf.h>


Public Member Functions | |
| BundleStreamBuf (BundleStreamBufCallback &callback, const dtn::data::Length chunk_size=4096, bool wait_seq_zero=false) | |
| virtual | ~BundleStreamBuf () |
| void | setChunkSize (const dtn::data::Length &size) |
| void | setTimeout (const dtn::data::Timeout &timeout) |
Static Public Attributes | |
| static const dtn::data::Length | BUFF_SIZE = 5120 |
Protected Member Functions | |
| virtual int | sync () |
| virtual std::char_traits< char > ::int_type | overflow (std::char_traits< char >::int_type=std::char_traits< char >::eof()) |
| virtual std::char_traits< char > ::int_type | underflow () |
Definition at line 42 of file BundleStreamBuf.h.
| BundleStreamBuf::BundleStreamBuf | ( | BundleStreamBufCallback & | callback, |
| const dtn::data::Length | chunk_size = 4096, |
||
| bool | wait_seq_zero = false |
||
| ) |
Definition at line 32 of file BundleStreamBuf.cpp.
References BUFF_SIZE.
|
virtual |
Definition at line 42 of file BundleStreamBuf.cpp.
|
protectedvirtual |
Definition at line 58 of file BundleStreamBuf.cpp.
References BUFF_SIZE, ibrcommon::BLOB::Reference::iostream(), and ibrcommon::BLOB::iostream::size().
Referenced by sync().

| void BundleStreamBuf::setChunkSize | ( | const dtn::data::Length & | size | ) |
Definition at line 120 of file BundleStreamBuf.cpp.
Referenced by dtn::api::OrderedStreamHandler::run().
| void BundleStreamBuf::setTimeout | ( | const dtn::data::Timeout & | timeout | ) |
Definition at line 125 of file BundleStreamBuf.cpp.
Referenced by dtn::api::OrderedStreamHandler::run().
|
protectedvirtual |
Definition at line 46 of file BundleStreamBuf.cpp.
References overflow().

|
protectedvirtual |
Definition at line 137 of file BundleStreamBuf.cpp.
References BUFF_SIZE, dtn::api::BundleStreamBufCallback::delivered(), dtn::data::Bundle::find(), dtn::api::BundleStreamBufCallback::get(), dtn::storage::BundleStorage::get(), dtn::data::PayloadBlock::getBLOB(), dtn::core::BundleCore::getInstance(), ibrcommon::TimeMeasurement::getSeconds(), dtn::core::BundleCore::getStorage(), IBRCOMMON_LOGGER_DEBUG_TAG, IBRCOMMON_LOGGER_ENDL, ibrcommon::BLOB::iostream::iostream(), dtn::core::BundleCore::processBlocks(), ibrcommon::TimeMeasurement::start(), and ibrcommon::TimeMeasurement::stop().

|
static |
Definition at line 46 of file BundleStreamBuf.h.
Referenced by BundleStreamBuf(), overflow(), and underflow().