dtn::storage::SimpleBundleStorage Class Reference

#include <SimpleBundleStorage.h>

Inheritance diagram for dtn::storage::SimpleBundleStorage:

Collaboration diagram for dtn::storage::SimpleBundleStorage:

Public Member Functions
	SimpleBundleStorage (const ibrcommon::File &workdir, const dtn::data::Length maxsize=0, const unsigned int buffer_limit=0)
virtual	~SimpleBundleStorage ()
virtual void	store (const dtn::data::Bundle &bundle)
virtual dtn::data::Bundle	get (const dtn::data::BundleID &id)
virtual void	get (const BundleSelector &cb, BundleResult &result) throw (NoBundleFoundException, BundleSelectorException)
virtual const eid_set	getDistinctDestinations ()
void	remove (const dtn::data::BundleID &id)
dtn::data::MetaBundle	remove (const ibrcommon::BloomFilter &filter)
void	clear ()
bool	empty ()
dtn::data::Size	count ()
void	releaseCustody (const dtn::data::EID &custodian, const dtn::data::BundleID &id)
void	raiseEvent (const dtn::core::Event *evt) throw ()
virtual const std::string	getName () const
virtual void	eventDataStorageStored (const dtn::storage::DataStorage::Hash &hash)
virtual void	eventDataStorageStoreFailed (const dtn::storage::DataStorage::Hash &hash, const ibrcommon::Exception &)
virtual void	eventDataStorageRemoved (const dtn::storage::DataStorage::Hash &hash)
virtual void	eventDataStorageRemoveFailed (const dtn::storage::DataStorage::Hash &hash, const ibrcommon::Exception &)
virtual void	iterateDataStorage (const dtn::storage::DataStorage::Hash &hash, dtn::storage::DataStorage::istream &stream)
virtual void	wait ()
virtual void	setFaulty (bool mode)
Public Member Functions inherited from dtn::storage::BundleStorage
virtual	~BundleStorage ()=0
void	remove (const dtn::data::Bundle &b)
dtn::data::Length	size () const
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)
Public Member Functions inherited from dtn::storage::BundleSeeker
virtual	~BundleSeeker ()
Public Member Functions inherited from dtn::core::EventReceiver
virtual	~EventReceiver ()=0
Public Member Functions inherited from dtn::daemon::IntegratedComponent
	IntegratedComponent ()
virtual	~IntegratedComponent ()
virtual void	initialize () throw ()
virtual void	startup () throw ()
virtual void	terminate () throw ()
Public Member Functions inherited from dtn::daemon::Component
virtual	~Component ()=0
Public Member Functions inherited from dtn::data::BundleList::Listener
virtual	~Listener ()=0

Protected Member Functions
virtual void	componentUp () throw ()
virtual void	componentDown () throw ()
virtual void	eventBundleExpired (const dtn::data::MetaBundle &b) throw ()
Protected Member Functions inherited from dtn::storage::BundleStorage
	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 ()

Additional Inherited Members
Public Types inherited from dtn::storage::BundleSeeker
typedef std::set< dtn::data::EID >	eid_set
Protected Attributes inherited from dtn::storage::BundleStorage
bool	_faulty

Detailed Description

This storage holds all bundles and fragments in the system memory.

Definition at line 53 of file SimpleBundleStorage.h.

Constructor & Destructor Documentation

dtn::storage::SimpleBundleStorage::SimpleBundleStorage	(	const ibrcommon::File &	workdir,
		const dtn::data::Length	maxsize = 0,
		const unsigned int	buffer_limit = 0
	)

Constructor

Definition at line 49 of file SimpleBundleStorage.cpp.

dtn::storage::SimpleBundleStorage::~SimpleBundleStorage ( )

virtual

Destructor

Definition at line 54 of file SimpleBundleStorage.cpp.

Member Function Documentation

void dtn::storage::SimpleBundleStorage::clear ( )

virtual

See Also

