|
SObjectizer
5.8
|
| ▼ dev | |
| ► so_5 | |
| ► 3rd_party | |
| ► timertt | |
| all.hpp | All project's stuff |
| ► details | |
| abort_on_fatal_error.hpp | Helpers for aborting the whole application in the case of a fatal error |
| always_false.hpp | A simple metafunction that always "returns" false |
| at_scope_exit.hpp | A simple implementation of at_scope_exit concept |
| invoke_noexcept_code.hpp | Helpers for invoking code which must not throws |
| ios_helpers.hpp | Various helpers for working with C++ iostreams |
| lambda_traits.hpp | Lambda-related type traits |
| remaining_time_counter.hpp | Helper class for calculating remaining time |
| rollback_on_exception.hpp | Helpers for do rollback actions in the case of exception |
| safe_cv_wait_for.hpp | Helpers for safe calls to condition_variable::wait_for with big timeout intervals |
| suppress_exceptions.hpp | Helpers for invoking code with suppressing exceptions |
| sync_helpers.hpp | Basic tools for simplify usage of std::mutex or null_mutex |
| ► disp | |
| ► active_group | |
| pub.cpp | |
| pub.hpp | Functions for creating and binding to the active group dispatcher |
| ► active_obj | |
| pub.cpp | |
| pub.hpp | Dispatcher creation and agent binding functions |
| ► adv_thread_pool | |
| ► impl | |
| disp.hpp | An implementation of advanced thread pool dispatcher |
| pub.cpp | Public interface of advanced thread pool dispatcher |
| pub.hpp | Public interface of advanced thread pool dispatcher |
| ► mpmc_queue_traits | |
| pub.cpp | Various traits for MPMC queues |
| pub.hpp | Various traits for MPMC queues |
| ► mpsc_queue_traits | |
| pub.cpp | Various traits for MPSC queues |
| pub.hpp | Various traits for MPSC queues |
| ► nef_one_thread | |
| params.hpp | Parameters for nef_one_thread dispatcher |
| pub.cpp | Functions for creating and binding of the single thread dispatcher that provides noexcept guarantee for scheduling evt_finish demand |
| pub.hpp | Functions for creating and binding of the single thread dispatcher that provides noexcept guarantee for scheduling evt_finish demand |
| ► nef_thread_pool | |
| pub.cpp | Public interface of thread pool dispatcher that provides noexcept guarantee for scheduling evt_finish demand |
| pub.hpp | Public interface of thread pool dispatcher that provides noexcept guarantee for scheduling evt_finish demand |
| ► one_thread | |
| params.hpp | Parameters for one_thread dispatcher |
| pub.cpp | |
| pub.hpp | Functions for creating and binding of the single thread dispatcher |
| ► prio_dedicated_threads | |
| ► one_per_prio | |
| pub.cpp | Functions for creating and binding of the dispatcher with dedicated threads per priority |
| pub.hpp | Functions for creating and binding of the dispatcher with dedicated threads per priority |
| ► prio_one_thread | |
| ► quoted_round_robin | |
| ► impl | |
| demand_queue.hpp | A demand queue for dispatcher with one common working thread and round-robin processing of prioritised demand on quoted basic |
| pub.cpp | Functions for creating and binding of the single thread dispatcher with priority support (quoted round robin policy) |
| pub.hpp | Functions for creating and binding of the single thread dispatcher with priority support (quoted round robin policy) |
| quotes.hpp | A storage of quotes for priorities |
| ► reuse | |
| work_thread.hpp | A working thread for dispatcher with one common working thread and support of demands priority |
| ► strictly_ordered | |
| ► impl | |
| demand_queue.hpp | A demand queue for dispatcher with one common working thread and support of demands priority |
| pub.cpp | Functions for creating and binding of the single thread dispatcher with priority support |
| pub.hpp | Functions for creating and binding of the single thread dispatcher with priority support |
| ► reuse | |
| ► work_thread | |
| work_thread.hpp | Working thread for dispatchers |
| actual_work_thread_factory_to_use.hpp | Helper for detection of actual work thread factory to use |
| data_source_prefix_helpers.hpp | Helpers creation of data source name prefixes |
| default_thread_pool_size.hpp | Reusable function for the default size for a thread pool |
| make_actual_dispatcher.hpp | A set of helpers for making actual dispatcher instances |
| queue_of_queues.hpp | Multi-producer/Multi-consumer queue of pointers to event queues |
| thread_pool_stats.hpp | Reusable tools for run-time monitoring of thread-pool-like dispatchers |
| work_thread_activity_tracking.hpp | Various helpers to work with thread activity tracking stuff |
| work_thread_factory_params.hpp | Various helpers to work with work thread factories |
| ► thread_pool | |
| ► impl | |
| basic_event_queue.hpp | A reusable implementation of agent_queue that can be used by various thread-pool dispatchers |
| common_implementation.hpp | Reusable common implementation for thread-pool-like dispatchers |
| disp.hpp | An implementation of thread pool dispatcher |
| work_thread_template.hpp | A reusable implementation of work_thread_template that can be used by various thread-pool dispatchers |
| pub.cpp | Public interface of thread pool dispatcher |
| pub.hpp | Public interface of thread pool dispatcher |
| abstract_work_thread.cpp | Interfaces for work_thread and work_thread's factory |
| abstract_work_thread.hpp | Interfaces for work_thread and work_thread's factory |
| ► experimental | |
| ► testing | |
| ► v1 | |
| all.cpp | Testing related stuff |
| all.hpp | Testing related stuff |
| testing.hpp | Top-level header file for all testing-related stuff |
| ► impl | |
| agent_ptr_compare.hpp | A special comparison for agent pointers |
| coop_private_iface.hpp | Private interface for a coop |
| coop_repository_basis.cpp | Basic part of coop_repository functionality |
| coop_repository_basis.hpp | Basic part of coop_repository functionality |
| delivery_filter_storage.hpp | Definition of storage for delivery filters |
| enveloped_msg_details.hpp | Some implementation details for enveloped messages |
| final_dereg_chain_helpers.hpp | Helpers for working with a chain of coops for the final deregistration |
| internal_agent_iface.hpp | Helper class for accessing private functionality of agent-class |
| internal_env_iface.hpp | Helper class for accessing private functionality of environment-class |
| layer_core.cpp | |
| layer_core.hpp | A definition of an utility class for work with layers |
| local_mbox.hpp | A local mbox definition |
| local_mbox_basic_subscription_info.hpp | Information about just one subscription |
| make_mchain.hpp | A helper function for the creation of a new mchain |
| mbox_core.cpp | |
| mbox_core.hpp | A definition of an utility class for work with mboxes |
| mbox_iface_for_timers.hpp | Definition of mbox_iface_for_timers |
| mchain_details.hpp | Implementation details for message chains |
| message_limit_action_msg_tracer.hpp | Declaration of action_msg_tracer for overlimit action tracing |
| message_sink_for_agent.hpp | |
| message_sink_with_message_limit.hpp | |
| message_sink_without_message_limit.hpp | |
| mpsc_mbox.hpp | A multi-producer/single-consumer mbox definition |
| msg_tracing_helpers.cpp | Implementation of some helpers for message tracing |
| msg_tracing_helpers.hpp | Various helpers for message delivery tracing stuff |
| mt_env_infrastructure.cpp | Default implementation of multithreaded environment infrastructure |
| mt_env_infrastructure.hpp | Default implementation of multithreaded environment infrastructure |
| named_local_mbox.cpp | |
| named_local_mbox.hpp | A definition of the named local mbox |
| process_unhandled_exception.cpp | Helpers for handling unhandled exceptions from agent's event handlers |
| process_unhandled_exception.hpp | Helpers for handling unhandled exceptions from agent's event handlers |
| run_stage.hpp | Helper template function for doing initialization phase with rollback on failure |
| simple_mtsafe_st_env_infrastructure.cpp | A very simple multithreaded-safe single thread environment infrastructure |
| simple_not_mtsafe_st_env_infrastructure.cpp | A very simple not-multithreaded-safe single thread environment infrastructure |
| st_env_infrastructure_reuse.hpp | Reusable stuff to be used in implementations of various single thread environment infrastructure |
| std_message_sinks.hpp | |
| std_msg_tracer_holder.hpp | Standard implementation of message tracer holder |
| stop_guard_repo.hpp | Repository of stop_guards |
| subscr_storage_adaptive.cpp | An adaptive storage for agent's subscriptions information |
| subscr_storage_flat_set_based.cpp | A flat-set based storage for agent's subscriptions information |
| subscr_storage_hash_table_based.cpp | A hash_table-based storage for agent's subscriptions information |
| subscr_storage_map_based.cpp | A map-based storage for agent's subscriptions information |
| subscr_storage_vector_based.cpp | A vector-based storage for agent's subscriptions information |
| subscription_storage_iface.cpp | An interface of subscription storage |
| subscription_storage_iface.hpp | An interface of subscription storage |
| thread_join_stuff.hpp | Various stuff related to worker thread's join |
| ► msinks | |
| transform_then_redirect.hpp | Stuff for transform_then_redirect message sink |
| ► stats | |
| ► impl | |
| activity_tracking.hpp | Details for implementation of activity tracking |
| ds_agent_core_stats.cpp | A data source class for run-time monitoring of agent_core |
| ds_agent_core_stats.hpp | A data source class for run-time monitoring of agent_core |
| ds_mbox_core_stats.cpp | A data source class for run-time monitoring of mbox_core |
| ds_mbox_core_stats.hpp | A data source class for run-time monitoring of mbox_core |
| ds_timer_thread_stats.cpp | A data source class for run-time monitoring of timer_thread |
| ds_timer_thread_stats.hpp | A data source class for run-time monitoring of timer_thread |
| st_env_stuff.hpp | Various stuff dedicated for single-threaded environments |
| std_controller.cpp | A standard implementation of controller for run-time monitoring |
| std_controller.hpp | A standard implementation of controller for run-time monitoring |
| controller.hpp | A public interface for control SObjectizer monitoring options |
| messages.hpp | Messages with monitoring information |
| prefix.hpp | A type for storing prefix of data_source name |
| repository.cpp | Interfaces of data source and data sources repository |
| repository.hpp | Interfaces of data source and data sources repository |
| std_names.cpp | Standard data sources prefixes and suffixes used by SObjectizer |
| std_names.hpp | Standard data sources prefixes and suffixes used by SObjectizer |
| work_thread_activity.hpp | Data types for work thread's activity stats |
| agent.cpp | |
| agent.hpp | A base class for agents |
| agent_context.hpp | A context for agent construction and tuning |
| agent_coop_notifications.hpp | Agent cooperation notifications definition |
| agent_identity.hpp | Types related to agents identity (name) |
| agent_ref_fwd.hpp | A forward declaration of agent_ref_t |
| agent_state_listener.hpp | Agent state listener definition |
| agent_tuning_options.hpp | A collector for agent tuning options |
| all.hpp | A helper header file for including all public SObjectizer stuff |
| api.hpp | Function for the SObjectizer starting |
| atomic_refcounted.hpp | The base class for the object with a reference counting definition |
| bind_transformer_helpers.hpp | Helpers to simplify usage of transform_then_redirect_sink |
| compiler_features.hpp | Detection of compiler version and absence of various features |
| coop.cpp | |
| coop.hpp | Cooperation of agents |
| coop_handle.hpp | Type of smart handle to coop |
| coop_listener.hpp | Interface for the cooperation listener definition |
| current_thread_id.hpp | A workaround for very slow implementation of std::this_thread::get_id() under some compilers |
| custom_mbox.hpp | Various stuff required for custom mboxes |
| declspec.hpp | |
| detect_os.hpp | Helper macros for detection of compiler/platform |
| disp_binder.hpp | Interface for the dispatcher binders definition |
| env_infrastructures.hpp | User-visible parameters for various environment infrastructures |
| enveloped_msg.cpp | Stuff related to enveloped messages |
| enveloped_msg.hpp | Stuff related to enveloped messages |
| environment.cpp | |
| environment.hpp | SObjectizer Environment definition |
| environment_infrastructure.hpp | Interface of environment_infrastructure entity |
| error_logger.cpp | Tools for logging error messages inside SObjectizer core |
| error_logger.hpp | Tools for logging error messages inside SObjectizer core |
| event_exception_logger.cpp | |
| event_exception_logger.hpp | An interface for the exception logging definition |
| event_queue.hpp | An interface of event queue for agent |
| event_queue_hook.cpp | Implementation details of event_queue_hook |
| event_queue_hook.hpp | Interface of event_queue_hook object |
| exception.cpp | |
| exception.hpp | An exception class |
| exception_control_flags.hpp | Types and constants for exception control flags |
| execution_demand.hpp | Event-related stuff |
| fwd.hpp | Forward declaration for SObjectizer run-time related classes |
| handler_makers.cpp | Implementation of some parts of handler makers which can't be inline |
| handler_makers.hpp | Various stuff for creation of event handlers |
| mbox.cpp | |
| mbox.hpp | Mbox definition |
| mbox_fwd.hpp | A forward declaration of mbox_t |
| mbox_namespace_name.hpp | A mbox_namespace_name_t class definition |
| mchain.cpp | Public part of message chain related stuff |
| mchain.hpp | Public part of message chain related stuff |
| mchain_helper_functions.hpp | Helper functions for mchains |
| mchain_select.hpp | Various stuff related to multi chain select |
| mchain_select_ifaces.hpp | Various stuff related to multi chain select |
| message.cpp | |
| message.hpp | A base class for the agent messages definition |
| message_handler_format_detector.hpp | Helpers for detection of message type by message handler format |
| message_holder.hpp | Definition of the template class message_holder |
| message_limit.cpp | |
| message_limit.hpp | Public part of message limit implementation |
| message_sink.hpp | A base class for message sinks |
| mhood.hpp | Definition of the template class mhood |
| msg_tracing.cpp | |
| msg_tracing.hpp | Stuff related to message delivery tracing |
| msg_tracing_individual.cpp | Stuff related to individual message delivery tracing |
| msg_tracing_individual.hpp | Stuff related to individual message delivery tracing |
| multi_sink_binding.hpp | Stuff for multi_sink_binding implementation |
| nonempty_name.hpp | A nonempty_name class definition |
| optional.hpp | Definition of optional type |
| outliving.hpp | Outliving_reference_t and related stuff |
| priority.hpp | Definition of priority type |
| queue_locks_defaults_manager.cpp | Interface of manager for default locks for event queues |
| queue_locks_defaults_manager.hpp | Interface of manager for default locks for event queues |
| ret_code.hpp | Error codes |
| rt.hpp | A wrapper for all major SO Run-Time includes |
| send_functions.hpp | Implementation of free functions send/send_delayed |
| single_sink_binding.hpp | Stuff for single_sink_binding implementation |
| so_layer.cpp | |
| so_layer.hpp | An addition layer for the SObjectizer Environment definition |
| spinlocks.hpp | Definition of various types of spinlocks |
| state.hpp | A class for the agent state definition |
| stop_guard.hpp | An iterface of stop_guard |
| subscription_storage_fwd.hpp | Forward definitions for subscription storage related stuff |
| thread_helper_functions.hpp | Helper functions for working with threads |
| timers.cpp | Timers and tools for working with timers |
| timers.hpp | Timers and tools for working with timers |
| transformed_message.hpp | Stuff related to template type transformed_message |
| types.hpp | Various typedefs |
| unique_subscribers_mbox.hpp | Implementation of unique_subscribers mbox |
| version.hpp | Definition of SO_5_VERSION macro |
| wait_indication.hpp | Definition of various types of waiting indicators |
| wrapped_env.cpp | Class wrapped_env and its details |
| wrapped_env.hpp | Class wrapped_env and its details |
| ▼ dox | |
| so_5 |