Node Class Referenceabstract

A replica node. More...

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

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

+ Inheritance diagram for Node:

Public Types

typedef NodePtr PointerType
 
typedef NodePrx ProxyType
 

Operations

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.
 
idempotent bool areYouCoordinator ()
 Determine if this node is a coordinator.
 
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.
 
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.
 
idempotent NodeInfoSeq nodes ()
 Get the replication group information.
 
virtual::IceStormElection::NodeInfoSeq nodes (const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
idempotent QueryInfo query ()
 Get the query information for the given node.
 
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.
 
idempotent Object * sync ()
 Get the sync object for the replica hosted by this node.
 
virtual::Ice::ObjectPrx sync (const ::Ice::Current &=::Ice::emptyCurrent) const =0
 
virtual ~Node ()
 

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

A replica node.

Member Typedef Documentation

◆ PointerType

◆ ProxyType

typedef NodePrx ProxyType

Constructor & Destructor Documentation

◆ ~Node()

~Node ( )
virtual

Operation Documentation

◆ _iceD_accept()

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

◆ _iceD_areYouCoordinator()

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

◆ _iceD_areYouThere()

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

◆ _iceD_invitation()

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

◆ _iceD_nodes()

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

◆ _iceD_query()

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

◆ _iceD_ready()

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

◆ _iceD_sync()

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

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

◆ accept() [1/2]

virtual void accept ( ::Ice::Int ,
const ::std::string & ,
const ::Ice::IntSeq & ,
const ::Ice::ObjectPrx & ,
const ::IceStormElection::LogUpdate & ,
::Ice::Int ,
const ::Ice::Current & = ::Ice::emptyCurrent )
pure virtual

◆ accept() [2/2]

void accept ( int j,
string gn,
Ice::IntSeq forwardedInvites,
Object * observer,
LogUpdate llu,
int max )

Called to accept an invitation into the given group.

Parameters
jThe id of the node accepting the invitation.
observerThe observer.
gnThe group name.
forwardedInvitesThe ids of the nodes to which invitations were forwarded.
lluThe last log update for the given node.
maxThe highest priority node seen by this replica group.

◆ areYouCoordinator() [1/2]

["cpp:const"]
idempotent bool areYouCoordinator ( )

Determine if this node is a coordinator.

Returns
True if the node is a coordinator, false otherwise.

◆ areYouCoordinator() [2/2]

virtual bool areYouCoordinator ( const ::Ice::Current & = ::Ice::emptyCurrent) const
pure virtual

◆ areYouThere() [1/2]

virtual bool areYouThere ( const ::std::string & ,
::Ice::Int ,
const ::Ice::Current & = ::Ice::emptyCurrent ) const
pure virtual

◆ areYouThere() [2/2]

["cpp:const"]
idempotent bool areYouThere ( string gn,
int j )

Determine if the node is a member of the given group with the given coordinator.

Parameters
gnThe group name.
jThe group coordinator.
Returns
True if the node is a member, false otherwise.

◆ 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

◆ invitation() [1/2]

virtual void invitation ( ::Ice::Int ,
const ::std::string & ,
const ::Ice::Current & = ::Ice::emptyCurrent )
pure virtual

◆ invitation() [2/2]

void invitation ( int j,
string gn )

Invite the node into a group with the given coordinator and group name.

Parameters
gnThe group name.
jThe group coordinator.

◆ nodes() [1/2]

["cpp:const"]
idempotent NodeInfoSeq nodes ( )

Get the replication group information.

Returns
The set of configured nodes and the associated priority.

◆ nodes() [2/2]

virtual::IceStormElection::NodeInfoSeq nodes ( const ::Ice::Current & = ::Ice::emptyCurrent) const
pure virtual

◆ query() [1/2]

["cpp:const"]
idempotent QueryInfo query ( )

Get the query information for the given node.

Returns
The query information.

◆ query() [2/2]

virtual::IceStormElection::QueryInfo query ( const ::Ice::Current & = ::Ice::emptyCurrent) const
pure virtual

◆ ready() [1/2]

virtual void ready ( ::Ice::Int ,
const ::std::string & ,
const ::Ice::ObjectPrx & ,
::Ice::Int ,
::Ice::Long ,
const ::Ice::Current & = ::Ice::emptyCurrent )
pure virtual

◆ ready() [2/2]

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.

Parameters
jThe group coordinator.
gnThe group name.
coordinatorThe proxy to the coordinator.
maxThe highest priority node seen by this replica group.
generationThe current generation count.

◆ sync() [1/2]

["cpp:const"]
idempotent Object * sync ( )

Get the sync object for the replica hosted by this node.

Returns
The sync object.

◆ sync() [2/2]

virtual::Ice::ObjectPrx sync ( const ::Ice::Current & = ::Ice::emptyCurrent) const
pure virtual

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