The replica observer. More...

defined in <ArmarXCore/applications/ArmarXStorm/IceStorm/Election.ice>

interface ReplicaObserver { ... }

Public Types
typedef ReplicaObserverPtr	PointerType

typedef ReplicaObserverPrx	ProxyType

Operations
bool	_iceD_addSubscriber (::IceInternal::Incoming &, const ::Ice::Current &)

bool	_iceD_createTopic (::IceInternal::Incoming &, const ::Ice::Current &)

bool	_iceD_destroyTopic (::IceInternal::Incoming &, const ::Ice::Current &)

bool	_iceD_init (::IceInternal::Incoming &, const ::Ice::Current &)

bool	_iceD_removeSubscriber (::IceInternal::Incoming &, const ::Ice::Current &)

virtual bool	_iceDispatch (::IceInternal::Incoming &, const ::Ice::Current &)

virtual void	addSubscriber (const ::IceStormElection::LogUpdate &, const ::std::string &, const ::IceStorm::SubscriberRecord &, const ::Ice::Current &=::Ice::emptyCurrent)=0

void	addSubscriber (LogUpdate llu, string topic, IceStorm::SubscriberRecord record) throws ObserverInconsistencyException
	Add a subscriber to a topic. More...

virtual void	createTopic (const ::IceStormElection::LogUpdate &, const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent)=0

void	createTopic (LogUpdate llu, string name) throws ObserverInconsistencyException
	Create the topic with the given name. More...

virtual void	destroyTopic (const ::IceStormElection::LogUpdate &, const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent)=0

void	destroyTopic (LogUpdate llu, string name) throws ObserverInconsistencyException
	Destroy the topic with the given name. More...

virtual const ::std::string &	ice_id (const ::Ice::Current &=::Ice::emptyCurrent) const

virtual ::std::vector<::std::string >	ice_ids (const ::Ice::Current &=::Ice::emptyCurrent) const

virtual bool	ice_isA (const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent) const

virtual void	init (const ::IceStormElection::LogUpdate &, const ::IceStormElection::TopicContentSeq &, const ::Ice::Current &=::Ice::emptyCurrent)=0

void	init (LogUpdate llu, TopicContentSeq content) throws ObserverInconsistencyException
	Initialize the observer. More...

virtual void	removeSubscriber (const ::IceStormElection::LogUpdate &, const ::std::string &, const ::Ice::IdentitySeq &, const ::Ice::Current &=::Ice::emptyCurrent)=0

void	removeSubscriber (LogUpdate llu, string topic, Ice::IdentitySeq subscribers) throws ObserverInconsistencyException
	Remove a subscriber from a topic. More...

virtual	~ReplicaObserver ()

Static Public Member Functions
static const ::std::string &	ice_staticId ()

Protected Member Functions
virtual void	_iceReadImpl (::Ice::InputStream *)

virtual void	_iceWriteImpl (::Ice::OutputStream *) const

Detailed Description

The replica observer.

Definition at line 43 of file Election.ice.

Member Typedef Documentation

◆ PointerType

typedef ReplicaObserverPtr PointerType

Definition at line 2511 of file Election.h.

◆ ProxyType

typedef ReplicaObserverPrx ProxyType

Definition at line 2510 of file Election.h.

Constructor & Destructor Documentation

◆ ~ReplicaObserver()

~ReplicaObserver ( )

virtual

Definition at line 1800 of file Election.cpp.

Operation Documentation

◆ _iceD_addSubscriber()

bool _iceD_addSubscriber	(	::IceInternal::Incoming &	inS,
		const ::Ice::Current &	current
	)

Definition at line 1899 of file Election.cpp.

◆ _iceD_createTopic()

bool _iceD_createTopic	(	::IceInternal::Incoming &	inS,
		const ::Ice::Current &	current
	)

Definition at line 1867 of file Election.cpp.

◆ _iceD_destroyTopic()

bool _iceD_destroyTopic	(	::IceInternal::Incoming &	inS,
		const ::Ice::Current &	current
	)

Definition at line 1883 of file Election.cpp.

◆ _iceD_init()

bool _iceD_init	(	::IceInternal::Incoming &	inS,
		const ::Ice::Current &	current
	)

Definition at line 1851 of file Election.cpp.

◆ _iceD_removeSubscriber()

bool _iceD_removeSubscriber	(	::IceInternal::Incoming &	inS,
		const ::Ice::Current &	current
	)

Definition at line 1917 of file Election.cpp.

◆ _iceDispatch()

bool _iceDispatch	(	::IceInternal::Incoming &	in,
		const ::Ice::Current &	current
	)

virtual

Definition at line 1949 of file Election.cpp.

◆ _iceReadImpl()

void _iceReadImpl ( ::Ice::InputStream * istr )

protectedvirtual

Definition at line 2018 of file Election.cpp.

Here is the call graph for this function:

◆ _iceWriteImpl()

