Update::PersistenceUpdater Class Reference

#include <PersistenceUpdater.h>

Inheritance diagram for Update::PersistenceUpdater:

[legend]Collaboration diagram for Update::PersistenceUpdater:

[legend]List of all members.

Public Types
typedef ACE_Allocator_Adapter< ACE_Malloc< ACE_MMAP_MEMORY_POOL, TAO_SYNCH_MUTEX > >	ALLOCATOR
typedef TopicStrt< QosSeq, ACE_CString >	Topic
	Persisted entity data structures.
typedef ParticipantStrt< QosSeq >	Participant
typedef ActorStrt< QosSeq, QosSeq, ACE_CString, BinSeq >	RWActor
typedef ACE_Hash_Map_With_Allocator< IdType_ExtId, Topic * >	TopicIndex
typedef ACE_Hash_Map_With_Allocator< IdType_ExtId, Participant * >	ParticipantIndex
typedef ACE_Hash_Map_With_Allocator< IdType_ExtId, RWActor * >	ActorIndex
Public Member Functions
	PersistenceUpdater (void)
virtual	~PersistenceUpdater (void)
virtual int	init (int argc, ACE_TCHAR *argv[])
	Service object initialization.
virtual int	fini (void)
	pure ACE_Task_Base methods
virtual int	svc (void)
virtual void	requestImage (void)
virtual void	create (const UTopic &topic)
	Add entities to be persisted.
virtual void	create (const UParticipant &participant)
virtual void	create (const URActor &actor)
virtual void	create (const UWActor &actor)
virtual void	create (const OwnershipData &data)
virtual void	update (const IdPath &id, const ::DDS::DomainParticipantQos &qos)
	Persist updated Qos parameters for an entity.
virtual void	update (const IdPath &id, const ::DDS::TopicQos &qos)
virtual void	update (const IdPath &id, const ::DDS::DataWriterQos &qos)
virtual void	update (const IdPath &id, const ::DDS::PublisherQos &qos)
virtual void	update (const IdPath &id, const ::DDS::DataReaderQos &qos)
virtual void	update (const IdPath &id, const ::DDS::SubscriberQos &qos)
virtual void	destroy (const IdPath &id, ItemType type, ActorType actor)
	Remove an entity (but not children) from persistence.
Private Member Functions
int	parse (int argc, ACE_TCHAR *argv[])
void	storeUpdate (const ACE_Message_Block &data, BinSeq &storage)
Private Attributes
ACE_TString	persistence_file_
bool	reset_
Manager *	um_
ALLOCATOR *	allocator_
TopicIndex *	topic_index_
ParticipantIndex *	participant_index_
ActorIndex *	actor_index_
Classes
class	IdType_ExtId

---

Member Typedef Documentation

typedef ACE_Hash_Map_With_Allocator<IdType_ExtId, RWActor*> Update::PersistenceUpdater::ActorIndex

typedef ACE_Allocator_Adapter<ACE_Malloc <ACE_MMAP_MEMORY_POOL , TAO_SYNCH_MUTEX> > Update::PersistenceUpdater::ALLOCATOR

typedef struct ParticipantStrt< QosSeq > Update::PersistenceUpdater::Participant

typedef ACE_Hash_Map_With_Allocator<IdType_ExtId, Participant*> Update::PersistenceUpdater::ParticipantIndex

typedef struct ActorStrt< QosSeq, QosSeq, ACE_CString, BinSeq > Update::PersistenceUpdater::RWActor

typedef struct TopicStrt< QosSeq, ACE_CString > Update::PersistenceUpdater::Topic

Persisted entity data structures.

typedef ACE_Hash_Map_With_Allocator<IdType_ExtId, Topic*> Update::PersistenceUpdater::TopicIndex

---

Constructor & Destructor Documentation

Update::PersistenceUpdater::PersistenceUpdater

(

void

)

Update::PersistenceUpdater::~PersistenceUpdater

(

void

)

[virtual]

---

Member Function Documentation

void Update::PersistenceUpdater::create

(

const OwnershipData &

data

)

[virtual]

Implements Update::Updater.

virtual void Update::PersistenceUpdater::create

(

const UWActor &

actor

)

[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::create

(

const URActor &

actor

)

[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::create

(

const UParticipant &

participant

)

[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::create

(

const UTopic &

topic

)

[virtual]

Add entities to be persisted.

Implements Update::Updater.

void Update::PersistenceUpdater::destroy	(	const IdPath &	id,
		ItemType	type,
		ActorType	actor
	)			[virtual]

Remove an entity (but not children) from persistence.

Implements Update::Updater.

int Update::PersistenceUpdater::fini

(

void

)

[virtual]

pure ACE_Task_Base methods

int Update::PersistenceUpdater::init	(	int	argc,
		ACE_TCHAR *	argv[]
	)			[virtual]

Service object initialization.

int Update::PersistenceUpdater::parse	(	int	argc,
		ACE_TCHAR *	argv[]
	)			[private]

void Update::PersistenceUpdater::requestImage

(

void

)

[virtual]

Request an image refresh to be sent upstream. This is currently done synchronously. TBD: Move to an asynchronous model

Implements Update::Updater.

void Update::PersistenceUpdater::storeUpdate	(	const ACE_Message_Block &	data,
		BinSeq &	storage
	)			[private]

int Update::PersistenceUpdater::svc

(

void

)

[virtual]

void Update::PersistenceUpdater::update	(	const IdPath &	id,
		const ::DDS::SubscriberQos &	qos
	)			[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::update	(	const IdPath &	id,
		const ::DDS::DataReaderQos &	qos
	)			[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::update	(	const IdPath &	id,
		const ::DDS::PublisherQos &	qos
	)			[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::update	(	const IdPath &	id,
		const ::DDS::DataWriterQos &	qos
	)			[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::update	(	const IdPath &	id,
		const ::DDS::TopicQos &	qos
	)			[virtual]

Implements Update::Updater.

void Update::PersistenceUpdater::update	(	const IdPath &	id,
		const ::DDS::DomainParticipantQos &	qos
	)			[virtual]

Persist updated Qos parameters for an entity.

Implements Update::Updater.

---

Member Data Documentation

ActorIndex* Update::PersistenceUpdater::actor_index_ [private]

ALLOCATOR* Update::PersistenceUpdater::allocator_ [private]

ParticipantIndex* Update::PersistenceUpdater::participant_index_ [private]

ACE_TString Update::PersistenceUpdater::persistence_file_ [private]

bool Update::PersistenceUpdater::reset_ [private]

TopicIndex* Update::PersistenceUpdater::topic_index_ [private]

Manager* Update::PersistenceUpdater::um_ [private]

---

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

• PersistenceUpdater.h
• PersistenceUpdater.cpp

---