A class for the named local mbox. More...

#include <named_local_mbox.hpp>

Inheritance diagram for so_5::impl::named_local_mbox_t:

Public Member Functions
virtual	~named_local_mbox_t () override

virtual mbox_id_t	id () const override
	Unique ID of this mbox. More...

virtual void	subscribe_event_handler (const std::type_index &type_wrapper, const so_5::message_limit::control_block_t limit, agent_t subscriber) override
	Add the message handler. More...

virtual void	unsubscribe_event_handlers (const std::type_index &type_wrapper, agent_t *subscriber) override
	Remove all message handlers. More...

virtual std::string	query_name () const override
	Get the mbox name. More...

virtual mbox_type_t	type () const override
	Get the type of message box. More...

virtual void	do_deliver_message (const std::type_index &msg_type, const message_ref_t &message, unsigned int overlimit_reaction_deep) const override
	Deliver message for all subscribers with respect to message limits. More...

virtual void	do_deliver_service_request (const std::type_index &msg_type, const message_ref_t &message, unsigned int overlimit_reaction_deep) const override
	Deliver service request. More...

virtual void	set_delivery_filter (const std::type_index &msg_type, const delivery_filter_t &filter, agent_t &subscriber) override
	Set a delivery filter for message type and subscriber. More...

virtual void	drop_delivery_filter (const std::type_index &msg_type, agent_t &subscriber) SO_5_NOEXCEPT override
	Removes delivery filter for message type and subscriber. More...

Public Member Functions inherited from so_5::abstract_message_box_t
	abstract_message_box_t ()=default

virtual	~abstract_message_box_t () SO_5_NOEXCEPT=default

template<class Message >
void	deliver_message (std::type_index subscription_type, const intrusive_ptr_t< Message > &msg_ref) const
	Deliver message. More...

template<class Message >
void	deliver_message (const intrusive_ptr_t< Message > &msg_ref) const
	Deliver message. More...

template<class Message >
void	deliver_message (std::type_index subscription_type, std::unique_ptr< Message > msg_unique_ptr, message_mutability_t mutability) const
	Deliver message. More...

template<class Message >
void	deliver_message (std::unique_ptr< Message > msg_unique_ptr) const
	Deliver message. More...

template<class Message >
void	deliver_message (Message *msg_raw_ptr) const
	Deliver message. More...

template<class Message >
void	deliver_signal () const
	Deliver signal. More...

template<class Result >
service_invoke_proxy_t< Result >	get_one ()
	Create a special proxy for service request invocation. More...

service_invoke_proxy_t< void >	run_one ()
	Create a special proxy for service request invocation where return type is void. More...

void	deliver_message (const std::type_index &msg_type, const message_ref_t &message) const
	Deliver message for all subscribers. More...

void	deliver_service_request (const std::type_index &msg_type, const message_ref_t &message) const
	Deliver service request. More...

virtual void	do_deliver_enveloped_msg (const std::type_index &msg_type, const message_ref_t &message, unsigned int overlimit_reaction_deep)
	Deliver enveloped message. More...

bool	operator== (const abstract_message_box_t &o) const SO_5_NOEXCEPT

bool	operator< (const abstract_message_box_t &o) const SO_5_NOEXCEPT

Private Member Functions
	named_local_mbox_t (const std::string &name, const mbox_t &mbox, impl::mbox_core_t &mbox_core)

Private Attributes
const std::string	m_name
	Mbox name. More...

impl::mbox_core_ref_t	m_mbox_core
	An utility for this mbox. More...

mbox_t	m_mbox
	Actual mbox. More...

Friends
class	impl::mbox_core_t

Additional Inherited Members
Protected Member Functions inherited from so_5::abstract_message_box_t
virtual void	do_deliver_message_from_timer (const std::type_index &msg_type, const message_ref_t &message)
	Special method for message delivery from a timer thread. More...

Protected Member Functions inherited from so_5::atomic_refcounted_t
	atomic_refcounted_t (const atomic_refcounted_t &)=delete

atomic_refcounted_t &	operator= (const atomic_refcounted_t &)=delete

	atomic_refcounted_t () SO_5_NOEXCEPT
	Default constructor. More...

	~atomic_refcounted_t () SO_5_NOEXCEPT=default
	Destructor. More...

void	inc_ref_count () SO_5_NOEXCEPT
	Increments reference count. More...

unsigned long	dec_ref_count () SO_5_NOEXCEPT
	Decrement reference count. More...

Static Protected Member Functions inherited from so_5::abstract_message_box_t
static void	delegate_deliver_message_from_timer (abstract_message_box_t &mbox, const std::type_index &msg_type, const message_ref_t &message)
	Helper for calling do_deliver_message_from_timer in derived classes. More...

Detailed Description

A class for the named local mbox.

