The replica observer. More...

defined in <ArmarXCore/applications/ArmarXStorm/IceStorm/generated/IceStorm/Election.h>

interface ReplicaObserver extends Ice::Object { ... }

Inheritance diagram for 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.

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.

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.

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.

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.

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.

Member Typedef Documentation

◆ PointerType

typedef ReplicaObserverPtr PointerType

◆ ProxyType

typedef ReplicaObserverPrx ProxyType

Constructor & Destructor Documentation

◆ ~ReplicaObserver()

~ReplicaObserver ( )

virtual

Operation Documentation

◆ _iceD_addSubscriber()

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

◆ _iceD_createTopic()

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

◆ _iceD_destroyTopic()

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

◆ _iceD_init()

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

◆ _iceD_removeSubscriber()

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

◆ _iceDispatch()

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

virtual

◆ _iceReadImpl()

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

protectedvirtual

◆ _iceWriteImpl()

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

protectedvirtual

◆ 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

◆ ice_ids()

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

◆ ice_isA()

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

virtual

◆ ice_staticId()

const::std::string & ice_staticId ( )

static

◆ 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]