so_5::message_limit::impl Namespace Reference

Internal implementation of message limits related stuff. More...

Namespaces
	anonymous_namespace{message_limit_internals.hpp}
	description_preparation_details

Classes
class	action_msg_tracer_t
	An interface of tracer for message delivery tracing. More...
struct	call_pre_abort_action
	Helper class for calling pre-abort action. More...
struct	call_pre_abort_action_impl
	Helper class for calling pre-abort action. More...
struct	call_pre_abort_action_impl< false, M, L >
	Specialization for the case of signal. More...
class	fixed_info_storage_t
	A fixed-capacity storage for message limits for one agent. More...
class	growable_info_storage_t
	A storage of growable capacity for message limits for one agent. More...
struct	info_block_t
	Run-time data for limit of one message type. More...
class	info_storage_t
	An interface for storage of messages limits for one agent. More...
struct	transformed_message_maker
	A helper function to call appropriate constructor of resulting type in dependence of message or signal. More...
struct	transformed_message_maker< true, Result, Msg >
	A specialization of signal. More...

Typedefs
using	info_block_container_t = std::vector< info_block_t >
	Type of container for limits' run-time data. More...

Functions
SO_5_FUNC void	drop_message_reaction (const overlimit_context_t &ctx)
	Actual implementation of drop message reaction. More...
SO_5_FUNC void	abort_app_reaction (const overlimit_context_t &ctx)
	Actual implementation of abort application reaction. More...
SO_5_FUNC void	redirect_reaction ( const overlimit_context_t &ctx, const mbox_t &to)
	Actual implementation of redirect message reaction. More...
SO_5_FUNC void	transform_reaction ( const overlimit_context_t &ctx, const mbox_t &to, const std::type_index &msg_type, const message_ref_t &message)
	Actual implementation of transform reaction. More...
static std::unique_ptr< info_storage_t >	create_info_storage_if_necessary (description_container_t &&descriptions)
	Create info_storage object if there are some message limits. More...
template<typename Lambda >
void	try_to_deliver_to_agent (mbox_id_t mbox_id, const agent_t &receiver, const control_block_t *limit, const std::type_index &msg_type, const message_ref_t &what_to_deliver, unsigned int overlimit_reaction_deep, const message_limit::impl::action_msg_tracer_t *tracer, Lambda delivery_action)
	A helper function for pushing a message or a service request to agent with respect to message limit. More...

Variables
const unsigned int	max_overlimit_reaction_deep = 32
	Maximum overlimit reaction deep. More...

Detailed Description

Internal implementation of message limits related stuff.

Since

v.5.5.4

Typedef Documentation

info_block_container_t

using so_5::message_limit::impl::info_block_container_t = typedef std::vector< info_block_t >

Type of container for limits' run-time data.

Since

v.5.5.4

Function Documentation

abort_app_reaction()

SO_5_FUNC void so_5::message_limit::impl::abort_app_reaction

(

const overlimit_context_t &

ctx

)

Actual implementation of abort application reaction.

Since

v.5.5.4

create_info_storage_if_necessary()

static std::unique_ptr< info_storage_t > so_5::message_limit::impl::create_info_storage_if_necessary ( description_container_t &&  descriptions )

inlinestatic

Create info_storage object if there are some message limits.

drop_message_reaction()

SO_5_FUNC void so_5::message_limit::impl::drop_message_reaction

(

const overlimit_context_t &

ctx

)

Actual implementation of drop message reaction.

Since

v.5.5.9

redirect_reaction()

SO_5_FUNC void so_5::message_limit::impl::redirect_reaction	(	const overlimit_context_t &	ctx,
		const mbox_t &	to
	)

Actual implementation of redirect message reaction.

Since

v.5.5.4

Parameters

ctx	Context on which overlimit must be handled.
to	Destination for message redirection.

transform_reaction()

SO_5_FUNC void so_5::message_limit::impl::transform_reaction	(	const overlimit_context_t &	ctx,
		const mbox_t &	to,
		const std::type_index &	msg_type,
		const message_ref_t &	message
	)

Actual implementation of transform reaction.

Since

v.5.5.4

Parameters

ctx	Context on which overlimit must be handled.
to	Destination for new message.
msg_type	Type of new message.
message	An instance of new message.

try_to_deliver_to_agent()

template<typename Lambda >

void so_5::message_limit::impl::try_to_deliver_to_agent	(	mbox_id_t	mbox_id,
		const agent_t &	receiver,
		const control_block_t *	limit,
		const std::type_index &	msg_type,
		const message_ref_t &	what_to_deliver,
		unsigned int	overlimit_reaction_deep,
		const message_limit::impl::action_msg_tracer_t *	tracer,
		Lambda	delivery_action
	)

A helper function for pushing a message or a service request to agent with respect to message limit.

Since

v.5.5.4

Template Parameters

Lambda

lambda-function to do actual pushing.

Parameters

mbox_id	Mbox that is used for message delivery. Added in v.5.5.23 for support of enveloped messages.
receiver	Receiver of the message or service request.
limit	Optional message limit. Value nullptr means that there is no message limit to control.
msg_type	Type of message to be delivered.
what_to_deliver	Message instance to be delivered.
overlimit_reaction_deep	Deep of overlimit reactions recursion.
tracer	Message delivery tracer to be used inside overlimit reaction.
delivery_action	Actual delivery action.

Variable Documentation

max_overlimit_reaction_deep

const unsigned int so_5::message_limit::impl::max_overlimit_reaction_deep = 32

Maximum overlimit reaction deep.

Since

v.5.5.4