Note: This class is necessary because there is a difference between reference counting for anonymous and named local mboxes. Named local mboxes should have only one instance inside SObjectizer Environment.

Constructor & Destructor Documentation

◆ named_local_mbox_t()

so_5::impl::named_local_mbox_t::named_local_mbox_t	(	const std::string &	name,
		const mbox_t &	mbox,
		impl::mbox_core_t &	mbox_core
	)

private

◆ ~named_local_mbox_t()

so_5::impl::named_local_mbox_t::~named_local_mbox_t ( )

overridevirtual

Member Function Documentation

◆ do_deliver_message()

void so_5::impl::named_local_mbox_t::do_deliver_message	(	const std::type_index &	msg_type,
		const message_ref_t &	message,
		unsigned int	overlimit_reaction_deep
	)		const

overridevirtual

Deliver message for all subscribers with respect to message limits.

Since: v.5.5.4

Note: It is obvious that do_deliver_message() must be non-const method. The constness is here now to keep compatibility in 5.5.* versions. The constness will be removed in v.5.6.0.

Implements so_5::abstract_message_box_t.

◆ do_deliver_service_request()

void so_5::impl::named_local_mbox_t::do_deliver_service_request	(	const std::type_index &	msg_type,
		const message_ref_t &	message,
		unsigned int	overlimit_reaction_deep
	)		const

overridevirtual

Deliver service request.

Since: v.5.5.4

Note: It is obvious that do_deliver_message() must be non-const method. The constness is here now to keep compatibility in 5.5.* versions. The constness will be removed in v.5.6.0.

Implements so_5::abstract_message_box_t.

◆ drop_delivery_filter()

void so_5::impl::named_local_mbox_t::drop_delivery_filter	(	const std::type_index &	msg_type,
		agent_t &	subscriber
	)

overridevirtual

Removes delivery filter for message type and subscriber.

Since: v.5.5.5

Implements so_5::abstract_message_box_t.

◆ id()

mbox_id_t so_5::impl::named_local_mbox_t::id ( ) const

overridevirtual

Unique ID of this mbox.

Since: v.5.4.0

Implements so_5::abstract_message_box_t.

◆ query_name()

std::string so_5::impl::named_local_mbox_t::query_name ( ) const

overridevirtual

Get the mbox name.

Implements so_5::abstract_message_box_t.

◆ set_delivery_filter()

void so_5::impl::named_local_mbox_t::set_delivery_filter	(	const std::type_index &	msg_type,
		const delivery_filter_t &	filter,
		agent_t &	subscriber
	)

overridevirtual

Set a delivery filter for message type and subscriber.

Since: v.5.5.5

Note: If there already is a delivery filter for that (msg_type,subscriber) pair then old delivery filter will be replaced by new one.

Implements so_5::abstract_message_box_t.

◆ subscribe_event_handler()

void so_5::impl::named_local_mbox_t::subscribe_event_handler	(	const std::type_index &	type_index,
		const so_5::message_limit::control_block_t *	limit,
		agent_t *	subscriber
	)

overridevirtual

Add the message handler.

Implements so_5::abstract_message_box_t.

◆ type()

mbox_type_t so_5::impl::named_local_mbox_t::type ( ) const

overridevirtual

Get the type of message box.

Since: v.5.5.3

Note: This method is primarily intended for internal usage. It is useful sometimes in subscription-related operations because there is no need to do some actions for MPSC mboxes.

Implements so_5::abstract_message_box_t.

◆ unsubscribe_event_handlers()

void so_5::impl::named_local_mbox_t::unsubscribe_event_handlers	(	const std::type_index &	type_index,
		agent_t *	subscriber
	)

overridevirtual

Remove all message handlers.

Implements so_5::abstract_message_box_t.

Friends And Related Function Documentation

◆ impl::mbox_core_t

friend class impl::mbox_core_t

friend

Member Data Documentation

◆ m_mbox

mbox_t so_5::impl::named_local_mbox_t::m_mbox

private

Actual mbox.

◆ m_mbox_core

impl::mbox_core_ref_t so_5::impl::named_local_mbox_t::m_mbox_core

private

An utility for this mbox.

◆ m_name

const std::string so_5::impl::named_local_mbox_t::m_name

private

Mbox name.

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

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ named_local_mbox_t()

◆ ~named_local_mbox_t()

Member Function Documentation

◆ do_deliver_message()

◆ do_deliver_service_request()

◆ drop_delivery_filter()

◆ id()

◆ query_name()

◆ set_delivery_filter()

◆ subscribe_event_handler()

◆ type()

◆ unsubscribe_event_handlers()

Friends And Related Function Documentation

◆ impl::mbox_core_t

Member Data Documentation

◆ m_mbox

◆ m_mbox_core

◆ m_name