#include <BundleStorage.h>

Inheritance diagram for dtn::storage::BundleStorage:

Collaboration diagram for dtn::storage::BundleStorage:

Classes
class	BundleLoadException

class	StorageSizeExeededException

Public Member Functions
virtual	~BundleStorage ()=0

virtual void	store (const dtn::data::Bundle &bundle)=0

virtual bool	contains (const dtn::data::BundleID &id)=0

virtual dtn::data::MetaBundle	info (const dtn::data::BundleID &id)=0

virtual dtn::data::Bundle	get (const dtn::data::BundleID &id)=0

virtual void	get (const BundleSelector &cb, BundleResult &result)=0 throw (NoBundleFoundException, BundleSelectorException)

virtual const eid_set	getDistinctDestinations ()=0

virtual void	remove (const dtn::data::BundleID &id)=0

void	remove (const dtn::data::Bundle &b)

virtual void	clear ()

virtual bool	empty ()

virtual dtn::data::Size	count ()

dtn::data::Length	size () const

virtual void	releaseCustody (const dtn::data::EID &custodian, const dtn::data::BundleID &id)=0

const dtn::data::EID	acceptCustody (const dtn::data::MetaBundle &meta)

void	rejectCustody (const dtn::data::MetaBundle &meta, dtn::data::CustodySignalBlock::REASON_CODE reason=dtn::data::CustodySignalBlock::NO_ADDITIONAL_INFORMATION)

void	attach (dtn::storage::BundleIndex *index)

void	detach (dtn::storage::BundleIndex *index)

virtual void	wait ()

virtual void	setFaulty (bool mode)

Public Member Functions inherited from dtn::storage::BundleSeeker
virtual	~BundleSeeker ()

Protected Member Functions
	BundleStorage (const dtn::data::Length &maxsize)

void	allocSpace (const dtn::data::Length &size) throw (StorageSizeExeededException)

void	freeSpace (const dtn::data::Length &size) throw ()

void	clearSpace () throw ()

void	eventBundleAdded (const dtn::data::MetaBundle &b) throw ()

void	eventBundleRemoved (const dtn::data::BundleID &id) throw ()

Protected Attributes
bool	_faulty

Additional Inherited Members
Public Types inherited from dtn::storage::BundleSeeker
typedef std::set< dtn::data::EID >	eid_set

Detailed Description

Definition at line 44 of file BundleStorage.h.

Constructor & Destructor Documentation

dtn::storage::BundleStorage::~BundleStorage ( )

pure virtual

destructor

Definition at line 40 of file BundleStorage.cpp.

dtn::storage::BundleStorage::BundleStorage ( const dtn::data::Length & maxsize)

protected

constructor

Definition at line 35 of file BundleStorage.cpp.

Member Function Documentation

const dtn::data::EID dtn::storage::BundleStorage::acceptCustody ( const dtn::data::MetaBundle & meta)

Accept custody for a given bundle. The previous custodian gets notified with a custody accept message.

Parameters

bundle

Returns: The new custodian.

Definition at line 49 of file BundleStorage.cpp.

References dtn::data::PrimaryBlock::APPDATA_IS_ADMRECORD, dtn::data::MetaBundle::custodian, dtn::core::CUSTODY_ACCEPT, dtn::data::CustodySignalBlock::custody_accepted, dtn::data::PrimaryBlock::destination, dtn::data::PrimaryBlock::DESTINATION_IS_SINGLETON, dtn::data::MetaBundle::get(), dtn::core::BundleCore::local, dtn::data::PrimaryBlock::PRIORITY_BIT1, dtn::data::PrimaryBlock::PRIORITY_BIT2, dtn::data::Bundle::push_back(), dtn::core::BundleGeneratedEvent::raise(), dtn::core::CustodyEvent::raise(), dtn::data::PrimaryBlock::set(), dtn::data::CustodySignalBlock::setMatch(), dtn::data::BundleID::source, and dtn::data::CustodySignalBlock::write().

Referenced by dtn::storage::SimpleBundleStorage::store(), and dtn::storage::SQLiteBundleStorage::store().

Here is the call graph for this function:

void dtn::storage::BundleStorage::allocSpace	(	const dtn::data::Length &	size)
throw	(	StorageSizeExeededException
	)

protected

Definition at line 131 of file BundleStorage.cpp.

Referenced by dtn::storage::SQLiteBundleStorage::iterateDatabase(), dtn::storage::SimpleBundleStorage::iterateDataStorage(), dtn::storage::MemoryBundleStorage::store(), dtn::storage::SimpleBundleStorage::store(), and dtn::storage::SQLiteBundleStorage::store().

void dtn::storage::BundleStorage::attach ( dtn::storage::BundleIndex * index)

attach an index to this storage

Definition at line 185 of file BundleStorage.cpp.

virtual void dtn::storage::BundleStorage::clear ( )

inlinevirtual

Clears all bundles and fragments in the storage.

Reimplemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Definition at line 119 of file BundleStorage.h.

Referenced by dtn::daemon::NativeDaemon::clearStorage().

void dtn::storage::BundleStorage::clearSpace	(	)
throw	(
	)

protected

Definition at line 159 of file BundleStorage.cpp.

