IBR-DTNSuite
0.12
|
#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, and ibrcommon::BLOB::Reference::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().