List of all members | Public Member Functions
NodeI Class Reference

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

+ Inheritance diagram for NodeI:

Public Member Functions

virtual void accept (int, const std::string &, const Ice::IntSeq &, const Ice::ObjectPrx &, const LogUpdate &, int, const Ice::Current &)
 
virtual bool areYouCoordinator (const Ice::Current &) const
 
virtual bool areYouThere (const std::string &, int, const Ice::Current &) const
 
void check ()
 
void checkObserverInit (Ice::Long)
 
void destroy ()
 
void finishUpdate ()
 
virtual void invitation (int, const std::string &, const Ice::Current &)
 
void merge (const std::set< int > &)
 
void mergeContinue ()
 
 NodeI (const IceStorm::InstancePtr &, const ReplicaPtr &, const Ice::ObjectPrx &, int, const std::map< int, NodePrx > &)
 
virtual NodeInfoSeq nodes (const Ice::Current &) const
 
virtual QueryInfo query (const Ice::Current &) const
 
virtual void ready (int, const std::string &, const Ice::ObjectPrx &, int, Ice::Long, const Ice::Current &)
 
void recovery (Ice::Long=-1)
 
void start ()
 
Ice::ObjectPrx startCachedRead (Ice::Long &, const char *, int)
 
void startObserverUpdate (Ice::Long, const char *, int)
 
Ice::ObjectPrx startUpdate (Ice::Long &, const char *, int)
 
virtual Ice::ObjectPrx sync (const Ice::Current &) const
 
void timeout ()
 
bool updateMaster (const char *, int)
 
- Public Member Functions inherited from Node
bool _iceD_accept (::IceInternal::Incoming &, const ::Ice::Current &)
 
bool _iceD_areYouCoordinator (::IceInternal::Incoming &, const ::Ice::Current &) const
 
bool _iceD_areYouThere (::IceInternal::Incoming &, const ::Ice::Current &) const
 
bool _iceD_invitation (::IceInternal::Incoming &, const ::Ice::Current &)
 
bool _iceD_nodes (::IceInternal::Incoming &, const ::Ice::Current &) const
 
bool _iceD_query (::IceInternal::Incoming &, const ::Ice::Current &) const
 
bool _iceD_ready (::IceInternal::Incoming &, const ::Ice::Current &)
 
bool _iceD_sync (::IceInternal::Incoming &, const ::Ice::Current &) const
 
virtual bool _iceDispatch (::IceInternal::Incoming &, const ::Ice::Current &)
 
virtual void accept (::Ice::Int, const ::std::string &, const ::Ice::IntSeq &, const ::Ice::ObjectPrx &, const ::IceStormElection::LogUpdate &, ::Ice::Int, const ::Ice::Current &=::Ice::emptyCurrent)=0
 
void accept (int j, string gn, Ice::IntSeq forwardedInvites, Object *observer, LogUpdate llu, int max)
 Called to accept an invitation into the given group. More...
 
idempotent bool areYouCoordinator ()
 Determine if this node is a coordinator. More...
 
virtual bool areYouCoordinator (const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
virtual bool areYouThere (const ::std::string &, ::Ice::Int, const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
idempotent bool areYouThere (string gn, int j)
 Determine if the node is a member of the given group with the given coordinator. 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 invitation (::Ice::Int, const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent)=0
 
void invitation (int j, string gn)
 Invite the node into a group with the given coordinator and group name. More...
 
idempotent NodeInfoSeq nodes ()
 Get the replication group information. More...
 
virtual ::IceStormElection::NodeInfoSeq nodes (const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
idempotent QueryInfo query ()
 Get the query information for the given node. More...
 
virtual ::IceStormElection::QueryInfo query (const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
virtual void ready (::Ice::Int, const ::std::string &, const ::Ice::ObjectPrx &, ::Ice::Int, ::Ice::Long, const ::Ice::Current &=::Ice::emptyCurrent)=0
 
void ready (int j, string gn, Object *coordinator, int max, long generation)
 Call from the group coordinator to a node to inform the node that the replica group is active. More...
 
idempotent Object * sync ()
 Get the sync object for the replica hosted by this node. More...
 
virtual ::Ice::ObjectPrx sync (const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
virtual ~Node ()
 

Additional Inherited Members

- Public Types inherited from Node
typedef NodePtr PointerType
 
typedef NodePrx ProxyType
 
- Static Public Member Functions inherited from Node
static const ::std::string & ice_staticId ()
 
- Protected Member Functions inherited from Node
virtual void _iceReadImpl (::Ice::InputStream *)
 
virtual void _iceWriteImpl (::Ice::OutputStream *) const
 

Detailed Description

Definition at line 28 of file NodeI.h.

Constructor & Destructor Documentation

◆ NodeI()

NodeI ( const IceStorm::InstancePtr &  instance,
const ReplicaPtr &  replica,
const Ice::ObjectPrx &  replicaProxy,
int  id,
const std::map< int, NodePrx > &  nodes 
)

Definition at line 169 of file NodeI.cpp.

Member Function Documentation

◆ accept()

void accept ( int  ,
const std::string &  ,
const Ice::IntSeq &  ,
const Ice::ObjectPrx &  ,
const LogUpdate &  ,
int  ,
const Ice::Current &   
)
virtual

Definition at line 901 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ areYouCoordinator()

bool areYouCoordinator ( const Ice::Current &  ) const
virtual

Definition at line 972 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ areYouThere()

bool areYouThere ( const std::string &  ,
int  ,
const Ice::Current &   
) const
virtual

Definition at line 979 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ check()

void check ( )

Definition at line 235 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ checkObserverInit()

void checkObserverInit ( Ice::Long  )

Definition at line 1119 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ destroy()

void destroy ( )

Definition at line 1084 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ finishUpdate()

void finishUpdate ( )

Definition at line 1235 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ invitation()

void invitation ( int  ,
const std::string &  ,
const Ice::Current &   
)
virtual

Definition at line 724 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ merge()

void merge ( const std::set< int > &  )

Definition at line 419 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ mergeContinue()

void mergeContinue ( )

Definition at line 529 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ nodes()

NodeInfoSeq nodes ( const Ice::Current &  ) const
virtual

Definition at line 992 of file NodeI.cpp.

◆ query()

QueryInfo query ( const Ice::Current &  ) const
virtual

Definition at line 1007 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ ready()

void ready ( int  ,
const std::string &  ,
const Ice::ObjectPrx &  ,
int  ,
Ice::Long  ,
const Ice::Current &   
)
virtual

Definition at line 853 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ recovery()

void recovery ( Ice::Long  generation = -1)

Definition at line 1030 of file NodeI.cpp.

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

◆ start()

void start ( )

Definition at line 204 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ startCachedRead()

Ice::ObjectPrx startCachedRead ( Ice::Long &  generation,
const char *  file,
int  line 
)

Definition at line 1195 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ startObserverUpdate()

void startObserverUpdate ( Ice::Long  generation,
const char *  file,
int  line 
)

Definition at line 1212 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ startUpdate()

Ice::ObjectPrx startUpdate ( Ice::Long &  generation,
const char *  file,
int  line 
)

Definition at line 1135 of file NodeI.cpp.

+ Here is the call graph for this function:

◆ sync()

Ice::ObjectPrx sync ( const Ice::Current &  ) const
virtual

Definition at line 986 of file NodeI.cpp.

◆ timeout()

void timeout ( )

Definition at line 371 of file NodeI.cpp.

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

◆ updateMaster()

bool updateMaster ( const char *  ,
int   
)

Definition at line 1164 of file NodeI.cpp.

+ Here is the call graph for this function:
The documentation for this class was generated from the following files: