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 42 of file Election.ice.

Member Typedef Documentation

◆ PointerType

typedef ReplicaObserverPtr PointerType

Definition at line 1566 of file Election.h.

◆ ProxyType

typedef ReplicaObserverPrx ProxyType

Definition at line 1565 of file Election.h.

Constructor & Destructor Documentation

◆ ~ReplicaObserver()

~ReplicaObserver ( )

virtual

Definition at line 1560 of file Election.cpp.

Operation Documentation

◆ _iceD_addSubscriber()

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

Definition at line 1655 of file Election.cpp.

◆ _iceD_createTopic()

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

Definition at line 1625 of file Election.cpp.

◆ _iceD_destroyTopic()

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

Definition at line 1640 of file Election.cpp.

◆ _iceD_init()

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

Definition at line 1610 of file Election.cpp.

◆ _iceD_removeSubscriber()

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

Definition at line 1672 of file Election.cpp.

◆ _iceDispatch()

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

virtual

Definition at line 1706 of file Election.cpp.

◆ _iceReadImpl()

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

protectedvirtual

Definition at line 1769 of file Election.cpp.

Here is the call graph for this function:

◆ _iceWriteImpl()

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

protectedvirtual

Definition at line 1761 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 1593 of file Election.cpp.

◆ ice_ids()

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

Definition at line 1587 of file Election.cpp.

◆ ice_isA()

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

virtual

Definition at line 1581 of file Election.cpp.

Here is the call graph for this function:

◆ ice_staticId()

const ::std::string & ice_staticId ( )

static

Definition at line 1599 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]