BundleStorage::clear()

Reimplemented from dtn::storage::BundleStorage.

Definition at line 458 of file SimpleBundleStorage.cpp.

References dtn::storage::MetaStorage::begin(), dtn::storage::MetaStorage::clear(), dtn::storage::MetaStorage::end(), ibrcommon::RWMutex::LOCK_READWRITE, dtn::storage::DataStorage::remove(), and dtn::data::BundleID::toString().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::componentDown ( ) throw ()

protectedvirtual

Implements dtn::daemon::IntegratedComponent.

Definition at line 185 of file SimpleBundleStorage.cpp.

References dtn::storage::MetaStorage::clear(), ibrcommon::LogLevel::error, IBRCOMMON_LOGGER_ENDL, IBRCOMMON_LOGGER_TAG, ibrcommon::JoinableThread::join(), ibrcommon::RWMutex::LOCK_READWRITE, dtn::core::EventDispatcher< E >::remove(), dtn::storage::DataStorage::reset(), ibrcommon::JoinableThread::stop(), dtn::storage::DataStorage::wait(), and ibrcommon::Exception::what().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::componentUp ( ) throw ()

protectedvirtual

Implements dtn::daemon::IntegratedComponent.

Definition at line 163 of file SimpleBundleStorage.cpp.

References dtn::core::EventDispatcher< E >::add(), ibrcommon::LogLevel::error, IBRCOMMON_LOGGER_ENDL, IBRCOMMON_LOGGER_TAG, ibrcommon::LogLevel::info, dtn::storage::DataStorage::iterateAll(), ibrcommon::RWMutex::LOCK_READONLY, dtn::storage::MetaStorage::size(), ibrcommon::JoinableThread::start(), and ibrcommon::Exception::what().

Here is the call graph for this function:

dtn::data::Size dtn::storage::SimpleBundleStorage::count ( )

virtual

See Also

BundleStorage::count()

Reimplemented from dtn::storage::BundleStorage.

Definition at line 235 of file SimpleBundleStorage.cpp.

References ibrcommon::RWMutex::LOCK_READONLY, and dtn::storage::MetaStorage::size().

Here is the call graph for this function:

bool dtn::storage::SimpleBundleStorage::empty ( )

virtual

See Also

BundleStorage::empty()

Reimplemented from dtn::storage::BundleStorage.

Definition at line 223 of file SimpleBundleStorage.cpp.

References dtn::storage::MetaStorage::empty(), and ibrcommon::RWMutex::LOCK_READONLY.

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::eventBundleExpired ( const dtn::data::MetaBundle &  b ) throw ()

protectedvirtual

Implements dtn::data::BundleList::Listener.

Definition at line 477 of file SimpleBundleStorage.cpp.

References dtn::core::BUNDLE_DELETED, dtn::data::StatusReportBlock::LIFETIME_EXPIRED, dtn::core::BundleExpiredEvent::raise(), and dtn::core::BundleEvent::raise().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::eventDataStorageRemoved ( const dtn::storage::DataStorage::Hash &  hash )

virtual

Implements dtn::storage::DataStorage::Callback.

Definition at line 96 of file SimpleBundleStorage.cpp.

References dtn::storage::MetaStorage::begin(), dtn::storage::MetaStorage::end(), dtn::storage::BundleStorage::freeSpace(), dtn::storage::MetaStorage::getSize(), IBRCOMMON_LOGGER_DEBUG_TAG, IBRCOMMON_LOGGER_ENDL, ibrcommon::RWMutex::LOCK_READWRITE, dtn::storage::MetaStorage::remove(), dtn::data::BundleID::toString(), and dtn::storage::DataStorage::Hash::value.

Referenced by eventDataStorageRemoveFailed().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::eventDataStorageRemoveFailed ( const dtn::storage::DataStorage::Hash &  hash, const ibrcommon::Exception &  ex  )

virtual

Implements dtn::storage::DataStorage::Callback.

