#include <DirectRouting.h>

Inheritance diagram for m2etis::pubsub::routing::DirectRouting< NetworkType >:

Public Types
typedef message::DirectRoutingInfo< NetworkType >	RoutingInfoType

typedef std::vector< typename NetworkType::Key >	KeyList

typedef std::pair< uint64_t, typename NetworkType::Key >	TimePair

typedef std::vector< TimePair >	TimeList

Public Member Functions
	DirectRouting (const unsigned short topic_name, PubSubSystemEnvironment *pssi, const typename NetworkType::Key &root)

virtual	~DirectRouting ()

void	setSelf (const typename NetworkType::Key &self)

void	setUnsubscriptionListener (const boost::function< void(const typename NetworkType::Key)> &listener)

void	selfSubscribed (const bool b)

bool	selfSubscribed () const

void	configureRoutingInfo (message::ActionType &msgType, typename message::RoutingInfo< NetworkType >::Ptr routingInfo, typename NetworkType::Key &)

KeyList	getTargetNodes (const message::ActionType mtype, typename message::RoutingInfo< NetworkType >::Ptr routingInfo, typename NetworkType::Key &) const

bool	processSubscribePayload (typename message::RoutingInfo< NetworkType >::Ptr routingInfo, const typename NetworkType::Key &sender, typename NetworkType::Key &, message::ActionType &) override

void	processUnsubscribePayload (typename message::RoutingInfo< NetworkType >::Ptr routingInfo, const typename NetworkType::Key &sender, typename NetworkType::Key &, message::ActionType &)

void	processPublishPayload (typename message::RoutingInfo< NetworkType >::Ptr routingInfo, const typename NetworkType::Key &, typename NetworkType::Key &, message::ActionType &msgType)

void	processNotifyPayload (typename message::RoutingInfo< NetworkType >::Ptr routingInfo, const typename NetworkType::Key &, typename NetworkType::Key &, message::ActionType &)

void	processControlPayload (typename message::RoutingInfo< NetworkType >::Ptr routingInfo, const typename NetworkType::Key &, typename NetworkType::Key &, message::ActionType &)

Public Member Functions inherited from m2etis::pubsub::routing::BaseRouting< NetworkType >
	BaseRouting (unsigned int, PubSubSystemEnvironment *)

virtual	~BaseRouting ()

void	configureSendCallback (const boost::function< void(typename message::RoutingInfo< NetworkType >::Ptr, const typename NetworkType::Key &, ControlTarget)> &func)
	with this function, new messages can be sent directly to nodes More...

Public Attributes
const uint64_t	periodic_

const uint64_t	purge_distance_

PubSubSystemEnvironment *	_pssi

boost::function< void(const typename NetworkType::Key)>	removed_subscriber_eventlistener_

uint64_t	purgeID_

Static Public Attributes
static const bool	register_forward_subscribe

static const bool	register_deliver_subscribe

static const bool	register_forward_unsubscribe

static const bool	register_deliver_unsubscribe

static const bool	periodicSubscribtion

Additional Inherited Members
Protected Attributes inherited from m2etis::pubsub::routing::BaseRouting< NetworkType >
boost::function< void(typename message::RoutingInfo< NetworkType >::Ptr, typename NetworkType::Key, ControlTarget)>	sendCtrlMsg_

Detailed Description

template<class NetworkType>
class m2etis::pubsub::routing::DirectRouting< NetworkType >

Definition at line 41 of file DirectRouting.h.

Member Typedef Documentation

template<class NetworkType >

typedef std::vector<typename NetworkType::Key> m2etis::pubsub::routing::DirectRouting< NetworkType >::KeyList

Definition at line 44 of file DirectRouting.h.

template<class NetworkType >

typedef message::DirectRoutingInfo<NetworkType> m2etis::pubsub::routing::DirectRouting< NetworkType >::RoutingInfoType

Definition at line 43 of file DirectRouting.h.

template<class NetworkType >

typedef std::vector<TimePair> m2etis::pubsub::routing::DirectRouting< NetworkType >::TimeList

Definition at line 46 of file DirectRouting.h.

template<class NetworkType >

typedef std::pair<uint64_t, typename NetworkType::Key> m2etis::pubsub::routing::DirectRouting< NetworkType >::TimePair

Definition at line 45 of file DirectRouting.h.

Constructor & Destructor Documentation

template<class NetworkType >

m2etis::pubsub::routing::DirectRouting< NetworkType >::DirectRouting	(	const unsigned short	topic_name,
		PubSubSystemEnvironment *	pssi,
		const typename NetworkType::Key &	root
	)

inline

Definition at line 81 of file DirectRouting.h.

Here is the call graph for this function:

template<class NetworkType >

virtual m2etis::pubsub::routing::DirectRouting< NetworkType >::~DirectRouting ( )

inlinevirtual

Definition at line 85 of file DirectRouting.h.

Here is the call graph for this function:

Member Function Documentation

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::configureRoutingInfo	(	message::ActionType &	msgType,
		typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		typename NetworkType::Key &	receiver
	)

inlinevirtual

Configures the periodic messages. Every node runs a thread that triggers subscribe messages. These messages are used for periodical tasks like heart beat, checking the cluster size etc. This means that the message is not always from type subscribe or does not have the same subscription information. Every strategy chooses how to use the periodic messages and can configure it in this function.

Parameters

mtype	Type of message to configure for
routingInfo	object to be configured with the necessary routing information

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 108 of file DirectRouting.h.

template<class NetworkType >

KeyList m2etis::pubsub::routing::DirectRouting< NetworkType >::getTargetNodes	(	const message::ActionType	mtype,
		typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		typename NetworkType::Key &
	)		const

inlinevirtual

