A replica node. More...

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

interface Node { ... }

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. 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 ()

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.

Definition at line 202 of file Election.ice.

Member Typedef Documentation

◆ PointerType

typedef NodePtr PointerType

Definition at line 1650 of file Election.h.

◆ ProxyType

typedef NodePrx ProxyType

Definition at line 1649 of file Election.h.

Constructor & Destructor Documentation

◆ ~Node()

~Node ( )

virtual

Definition at line 1928 of file Election.cpp.

Operation Documentation

◆ _iceD_accept()

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

Definition at line 2014 of file Election.cpp.

◆ _iceD_areYouCoordinator()

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

Definition at line 2037 of file Election.cpp.

◆ _iceD_areYouThere()

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

Definition at line 2049 of file Election.cpp.

◆ _iceD_invitation()

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

Definition at line 1978 of file Election.cpp.

◆ _iceD_nodes()

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

Definition at line 2078 of file Election.cpp.

◆ _iceD_query()

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

Definition at line 2090 of file Election.cpp.

◆ _iceD_ready()

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

Definition at line 1993 of file Election.cpp.

◆ _iceD_sync()

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

Definition at line 2066 of file Election.cpp.

◆ _iceDispatch()

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

virtual

Definition at line 2122 of file Election.cpp.

◆ _iceReadImpl()

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

protectedvirtual

Definition at line 2197 of file Election.cpp.

Here is the call graph for this function:

◆ _iceWriteImpl()

void _iceWriteImpl ( ::Ice::OutputStream * ostr ) const

protectedvirtual

Definition at line 2189 of file Election.cpp.

Here is the call graph for this function:

◆ 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

j	The id of the node accepting the invitation.
observer	The observer.
gn	The group name.
forwardedInvites	The ids of the nodes to which invitations were forwarded.
llu	The last log update for the given node.
max	The 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

gn	The group name.
j	The 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

Definition at line 1961 of file Election.cpp.

◆ ice_ids()

std::vector<::std::string > ice_ids ( const ::Ice::Current & = ::Ice::emptyCurrent ) const

Definition at line 1955 of file Election.cpp.

◆ ice_isA()

bool ice_isA	(	const ::std::string &	s,
		const ::Ice::Current &	= `::Ice::emptyCurrent`
	)		const

virtual

Definition at line 1949 of file Election.cpp.

Here is the call graph for this function:

◆ ice_staticId()

const ::std::string & ice_staticId ( )

static

Definition at line 1967 of file Election.cpp.

◆ 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

gn	The group name.
j	The 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

j	The group coordinator.
gn	The group name.
coordinator	The proxy to the coordinator.
max	The highest priority node seen by this replica group.
generation	The 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.

Here is the caller graph for this function:

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

ArmarXCore/applications/ArmarXStorm/IceStorm/Election.ice
ArmarXCore/applications/ArmarXStorm/IceStorm/generated/IceStorm/Election.h
ArmarXCore/applications/ArmarXStorm/IceStorm/generated/Election.cpp

Public Types

Operations

Static Public Member Functions

Protected Member Functions

Detailed Description

Member Typedef Documentation

◆ PointerType

◆ ProxyType

Constructor & Destructor Documentation

◆ ~Node()

Operation Documentation

◆ _iceD_accept()

◆ _iceD_areYouCoordinator()

◆ _iceD_areYouThere()

◆ _iceD_invitation()

◆ _iceD_nodes()

◆ _iceD_query()

◆ _iceD_ready()

◆ _iceD_sync()

◆ _iceDispatch()

◆ _iceReadImpl()

◆ _iceWriteImpl()

◆ accept() [1/2]

◆ accept() [2/2]

◆ areYouCoordinator() [1/2]

◆ areYouCoordinator() [2/2]

◆ areYouThere() [1/2]

◆ areYouThere() [2/2]

◆ ice_id()

◆ ice_ids()

◆ ice_isA()

◆ ice_staticId()

◆ invitation() [1/2]

◆ invitation() [2/2]

◆ nodes() [1/2]

◆ nodes() [2/2]

◆ query() [1/2]

◆ query() [2/2]

◆ ready() [1/2]

◆ ready() [2/2]

◆ sync() [1/2]

◆ sync() [2/2]