Definition at line 120 of file SimpleBundleStorage.cpp.

References ibrcommon::LogLevel::error, eventDataStorageRemoved(), IBRCOMMON_LOGGER_ENDL, IBRCOMMON_LOGGER_TAG, dtn::storage::DataStorage::Hash::value, and ibrcommon::Exception::what().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::eventDataStorageStored ( const dtn::storage::DataStorage::Hash &  hash )

virtual

Implements dtn::storage::DataStorage::Callback.

Definition at line 58 of file SimpleBundleStorage.cpp.

References IBRCOMMON_LOGGER_DEBUG_TAG, IBRCOMMON_LOGGER_ENDL, ibrcommon::RWMutex::LOCK_READWRITE, and dtn::storage::DataStorage::Hash::value.

void dtn::storage::SimpleBundleStorage::eventDataStorageStoreFailed ( const dtn::storage::DataStorage::Hash &  hash, const ibrcommon::Exception &  ex  )

virtual

Implements dtn::storage::DataStorage::Callback.

Definition at line 66 of file SimpleBundleStorage.cpp.

References ibrcommon::LogLevel::error, dtn::storage::BundleStorage::freeSpace(), dtn::storage::MetaStorage::getSize(), IBRCOMMON_LOGGER_ENDL, IBRCOMMON_LOGGER_TAG, ibrcommon::RWMutex::LOCK_READONLY, ibrcommon::RWMutex::LOCK_READWRITE, dtn::storage::MetaStorage::remove(), dtn::storage::DataStorage::Hash::value, and ibrcommon::Exception::what().

Here is the call graph for this function:

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

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 of the

Implements dtn::storage::BundleStorage.

Definition at line 276 of file SimpleBundleStorage.cpp.

References dtn::storage::BundleStorage::_faulty, dtn::data::AgeBlock::addSeconds(), ibrcommon::LogLevel::error, dtn::data::Bundle::find(), dtn::storage::MetaStorage::find(), IBRCOMMON_LOGGER_ENDL, IBRCOMMON_LOGGER_TAG, ibrcommon::File::lastaccess(), ibrcommon::File::lastmodify(), ibrcommon::RWMutex::LOCK_READONLY, dtn::data::MetaBundle::mockUp(), dtn::storage::DataStorage::retrieve(), dtn::data::BundleID::toString(), and ibrcommon::Exception::what().

Here is the call graph for this function:

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

virtual

See Also

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

Implements dtn::storage::BundleStorage.

Definition at line 252 of file SimpleBundleStorage.cpp.

References dtn::utils::Clock::isExpired(), dtn::data::MetaBundle::lifetime, ibrcommon::RWMutex::LOCK_READONLY, and dtn::data::BundleID::timestamp.

Here is the call graph for this function:

const SimpleBundleStorage::eid_set dtn::storage::SimpleBundleStorage::getDistinctDestinations ( )

virtual

See Also

BundleSeeker::getDistinctDestinations()

Implements dtn::storage::BundleStorage.

Definition at line 343 of file SimpleBundleStorage.cpp.

References dtn::storage::MetaStorage::getDistinctDestinations(), and ibrcommon::RWMutex::LOCK_READONLY.

Here is the call graph for this function:

const std::string dtn::storage::SimpleBundleStorage::getName ( ) const

virtual

See Also

Component::getName()

Implements dtn::daemon::Component.

Definition at line 218 of file SimpleBundleStorage.cpp.

void dtn::storage::SimpleBundleStorage::iterateDataStorage ( const dtn::storage::DataStorage::Hash &  hash, dtn::storage::DataStorage::istream &  stream  )

virtual

Implements dtn::storage::DataStorage::Callback.

Definition at line 128 of file SimpleBundleStorage.cpp.

