pub.cpp File Reference

#include <so_5/disp/one_thread/pub.hpp>
#include <so_5/environment.hpp>
#include <so_5/send_functions.hpp>
#include <so_5/stats/repository.hpp>
#include <so_5/stats/messages.hpp>
#include <so_5/stats/std_names.hpp>
#include <so_5/stats/impl/activity_tracking.hpp>
#include <so_5/disp/reuse/work_thread/work_thread.hpp>
#include <so_5/disp/reuse/actual_work_thread_factory_to_use.hpp>
#include <so_5/disp/reuse/data_source_prefix_helpers.hpp>
#include <so_5/disp/reuse/make_actual_dispatcher.hpp>
#include <so_5/details/rollback_on_exception.hpp>
#include <atomic>

Go to the source code of this file.

Classes
struct	so_5::disp::one_thread::impl::data_source_details::common_data_t< Work_Thread >
class	so_5::disp::one_thread::impl::data_source_t< Work_Thread >
	Data source for one-thread dispatcher. More...
class	so_5::disp::one_thread::impl::actual_dispatcher_t< Work_Thread >
	A dispatcher with the single working thread and an event queue. More...
class	so_5::disp::one_thread::impl::dispatcher_handle_maker_t

Namespaces
namespace	so_5
	Private part of message limit implementation.
namespace	so_5::disp
	Event dispatchers.
namespace	so_5::disp::one_thread
	Dispatcher with single working thread.
namespace	so_5::disp::one_thread::impl
	Implementation details for dispatcher with single working thread.
namespace	so_5::disp::one_thread::impl::data_source_details

Functions
void	so_5::disp::one_thread::impl::data_source_details::track_activity (const mbox_t &, const common_data_t< work_thread::work_thread_no_activity_tracking_t > &)
void	so_5::disp::one_thread::impl::data_source_details::track_activity (const mbox_t &mbox, const common_data_t< work_thread::work_thread_with_activity_tracking_t > &data)
SO_5_FUNC dispatcher_handle_t	so_5::disp::one_thread::make_dispatcher ( environment_t &env, const std::string_view data_sources_name_base, disp_params_t params)
	Create an instance of one_thread dispatcher.