MCPcopy Create free account

hub / github.com/Stiffstream/sobjectizer / functions

Functions6,598 in github.com/Stiffstream/sobjectizer

↓ 2 callersMethodquery_max_demands_at_once
Get maximum count of demands to do processed at once.
dev/so_5/disp/thread_pool/pub.hpp:213
↓ 2 callersMethodquery_stats
dev/so_5/impl/mt_env_infrastructure.cpp:124
↓ 2 callersMethodquery_stats
dev/so_5/impl/mbox_core.cpp:300
↓ 2 callersMethodquery_stats
dev/so_5/impl/simple_not_mtsafe_st_env_infrastructure.cpp:95
↓ 2 callersMethodquery_stats
! * \note * This method locks the main mutex by itself. */
dev/so_5/impl/simple_mtsafe_st_env_infrastructure.cpp:170
↓ 2 callersMethodquery_subscriptions_count
dev/so_5/impl/subscr_storage_adaptive.cpp:229
↓ 2 callersFunctionqueue_locks_defaults_manager_t
dev/so_5/queue_locks_defaults_manager.hpp:39
↓ 2 callersMethodrelease
dev/test/so_5/disp/custom_work_thread.hpp:70
↓ 2 callersMethodrelease_thread_for_group
dev/so_5/disp/active_group/pub.cpp:274
↓ 2 callersMethodremove
dev/so_5/stats/impl/std_controller.cpp:102
↓ 2 callersFunctionrepository_t
dev/so_5/stats/repository.hpp:76
↓ 2 callersFunctionrun_sample
dev/sample/so_5/adv_thread_pool_fifo/main.cpp:96
↓ 2 callersFunctionrun_test_threads
dev/test/so_5/spinlocks/llvm_inspired_test/main.cpp:90
↓ 2 callersFunctionsequence_to_string
dev/test/so_5/coop/parent_child_1/main.cpp:202
↓ 2 callersFunctionsequence_to_string
dev/test/so_5/coop/coop_notify_2/main.cpp:123
↓ 2 callersFunctionsequence_to_string
dev/test/so_5/coop/parent_child_3/main.cpp:210
↓ 2 callersMethodset_completion
dev/so_5/experimental/testing/v1/all.cpp:50
↓ 2 callersMethodset_delivery_filter
dev/so_5/impl/named_local_mbox.cpp:86
↓ 2 callersMethodset_disp_binder
! * \brief Setter for disp_binder. * * \attention * It's not a thread safe method. But it's expected that it will be used * in the cont
dev/so_5/impl/internal_agent_iface.hpp:69
↓ 2 callersMethodset_exception_reaction
! * \name Exception reaction methods. * \{ */ ! * \brief Set exception reaction for that cooperation. * * This value will be used by
dev/so_5/coop.hpp:736
↓ 2 callersMethodset_handle_n
Set limit for count of messages to be handled.
dev/so_5/mchain.hpp:1156
↓ 2 callersMethodset_message_or_signal
dev/so_5/impl/msg_tracing_helpers.cpp:112
↓ 2 callersMethodset_size
dev/test/so_5/disp/adv_thread_pool/cooperation_fifo_2/main.cpp:38
↓ 2 callersMethodset_size
dev/test/so_5/disp/adv_thread_pool/individual_fifo/main.cpp:37
↓ 2 callersMethodset_size
dev/test/so_5/disp/thread_pool/cooperation_fifo_2/main.cpp:38
↓ 2 callersMethodset_size
dev/test/so_5/disp/thread_pool/individual_fifo/main.cpp:37
↓ 2 callersMethodset_size
dev/test/so_5/disp/thread_pool/cooperation_fifo/main.cpp:47
↓ 2 callersMethodset_target
dev/test/so_5/testing/v1/testenv_ping_pong/main.cpp:23
↓ 2 callersMethodsetup_content
dev/so_5/impl/subscr_storage_adaptive.cpp:217
↓ 2 callersFunctionshould_throw
dev/test/so_5/disp/custom_new_operator.hpp:15
↓ 2 callersFunctionshutdown_and_wait
dev/so_5/disp/active_obj/pub.cpp:50
↓ 2 callersFunctionshutdown_and_wait
dev/so_5/disp/active_group/pub.cpp:50
↓ 2 callersMethodsignal_dest
dev/test/so_5/mbox/sink_binding/multi_sink_simple_2/main.cpp:40
↓ 2 callersMethodsink_priority
dev/so_5/mbox.cpp:59
↓ 2 callersMethodsize
! * \brief Get the current size of the queue. * * \since * v.5.5.4 */
dev/so_5/disp/adv_thread_pool/impl/disp.hpp:294
↓ 2 callersMethodso5_message_kind
dev/so_5/message.hpp:345
↓ 2 callersMethodso_switch_to_awaiting_deregistration_state
dev/so_5/agent.cpp:880
↓ 2 callersFunctionso_this_agent_disp_binder
! * \brief Returns the dispatcher binder that is used for binding this * agent. * * \attention * It's safe to use this method only whil
dev/so_5/agent.hpp:2714
↓ 2 callersFunctionsource_t
dev/so_5/stats/repository.hpp:45
↓ 2 callersFunctionspecial_sink_ptr_compare
dev/so_5/message_sink.hpp:137
↓ 2 callersMethodstart
dev/test/so_5/coop/msg_loss_at_registration/main.cpp:138
↓ 2 callersMethodstart
Launch work thread.
dev/so_5/disp/thread_pool/impl/work_thread_template.hpp:253
↓ 2 callersMethodstart
dev/so_5/impl/mt_env_infrastructure.cpp:40
↓ 2 callersMethodstop
dev/so_5/environment.cpp:721
↓ 2 callersMethodstop
dev/so_5/wrapped_env.cpp:409
↓ 2 callersMethodstop_service
Stop demands processing.
dev/so_5/disp/reuse/work_thread/work_thread.hpp:302
↓ 2 callersFunctionswap
dev/so_5/environment.cpp:84
↓ 2 callersMethodtake_activity_stats
dev/so_5/disp/adv_thread_pool/impl/disp.hpp:456
↓ 2 callersMethodtake_activity_stats
dev/so_5/disp/nef_one_thread/pub.cpp:362
↓ 2 callersMethodthread_id
! * \brief Get ID of work thread. * * \note This method returns correct value only after start * of the thread. * * \since * v.5.
dev/so_5/disp/adv_thread_pool/impl/disp.hpp:587
↓ 2 callersMethodthread_id
dev/so_5/disp/nef_one_thread/pub.cpp:444
↓ 2 callersMethodtimeout_before_nearest_timer
dev/so_5/3rd_party/timertt/all.hpp:3529
↓ 2 callersFunctiontimer_list_manager_factory
! * \since * v.5.5.0 * * \brief Factory for timer_list manager with default parameters. */
dev/so_5/timers.hpp:752
↓ 2 callersFunctiontimer_wheel_manager_factory
! * \name Standard timer manager factories. * \{ */ ! * \since * v.5.5.0 * * \brief Factory for timer_wheel manager with default parameters. *
dev/so_5/timers.hpp:659
↓ 2 callersFunctionto_priority_t
! * \since * v.5.5.8 * * \brief Helper function for conversion from size_t to priority. * * \throw std::invalid_argument if \a v is out of range
dev/so_5/priority.hpp:61
↓ 2 callersFunctionto_shptr_noexcept
! * \brief A helper function for unsafe extraction of shared_ptr to * coop from coop_handle instance. * * \note * This function don't throws if c
dev/so_5/coop_handle.hpp:227
↓ 2 callersFunctiontotal_messages
dev/test/so_5/bench/thread_pool_disp/main.cpp:146
↓ 2 callersFunctiontransform_reaction
dev/so_5/message_limit.cpp:104
↓ 2 callersFunctiontransform_then_redirect
dev/so_5/msinks/transform_then_redirect.hpp:545
↓ 2 callersMethodtry_get_payload
dev/so_5/enveloped_msg.cpp:72
↓ 2 callersMethodunbind_agent
dev/test/so_5/disp/binder/correct_unbind_after_throw_on_bind/main.cpp:104
↓ 2 callersMethodundo_preallocation
dev/so_5/disp/thread_pool/pub.cpp:105
↓ 2 callersMethodunfreeze
dev/so_5/experimental/testing/v1/all.cpp:1489
↓ 2 callersMethodunlock
dev/test/so_5/disp/thread_pool/cooperation_fifo/main.cpp:35
↓ 2 callersMethodunlock
dev/so_5/details/sync_helpers.hpp:38
↓ 2 callersMethodupdate_queue_stats
! * \brief Update queue description with current information. * * \attention Must be called only if !cooperation_fifo(). * *
dev/so_5/disp/thread_pool/impl/common_implementation.hpp:182
↓ 2 callersFunctionupdate_stats_from_duration
! * \brief Helper function for simplification of current stats update. * * \since v.5.5.18 */
dev/so_5/stats/work_thread_activity.hpp:150
↓ 2 callersMethodwait
dev/test/so_5/mchain/not_empty_notify/main.cpp:29
↓ 2 callersMethodwait_for_emptyness
! * \brief Wait while queue becomes empty. * * It is necessary because there is a possibility that * after processing of demand_handler_on
dev/so_5/disp/thread_pool/impl/basic_event_queue.hpp:226
↓ 2 callersMethodwait_for_start_deregistration
dev/so_5/impl/mt_env_infrastructure.cpp:104
↓ 2 callersMethodwait_start_if_not_started
dev/so_5/impl/st_env_infrastructure_reuse.hpp:75
↓ 2 callersMethodwait_started
dev/so_5/impl/st_env_infrastructure_reuse.hpp:74
↓ 2 callersMethodwait_stopped
dev/so_5/impl/st_env_infrastructure_reuse.hpp:76
↓ 2 callersMethodwas_sent_or_received
! * \return true if something was sent or received/handled. */
dev/so_5/mchain_select.hpp:140
↓ 2 callersMethodwork_started
dev/so_5/impl/st_env_infrastructure_reuse.hpp:78
↓ 2 callersMethodwork_stopped
dev/so_5/impl/st_env_infrastructure_reuse.hpp:79
↓ 2 callersMethodwork_thread_factory
Getter for work thread factory.
dev/so_5/disp/reuse/work_thread_factory_params.hpp:42
↓ 2 callersMethodworker_started
Remove the front demand. ! * \retval true queue must be activated. * \retval false queue must not be activated. */
dev/so_5/disp/adv_thread_pool/impl/disp.hpp:213
↓ 2 callersFunctionwrapped_env_t
dev/so_5/wrapped_env.hpp:332
↓ 1 callersMethodRead
dev/test/so_5/spinlocks/llvm_inspired_test/main.cpp:40
↓ 1 callersFunctionabstract_message_box_t
dev/so_5/mbox.hpp:197
↓ 1 callersFunctionabstract_message_chain_t
dev/so_5/mchain.hpp:463
↓ 1 callersFunctionabstract_message_sink_t
dev/so_5/message_sink.hpp:75
↓ 1 callersFunctionabstract_scenario_step_t
dev/so_5/experimental/testing/v1/all.hpp:599
↓ 1 callersFunctionabstract_work_thread_factory_t
dev/so_5/disp/abstract_work_thread.hpp:150
↓ 1 callersFunctionabstract_work_thread_t
dev/so_5/disp/abstract_work_thread.hpp:63
↓ 1 callersMethodaccept
dev/so_5/impl/st_env_infrastructure_reuse.hpp:441
↓ 1 callersFunctionaccept_indicators
dev/so_5/message_limit.hpp:589
↓ 1 callersFunctionaccept_one_indicator
dev/so_5/message_limit.hpp:126
↓ 1 callersMethodaction
dev/sample/so_5/machine_control/main.cpp:444
↓ 1 callersMethodactivate
dev/so_5/3rd_party/timertt/all.hpp:955
↓ 1 callersMethodactivate
dev/so_5/3rd_party/timertt/all.hpp:2324
↓ 1 callersMethodactivate
dev/so_5/experimental/testing/v1/all.cpp:113
↓ 1 callersMethodactual_close
dev/so_5/impl/mchain_details.hpp:573
↓ 1 callersMethodactual_name
Attempt to get an agent name. ! * \return empty std::string_view if agent has no an actual name. */
dev/so_5/agent_identity.hpp:161
↓ 1 callersMethodactual_state_to_enter
dev/so_5/agent.cpp:625
↓ 1 callersFunctionactual_work_thread_factory_to_use
dev/so_5/disp/reuse/actual_work_thread_factory_to_use.hpp:41
↓ 1 callersMethodadd_case
Helper method for setting up specific select_case. ! * This method will be used during creation of select_cases_holder. */
dev/so_5/mchain_select.hpp:819
↓ 1 callersMethodadd_child
! * \brief Add a new child to the parent coop. * * This method is called by child coop. * * \note * This method locks the parent coo
dev/so_5/coop.hpp:1241
↓ 1 callersMethodadd_current_thread
dev/test/so_5/disp/adv_thread_pool/cooperation_fifo_2/main.cpp:31
← previousnext →601–700 of 6,598, ranked by callers