ReplicaObserver Class Referenceabstract

The replica observer. More...

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

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.

Definition at line 43 of file Election.ice.

Member Typedef Documentation

◆ PointerType

Definition at line 2511 of file Election.h.

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

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ _iceD_createTopic()

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

Definition at line 1867 of file Election.cpp.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ _iceD_destroyTopic()

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

Definition at line 1883 of file Election.cpp.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ _iceD_init()

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

Definition at line 1851 of file Election.cpp.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ _iceD_removeSubscriber()

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

Definition at line 1917 of file Election.cpp.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ _iceDispatch()

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

Definition at line 1949 of file Election.cpp.

+ Here is the call graph for this function:

◆ _iceReadImpl()

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

Definition at line 2018 of file Election.cpp.

◆ _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
lluThe log update token.
topicThe topic name to which to add the subscriber.
recordThe subscriber information.
Exceptions
ObserverInconsistencyExceptionRaised if an inconsisency was detected.
+ Here is the caller graph for this function:

◆ 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
lluThe log update token.
nameThe topic name.
Exceptions
ObserverInconsistencyExceptionRaised if an inconsisency was detected.
+ Here is the caller graph for this function:

◆ 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
lluThe log update token.
nameThe topic name.
Exceptions
ObserverInconsistencyExceptionRaised if an inconsisency was detected.
+ Here is the caller graph for this function:

◆ ice_id()

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

Definition at line 1834 of file Election.cpp.

+ Here is the call graph for this function:

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

◆ 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
lluThe last log update seen by the master.
contentThe topic content.
Exceptions
ObserverInconsistencyExceptionRaised if an inconsisency was detected.
+ Here is the caller graph for this function:

◆ 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
lluThe log update token.
nameThe topic name.
subscribersThe identities of the subscribers to remove.
Exceptions
ObserverInconsistencyExceptionRaised if an inconsisency was detected.
+ Here is the caller graph for this function:

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