References dtn::storage::BundleStorage::allocSpace(), ibrcommon::LogLevel::error, dtn::storage::BundleStorage::eventBundleAdded(), IBRCOMMON_LOGGER_DEBUG_TAG, IBRCOMMON_LOGGER_ENDL, IBRCOMMON_LOGGER_TAG, ibrcommon::RWMutex::LOCK_READWRITE, dtn::storage::DataStorage::remove(), dtn::storage::MetaStorage::store(), and dtn::storage::DataStorage::Hash::value.

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::raiseEvent ( const dtn::core::Event *  evt ) throw ()

virtual

This method is used to receive events.

Parameters

evt

Implements dtn::core::EventReceiver.

Definition at line 206 of file SimpleBundleStorage.cpp.

References dtn::core::TimeEvent::getAction(), dtn::core::TimeEvent::getTimestamp(), ibrcommon::RWMutex::LOCK_READWRITE, and dtn::core::TIME_SECOND_TICK.

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::releaseCustody ( const dtn::data::EID &  custodian, const dtn::data::BundleID &  id  )

virtual

See Also

BundleStorage::releaseCustody();

Implements dtn::storage::BundleStorage.

Definition at line 229 of file SimpleBundleStorage.cpp.

void dtn::storage::SimpleBundleStorage::remove ( const dtn::data::BundleID &  id )

virtual

This method deletes a specific bundle in the storage. No reports will be generated here.

Parameters

id	The ID of the bundle to remove.

Implements dtn::storage::BundleStorage.

Definition at line 379 of file SimpleBundleStorage.cpp.

References dtn::storage::BundleStorage::eventBundleRemoved(), dtn::storage::MetaStorage::find(), dtn::storage::MetaStorage::isRemoved(), ibrcommon::RWMutex::LOCK_READONLY, dtn::storage::MetaStorage::markRemoved(), dtn::data::MetaBundle::mockUp(), dtn::storage::DataStorage::remove(), and dtn::data::BundleID::toString().

Here is the call graph for this function:

dtn::data::MetaBundle dtn::storage::SimpleBundleStorage::remove ( const ibrcommon::BloomFilter &  filter )

virtual

Remove one bundles which match this filter

Parameters

filter

Returns

The bundle meta data of the removed bundle.

Reimplemented from dtn::storage::BundleStorage.

Definition at line 434 of file SimpleBundleStorage.cpp.

References dtn::storage::BundleStorage::eventBundleRemoved(), dtn::storage::MetaStorage::find(), dtn::storage::MetaStorage::isRemoved(), ibrcommon::RWMutex::LOCK_READONLY, dtn::storage::MetaStorage::markRemoved(), dtn::storage::DataStorage::remove(), and dtn::data::BundleID::toString().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::setFaulty ( bool  mode )

virtual

Set the storage to faulty. If set to true, each try to store or retrieve a bundle will fail.

Reimplemented from dtn::storage::BundleStorage.

Definition at line 246 of file SimpleBundleStorage.cpp.

References dtn::storage::BundleStorage::_faulty, and dtn::storage::DataStorage::setFaulty().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::store ( const dtn::data::Bundle &  bundle )

virtual

Stores a bundle in the storage.

Parameters

bundle

The bundle to store.

Implements dtn::storage::BundleStorage.

Definition at line 349 of file SimpleBundleStorage.cpp.

References dtn::storage::BundleStorage::acceptCustody(), dtn::storage::BundleStorage::allocSpace(), dtn::data::PrimaryBlock::custodian, and dtn::data::DefaultSerializer::getLength().

Here is the call graph for this function:

void dtn::storage::SimpleBundleStorage::wait ( )

virtual

Wait until all the data has been stored to the disk

Reimplemented from dtn::storage::BundleStorage.

Definition at line 241 of file SimpleBundleStorage.cpp.

References dtn::storage::DataStorage::wait().

Here is the call graph for this function:

---

The documentation for this class was generated from the following files:

• daemon/src/storage/SimpleBundleStorage.h
• daemon/src/storage/SimpleBundleStorage.cpp