The replica observer.
More...
defined in <ArmarXCore/applications/ArmarXStorm/IceStorm/Election.ice>
interface ReplicaObserver extends Ice::Object { ... }
|
| 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 () |
| |
The replica observer.
Definition at line 43 of file Election.ice.
◆ PointerType
◆ ProxyType
◆ ~ReplicaObserver()
◆ _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]
◆ addSubscriber() [2/2]
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
-
◆ createTopic() [1/2]
◆ createTopic() [2/2]
Create the topic with the given name.
- Parameters
-
| llu | The log update token. |
| name | The topic name. |
- Exceptions
-
◆ destroyTopic() [1/2]
◆ destroyTopic() [2/2]
Destroy the topic with the given name.
- Parameters
-
| llu | The log update token. |
| name | The topic name. |
- Exceptions
-
◆ 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]
◆ init() [2/2]
Initialize the observer.
- Parameters
-
| llu | The last log update seen by the master. |
| content | The topic content. |
- Exceptions
-
◆ 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]
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
-
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