SObjectizer
5.7
|
#include <so_5/disp/active_obj/pub.hpp>
#include <so_5/event_queue.hpp>
#include <so_5/send_functions.hpp>
#include <so_5/details/rollback_on_exception.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/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_obj::impl::dispatcher_template_t< Work_Thread > |
Implementation of active object dispatcher in form of template class. More... | |
class | so_5::disp::active_obj::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_obj::impl::dispatcher_handle_maker_t |
Namespaces | |
so_5 | |
Public part of message limit implementation. | |
so_5::disp | |
Event dispatchers. | |
so_5::disp::active_obj | |
Active objects dispatcher. | |
so_5::disp::active_obj::impl | |
Active objects dispatcher implemetation details. | |
so_5::disp::active_obj::impl::anonymous_namespace{pub.cpp} | |
Functions | |
template<class T > | |
void | so_5::disp::active_obj::impl::anonymous_namespace{pub.cpp}::shutdown_and_wait (T &w) |
Just a helper function for consequetive call to shutdown and wait. More... | |
template<class Work_Thread > | |
void | so_5::disp::active_obj::impl::anonymous_namespace{pub.cpp}::send_demands_count_stats (const so_5::mbox_t &mbox, const stats::prefix_t &prefix, Work_Thread &wt) |
void | so_5::disp::active_obj::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_obj::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_obj::make_dispatcher ( environment_t &env, const std::string_view data_sources_name_base, disp_params_t params) |
Create an instance of active_obj dispatcher. More... | |