void _iceWriteImpl ( ::Ice::OutputStream * ostr ) const

protectedvirtual

Definition at line 2010 of file Election.cpp.

Here is the call graph for this function:

◆ addSubscriber() [1/2]

virtual void addSubscriber	(	const ::IceStormElection::LogUpdate &	,
		const ::std::string &	,
		const ::IceStorm::SubscriberRecord &	,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)

pure virtual

◆ addSubscriber() [2/2]

void addSubscriber	(	LogUpdate	llu,
		string	topic,
		IceStorm::SubscriberRecord	record
	)		throws ObserverInconsistencyException

Add a subscriber to a topic.

Parameters

llu	The log update token.
topic	The topic name to which to add the subscriber.
record	The subscriber information.

Exceptions

ObserverInconsistencyException Raised if an inconsisency was detected.

◆ createTopic() [1/2]

virtual void createTopic	(	const ::IceStormElection::LogUpdate &	,
		const ::std::string &	,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)

pure virtual

◆ createTopic() [2/2]

void createTopic	(	LogUpdate	llu,
		string	name
	)		throws ObserverInconsistencyException

Create the topic with the given name.

Parameters

llu	The log update token.
name	The topic name.

Exceptions

ObserverInconsistencyException Raised if an inconsisency was detected.

◆ destroyTopic() [1/2]

virtual void destroyTopic	(	const ::IceStormElection::LogUpdate &	,
		const ::std::string &	,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)

pure virtual

◆ destroyTopic() [2/2]

void destroyTopic	(	LogUpdate	llu,
		string	name
	)		throws ObserverInconsistencyException

Destroy the topic with the given name.

Parameters

llu	The log update token.
name	The topic name.

Exceptions

ObserverInconsistencyException Raised if an inconsisency was detected.

◆ ice_id()

const ::std::string & ice_id ( const ::Ice::Current & = ::Ice::emptyCurrent ) const

virtual

Definition at line 1834 of file Election.cpp.

◆ ice_ids()

std::vector<::std::string > ice_ids ( const ::Ice::Current & = ::Ice::emptyCurrent ) const

Definition at line 1827 of file Election.cpp.

◆ ice_isA()

bool ice_isA	(	const ::std::string &	s,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)		const

virtual

Definition at line 1819 of file Election.cpp.

Here is the call graph for this function:

◆ ice_staticId()

const ::std::string & ice_staticId ( )

static

Definition at line 1840 of file Election.cpp.

Here is the caller graph for this function:

◆ init() [1/2]

virtual void init	(	const ::IceStormElection::LogUpdate &	,
		const ::IceStormElection::TopicContentSeq &	,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)

pure virtual

◆ init() [2/2]

void init	(	LogUpdate	llu,
		TopicContentSeq	content
	)		throws ObserverInconsistencyException

Initialize the observer.

Parameters

llu	The last log update seen by the master.
content	The topic content.

Exceptions

ObserverInconsistencyException Raised if an inconsisency was detected.

◆ removeSubscriber() [1/2]

virtual void removeSubscriber	(	const ::IceStormElection::LogUpdate &	,
		const ::std::string &	,
		const ::Ice::IdentitySeq &	,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)

pure virtual

◆ removeSubscriber() [2/2]

void removeSubscriber	(	LogUpdate	llu,
		string	topic,
		Ice::IdentitySeq	subscribers
	)		throws ObserverInconsistencyException

Remove a subscriber from a topic.

Parameters

llu	The log update token.
name	The topic name.
subscribers	The identities of the subscribers to remove.

Exceptions

ObserverInconsistencyException Raised if an inconsisency was detected.

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

ArmarXCore/applications/ArmarXStorm/IceStorm/Election.ice
ArmarXCore/applications/ArmarXStorm/IceStorm/generated/IceStorm/Election.h
ArmarXCore/applications/ArmarXStorm/IceStorm/generated/Election.cpp

Public Types

Operations

Static Public Member Functions

Protected Member Functions

Detailed Description

Member Typedef Documentation

◆ PointerType

◆ ProxyType

Constructor & Destructor Documentation

◆ ~ReplicaObserver()

Operation Documentation

◆ _iceD_addSubscriber()

◆ _iceD_createTopic()

◆ _iceD_destroyTopic()

◆ _iceD_init()

◆ _iceD_removeSubscriber()

◆ _iceDispatch()

◆ _iceReadImpl()

◆ _iceWriteImpl()

◆ addSubscriber() [1/2]

◆ addSubscriber() [2/2]

◆ createTopic() [1/2]

◆ createTopic() [2/2]

◆ destroyTopic() [1/2]

◆ destroyTopic() [2/2]

◆ ice_id()

◆ ice_ids()

◆ ice_isA()

◆ ice_staticId()

◆ init() [1/2]

◆ init() [2/2]

◆ removeSubscriber() [1/2]

◆ removeSubscriber() [2/2]