Returns a list of target nodes for the specified message type and algoinfo in regard to the node's position in the logic distribution tree.

Parameters

mtype	the type of the message (SUBSCRIBE, UNSUBSCIBE, or PUBLISH)
algoinfo	only contains info if mytpe == PUBLISH

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 144 of file DirectRouting.h.

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::processControlPayload	(	typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		const typename NetworkType::Key &	sender,
		typename NetworkType::Key &	receiver,
		message::ActionType &	msgType
	)

inlinevirtual

Handles a control message. The routing information of this node is updated, a decision about continuing the workflow is made and saved in a routingInfo object together with the necessary information. Control messages are used by routing strategies, that do not build the tree implicitly with subscribe messages, but need more complex control commands.

Parameters

routingInfo	contains routing information provided by the sender, will be updated with routing decisions
sender	the senders's key

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 257 of file DirectRouting.h.

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::processNotifyPayload	(	typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		const typename NetworkType::Key &	,
		typename NetworkType::Key &	,
		message::ActionType &
	)

inlinevirtual

Handle a notify message

Parameters

sender	the notifier's key
algoinfo	the payload created by this algorithm at the notify's node

Returns: an information unit, whether the message should be spread out to subscribers ond if the current node is the root-node for that topic.

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 252 of file DirectRouting.h.

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::processPublishPayload	(	typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		const typename NetworkType::Key &	,
		typename NetworkType::Key &	,
		message::ActionType &	msgType
	)

inlinevirtual

Handle a publish message

Parameters

sender	the publisher's key
algoinfo	the payload created by this algorithm at the publisher's node

Returns: an information unit, whether the message should be spread out to subscribers ond if the current node is the root-node for that topic.

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 231 of file DirectRouting.h.

template<class NetworkType >

bool m2etis::pubsub::routing::DirectRouting< NetworkType >::processSubscribePayload	(	typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		const typename NetworkType::Key &	sender,
		typename NetworkType::Key &	,
		message::ActionType &
	)

inlineoverridevirtual

Handle a subscribe message

Parameters

sender	the subscriber's key
algoinfo	the payload created by this algorithm at the subscriber's node

Returns: an information unit, whether the message should be stopped or needs to be changed

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 182 of file DirectRouting.h.

Here is the call graph for this function:

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::processUnsubscribePayload	(	typename message::RoutingInfo< NetworkType >::Ptr	routingInfo,
		const typename NetworkType::Key &	sender,
		typename NetworkType::Key &	,
		message::ActionType &
	)

inlinevirtual

Handle a unsubscribe message

Parameters

sender	the unsubscriber's key
algoinfo	the payload created by this algorithm at the unsubscriber's node

Returns: an information unit, whether the message should be stopped or needs to be changed

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 211 of file DirectRouting.h.

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::selfSubscribed ( const bool b )

inline

Definition at line 99 of file DirectRouting.h.

template<class NetworkType >

bool m2etis::pubsub::routing::DirectRouting< NetworkType >::selfSubscribed ( ) const

inline

Definition at line 104 of file DirectRouting.h.

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::setSelf ( const typename NetworkType::Key & self )

inline

Definition at line 90 of file DirectRouting.h.

template<class NetworkType >

void m2etis::pubsub::routing::DirectRouting< NetworkType >::setUnsubscriptionListener ( const boost::function< void(const typename NetworkType::Key)> & listener )

inlinevirtual

Implements m2etis::pubsub::routing::BaseRouting< NetworkType >.

Definition at line 94 of file DirectRouting.h.

Member Data Documentation

template<class NetworkType >

PubSubSystemEnvironment* m2etis::pubsub::routing::DirectRouting< NetworkType >::_pssi

Definition at line 73 of file DirectRouting.h.

template<class NetworkType >

const uint64_t m2etis::pubsub::routing::DirectRouting< NetworkType >::periodic_

Definition at line 68 of file DirectRouting.h.

template<class NetworkType >

const bool m2etis::pubsub::routing::DirectRouting< NetworkType >::periodicSubscribtion

static

Definition at line 65 of file DirectRouting.h.

template<class NetworkType >

const uint64_t m2etis::pubsub::routing::DirectRouting< NetworkType >::purge_distance_

Definition at line 71 of file DirectRouting.h.

template<class NetworkType >

uint64_t m2etis::pubsub::routing::DirectRouting< NetworkType >::purgeID_

Definition at line 79 of file DirectRouting.h.

template<class NetworkType >

const bool m2etis::pubsub::routing::DirectRouting< NetworkType >::register_deliver_subscribe

static

Definition at line 55 of file DirectRouting.h.

template<class NetworkType >

const bool m2etis::pubsub::routing::DirectRouting< NetworkType >::register_deliver_unsubscribe

static

Definition at line 61 of file DirectRouting.h.

template<class NetworkType >

const bool m2etis::pubsub::routing::DirectRouting< NetworkType >::register_forward_subscribe

static

Definition at line 52 of file DirectRouting.h.

template<class NetworkType >

const bool m2etis::pubsub::routing::DirectRouting< NetworkType >::register_forward_unsubscribe

static

Definition at line 58 of file DirectRouting.h.

template<class NetworkType >

boost::function<void(const typename NetworkType::Key)> m2etis::pubsub::routing::DirectRouting< NetworkType >::removed_subscriber_eventlistener_

Definition at line 77 of file DirectRouting.h.

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

DirectRouting.h

Public Types

Public Member Functions

Public Attributes

Static Public Attributes

Additional Inherited Members

Detailed Description

template<class NetworkType> class m2etis::pubsub::routing::DirectRouting< NetworkType >

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

template<class NetworkType>
class m2etis::pubsub::routing::DirectRouting< NetworkType >