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 |