active_group/pub.cpp File Reference

#include <so_5/disp/active_group/pub.hpp>
#include <so_5/send_functions.hpp>
#include <so_5/details/rollback_on_exception.hpp>
#include <so_5/disp/reuse/data_source_prefix_helpers.hpp>
#include <so_5/disp/reuse/make_actual_dispatcher.hpp>
#include <so_5/disp/reuse/work_thread/work_thread.hpp>
#include <so_5/stats/repository.hpp>
#include <so_5/stats/messages.hpp>
#include <so_5/stats/std_names.hpp>
#include <map>
#include <mutex>
#include <algorithm>

Classes
class	so_5::disp::active_group::impl::actual_dispatcher_iface_t
	An actual interface of active group dispatcher. More...
class	so_5::disp::active_group::impl::actual_binder_t
	Implementation of binder interface for active_group dispatcher. More...
class	so_5::disp::active_group::impl::dispatcher_template_t< Work_Thread >
	Implementation of active object dispatcher in form of template class. More...
struct	so_5::disp::active_group::impl::dispatcher_template_t< Work_Thread >::thread_with_refcounter_t
	Auxiliary class for the working agent counting. More...
class	so_5::disp::active_group::impl::dispatcher_template_t< Work_Thread >::disp_data_source_t
	Data source for run-time monitoring of whole dispatcher. More...
class	so_5::disp::active_group::impl::dispatcher_handle_maker_t

Namespaces
	so_5
	Public part of message limit implementation.
	so_5::disp
	Event dispatchers.
	so_5::disp::active_group
	Active groups dispatcher.
	so_5::disp::active_group::impl
	Active groups dispatcher implemetation details.
	so_5::disp::active_group::impl::anonymous_namespace{pub.cpp}

Typedefs
using	so_5::disp::active_group::impl::actual_dispatcher_iface_shptr_t = std::shared_ptr< actual_dispatcher_iface_t >

Functions
template<class T >
void	so_5::disp::active_group::impl::anonymous_namespace{pub.cpp}::shutdown_and_wait (T &w)
	Just a helper function for consequetive call to shutdown and wait. More...
void	so_5::disp::active_group::impl::anonymous_namespace{pub.cpp}::send_thread_activity_stats (const so_5::mbox_t &, const stats::prefix_t &, work_thread::work_thread_no_activity_tracking_t &)
void	so_5::disp::active_group::impl::anonymous_namespace{pub.cpp}::send_thread_activity_stats (const so_5::mbox_t &mbox, const stats::prefix_t &prefix, work_thread::work_thread_with_activity_tracking_t &wt)
SO_5_FUNC dispatcher_handle_t	so_5::disp::active_group::make_dispatcher ( so_5::environment_t &env, const std::string_view data_sources_name_base, disp_params_t params)
	Create an instance of active_group dispatcher. More...