Referenced by dtn::storage::MemoryBundleStorage::clear(), dtn::storage::SQLiteBundleStorage::clear(), and dtn::storage::SimpleBundleStorage::componentDown().

virtual bool dtn::storage::BundleStorage::contains ( const dtn::data::BundleID & id)

pure virtual

This method returns true if the requested bundle is stored in the storage.

Implemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Referenced by dtn::core::FragmentManager::componentRun(), and dtn::net::EMailSmtpService::run().

virtual dtn::data::Size dtn::storage::BundleStorage::count ( )

inlinevirtual

Returns: the count of bundles in the storage

Reimplemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Definition at line 129 of file BundleStorage.h.

Referenced by dtn::daemon::NativeDaemon::getStats().

void dtn::storage::BundleStorage::detach ( dtn::storage::BundleIndex * index)

detach a specific bundle index

Definition at line 191 of file BundleStorage.cpp.

virtual bool dtn::storage::BundleStorage::empty ( )

inlinevirtual

Returns: True, if no bundles in the storage.

Reimplemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Definition at line 124 of file BundleStorage.h.

void dtn::storage::BundleStorage::eventBundleAdded	(	const dtn::data::MetaBundle &	b)
throw	(
	)

protected

Definition at line 165 of file BundleStorage.cpp.

References dtn::storage::BundleIndex::add(), IBRCOMMON_LOGGER_DEBUG_TAG, and IBRCOMMON_LOGGER_ENDL.

Referenced by dtn::storage::SQLiteBundleStorage::iterateDatabase(), dtn::storage::SimpleBundleStorage::iterateDataStorage(), dtn::storage::MemoryBundleStorage::store(), and dtn::storage::SQLiteBundleStorage::store().

Here is the call graph for this function:

void dtn::storage::BundleStorage::eventBundleRemoved	(	const dtn::data::BundleID &	id)
throw	(
	)

protected

Definition at line 175 of file BundleStorage.cpp.

References IBRCOMMON_LOGGER_DEBUG_TAG, IBRCOMMON_LOGGER_ENDL, and dtn::storage::BundleIndex::remove().

Referenced by dtn::storage::MemoryBundleStorage::clear(), dtn::storage::MemoryBundleStorage::remove(), dtn::storage::SimpleBundleStorage::remove(), and dtn::storage::SQLiteBundleStorage::remove().

Here is the call graph for this function:

void dtn::storage::BundleStorage::freeSpace	(	const dtn::data::Length &	size)
throw	(
	)

protected

Definition at line 145 of file BundleStorage.cpp.

References ibrcommon::LogLevel::critical, IBRCOMMON_LOGGER_ENDL, and IBRCOMMON_LOGGER_TAG.

Referenced by dtn::storage::SimpleBundleStorage::eventDataStorageRemoved(), dtn::storage::SimpleBundleStorage::eventDataStorageStoreFailed(), dtn::storage::SQLiteBundleStorage::remove(), dtn::storage::MemoryBundleStorage::store(), and dtn::storage::SQLiteBundleStorage::store().

virtual dtn::data::Bundle dtn::storage::BundleStorage::get ( const dtn::data::BundleID & id)

pure virtual

This method returns a specific bundle which is identified by its id.

Parameters

id	The ID of the bundle to return.

Returns: A bundle object.

Implemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Referenced by dtn::net::FileConvergenceLayer::componentRun(), dtn::core::FragmentManager::componentRun(), dtn::api::NativeSession::load(), dtn::routing::NodeHandshakeExtension::processHandshake(), dtn::routing::ProphetRoutingExtension::processHandshake(), dtn::net::UDPConvergenceLayer::queue(), dtn::net::HTTPConvergenceLayer::queue(), dtn::api::Registration::receive(), dtn::net::LOWPANConnectionSender::run(), dtn::api::ExtendedApiHandler::run(), dtn::core::FragmentManager::setOffset(), and dtn::api::BundleStreamBuf::underflow().

virtual void dtn::storage::BundleStorage::get	(	const BundleSelector &	cb,
		BundleResult &	result
	)
throw	(	NoBundleFoundException,
		BundleSelectorException
	)

pure virtual

See Also: BundleSeeker::get(BundleSelector &cb, BundleResult &result)

Implements dtn::storage::BundleSeeker.

Implemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

virtual const eid_set dtn::storage::BundleStorage::getDistinctDestinations ( )

pure virtual

See Also: BundleSeeker::getDistinctDestinations()

Implements dtn::storage::BundleSeeker.

Implemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Referenced by dtn::dht::DHTNameService::componentRun().

virtual dtn::data::MetaBundle dtn::storage::BundleStorage::info ( const dtn::data::BundleID & id)

pure virtual

Get meta data about a specific bundle ID

Implemented in dtn::storage::SQLiteBundleStorage, dtn::storage::SimpleBundleStorage, and dtn::storage::MemoryBundleStorage.

Referenced by dtn::api::NativeSession::delivered(), and dtn::routing::RetransmissionExtension::raiseEvent().

void dtn::storage::BundleStorage::rejectCustody	(	const dtn::data::MetaBundle &	meta,
		dtn::data::CustodySignalBlock::REASON_CODE	reason = `dtn::data::CustodySignalBlock::NO_ADDITIONAL_INFORMATION`
	)