TopicManagerImpl Class Reference

#include <ArmarXCore/applications/ArmarXStorm/IceStorm/TopicManagerI.h>

+ Inheritance diagram for TopicManagerImpl:

Public Member Functions

TopicPrx create (const std::string &)
 
void getContent (IceStormElection::LogUpdate &, IceStormElection::TopicContentSeq &)
 
virtual IceStormElection::LogUpdate getLastLogUpdate () const
 
virtual Ice::ObjectPrx getObserver () const
 
Ice::ObjectPtr getServant () const
 
virtual Ice::ObjectPrx getSync () const
 
virtual void initMaster (const std::set< IceStormElection::GroupNodeInfo > &, const IceStormElection::LogUpdate &)
 
void observerAddSubscriber (const IceStormElection::LogUpdate &, const std::string &, const IceStorm::SubscriberRecord &)
 
void observerCreateTopic (const IceStormElection::LogUpdate &, const std::string &)
 
void observerDestroyTopic (const IceStormElection::LogUpdate &, const std::string &)
 
void observerInit (const IceStormElection::LogUpdate &, const IceStormElection::TopicContentSeq &)
 
void observerRemoveSubscriber (const IceStormElection::LogUpdate &, const std::string &, const Ice::IdentitySeq &)
 
void reap ()
 
TopicPrx retrieve (const std::string &) const
 
TopicDict retrieveAll () const
 
void shutdown ()
 
virtual void sync (const Ice::ObjectPrx &)
 
 TopicManagerImpl (const PersistentInstancePtr &)
 
- Public Member Functions inherited from Replica
virtual void initMaster (const std::set< IceStormElection::GroupNodeInfo > &, const LogUpdate &)=0
 
- Public Member Functions inherited from ObserverUpdater
virtual ~ObserverUpdater ()
 

Additional Inherited Members

- Public Types inherited from ObserverUpdater
typedef ObserverUpdaterPtr PointerType
 

Constructor & Destructor Documentation

◆ TopicManagerImpl()

Member Function Documentation

◆ create()

TopicPrx create ( const std::string & )

◆ getContent()

void getContent ( IceStormElection::LogUpdate & llu,
IceStormElection::TopicContentSeq & content )

◆ getLastLogUpdate()

LogUpdate getLastLogUpdate ( ) const
virtual

Implements Replica.

◆ getObserver()

Ice::ObjectPrx getObserver ( ) const
virtual

Implements Replica.

◆ getServant()

Ice::ObjectPtr getServant ( ) const

◆ getSync()

Ice::ObjectPrx getSync ( ) const
virtual

Implements Replica.

◆ initMaster()

void initMaster ( const std::set< IceStormElection::GroupNodeInfo > & ,
const IceStormElection::LogUpdate &  )
virtual

◆ observerAddSubscriber()

void observerAddSubscriber ( const IceStormElection::LogUpdate & ,
const std::string & ,
const IceStorm::SubscriberRecord &  )

◆ observerCreateTopic()

void observerCreateTopic ( const IceStormElection::LogUpdate & ,
const std::string &  )

◆ observerDestroyTopic()

void observerDestroyTopic ( const IceStormElection::LogUpdate & ,
const std::string &  )

◆ observerInit()

void observerInit ( const IceStormElection::LogUpdate & llu,
const IceStormElection::TopicContentSeq & content )

◆ observerRemoveSubscriber()

void observerRemoveSubscriber ( const IceStormElection::LogUpdate & ,
const std::string & ,
const Ice::IdentitySeq &  )

◆ reap()

void reap ( )

◆ retrieve()

TopicPrx retrieve ( const std::string & ) const

◆ retrieveAll()

TopicDict retrieveAll ( ) const

◆ shutdown()

void shutdown ( )

◆ sync()

void sync ( const Ice::ObjectPrx & master)
virtual

Implements Replica.


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