SObjectizer  5.5
Classes | Namespaces | Typedefs | Functions
one_thread/pub.cpp File Reference
#include <so_5/disp/one_thread/h/pub.hpp>
#include <so_5/rt/h/disp.hpp>
#include <so_5/rt/h/environment.hpp>
#include <so_5/rt/h/send_functions.hpp>
#include <so_5/rt/stats/h/repository.hpp>
#include <so_5/rt/stats/h/messages.hpp>
#include <so_5/rt/stats/h/std_names.hpp>
#include <so_5/rt/stats/impl/h/activity_tracking.hpp>
#include <so_5/disp/reuse/work_thread/h/work_thread.hpp>
#include <so_5/disp/reuse/h/disp_binder_helpers.hpp>
#include <so_5/disp/reuse/h/data_source_prefix_helpers.hpp>
#include <so_5/disp/reuse/h/proxy_dispatcher_template.hpp>
#include <so_5/details/h/rollback_on_exception.hpp>
#include <so_5/h/stdcpp.hpp>
#include <atomic>

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_disp_iface_t
 Interface of actual 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::proxy_dispatcher_t
 A proxy dispatcher which creates actual dispatcher at start. More...
 
class  so_5::disp::one_thread::impl::binding_actions_mixin_t
 Implementation of binding actions to be reused in various binder implementation. More...
 
class  so_5::disp::one_thread::impl::disp_binder_t
 Agent dispatcher binder. More...
 
class  so_5::disp::one_thread::impl::disp_binder_for_specific_dispatcher_t
 Agent dispatcher binder. More...
 
class  so_5::disp::one_thread::impl::real_private_dispatcher_t
 A real implementation of private_dispatcher interface. More...
 

Namespaces

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

Typedefs

using so_5::disp::one_thread::impl::proxy_dispatcher_base_t = so_5::disp::reuse::proxy_dispatcher_template_t< actual_disp_iface_t, disp_params_t >
 
using so_5::disp::one_thread::impl::private_dispatcher_binder_t = so_5::disp::reuse::binder_for_private_disp_template_t< private_dispatcher_handle_t, proxy_dispatcher_t, binding_actions_mixin_t >
 A binder for the private one_thread dispatcher. More...
 

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_unique_ptr_t so_5::disp::one_thread::create_disp ( disp_params_t params)
 Create an instance of one_thread dispatcher to be used as named dispatcher. More...
 
SO_5_FUNC private_dispatcher_handle_t so_5::disp::one_thread::create_private_disp ( environment_t &env, const std::string &data_sources_name_base, disp_params_t params)
 Create a private one_thread dispatcher. More...
 
SO_5_FUNC disp_binder_unique_ptr_t so_5::disp::one_thread::create_disp_binder ( nonempty_name_t disp_name)
 Create a dispatcher binder object. More...
 
disp_binder_unique_ptr_t so_5::disp::one_thread::internals::create_binder_for_specific_dispatcher ( so_5::dispatcher_t &dispatcher)
 Create binder for a specific dispatcher instance. More...