MCPcopy Create free account

hub / github.com/Stiffstream/sobjectizer / functions

Functions6,598 in github.com/Stiffstream/sobjectizer

↓ 2 callersFunctiondo_check_no_wait_throw_exception_impl
dev/test/so_5/mchain/limited_no_app_abort/main.cpp:85
↓ 2 callersFunctiondo_check_stop_pred
dev/test/so_5/mchain/adv_prepared_select/main.cpp:238
↓ 2 callersFunctiondo_check_stop_pred
dev/test/so_5/mchain/adv_receive/main.cpp:221
↓ 2 callersFunctiondo_check_stop_pred
dev/test/so_5/mchain/adv_extensible_select/main.cpp:244
↓ 2 callersFunctiondo_check_stop_pred
dev/test/so_5/mchain/adv_prepared_receive/main.cpp:195
↓ 2 callersFunctiondo_check_wait_drop_newest_impl
dev/test/so_5/mchain/limited_no_app_abort/main.cpp:165
↓ 2 callersFunctiondo_check_wait_remove_oldest_impl
dev/test/so_5/mchain/limited_no_app_abort/main.cpp:200
↓ 2 callersFunctiondo_check_wait_throw_exception_impl
dev/test/so_5/mchain/limited_no_app_abort/main.cpp:235
↓ 2 callersFunctiondo_test
dev/test/so_5/mchain/adv_select_mthread_read/main.cpp:62
↓ 2 callersFunctiondo_test
dev/test/so_5/mchain/adv_select_mthread_empty_timeout/main.cpp:48
↓ 2 callersFunctiondo_test_case
dev/test/so_5/mchain/auto_close_chains_ex/main.cpp:26
↓ 2 callersFunctiondo_test_no_wait
dev/test/so_5/mchain/limited_no_app_abort/main.cpp:124
↓ 2 callersFunctiondo_test_wait
dev/test/so_5/mchain/limited_no_app_abort/main.cpp:277
↓ 2 callersMethoddrop_content
dev/so_5/impl/subscr_storage_adaptive.cpp:204
↓ 2 callersMethoddrop_disp_binder
! * \brief Helper method that drops pointer to disp_binder. * * This method is intended to be used for rollback actions * (for example, wh
dev/so_5/impl/internal_agent_iface.hpp:116
↓ 2 callersMethoddrop_subscription
dev/so_5/agent.hpp:3960
↓ 2 callersMethodempty
Check for the emptiness of message_holder.
dev/so_5/message_holder.hpp:113
↓ 2 callersMethodempty
dev/so_5/impl/local_mbox.hpp:569
↓ 2 callersMethodend
Get iterator for the item just behind the last item in select_cases_holder.
dev/so_5/mchain_select.hpp:580
↓ 2 callersFunctionensure_different_pointers
dev/test/so_5/mchain/params_clone/main.cpp:23
↓ 2 callersFunctionensure_message_with_actual_data
dev/so_5/message.hpp:538
↓ 2 callersFunctionensure_queue_not_full
dev/so_5/impl/mchain_details.hpp:64
↓ 2 callersFunctionensure_sink_for_same_owner
! * \brief Helper the ensures that sink can be used with agent. * * It throws if: * * - \a sink is not a message_sink_for_agent_t (or derived cla
dev/so_5/impl/mpsc_mbox.hpp:115
↓ 2 callersMethodensure_started
Checks that timer thread is really started. ! * \throw std::exception if thread is not started. */
dev/so_5/3rd_party/timertt/all.hpp:2971
↓ 2 callersMethodexec
Call event handler directly.
dev/so_5/execution_demand.hpp:147
↓ 2 callersMethodfind
! * \note * Returns nullptr if there is no sink for \a msg_type. */
dev/so_5/impl/std_message_sinks.hpp:136
↓ 2 callersMethodfind_or_create
dev/so_5/impl/std_message_sinks.hpp:199
↓ 2 callersMethodfinish
dev/so_5/impl/mt_env_infrastructure.cpp:47
↓ 2 callersMethodgiveout_next
Get the next item in the current queue to which select_case belongs at this moment and drop this pointer to nullptr value. ! * This method must be
dev/so_5/mchain_select_ifaces.hpp:181
↓ 2 callersMethodhandle_demand
dev/so_5/impl/st_env_infrastructure_reuse.hpp:214
↓ 2 callersMethodhandle_next
dev/so_5/mchain_select.hpp:1254
↓ 2 callersMethodhandle_next
dev/so_5/mchain.hpp:1631
↓ 2 callersMethodhas_actual_name
Does agent have an actual name?
dev/so_5/agent_identity.hpp:150
↓ 2 callersMethodhas_live_coop
Is there any live coop?
dev/so_5/impl/st_env_infrastructure_reuse.hpp:174
↓ 2 callersMethodhas_stored_msg_inspection_result
dev/so_5/experimental/testing/v1/all.cpp:1651
↓ 2 callersMethodid
dev/sample/so_5/custom_work_thread_factory/main.cpp:80
↓ 2 callersMethodid
dev/test/so_5/enveloped_msg/common_stuff.hpp:124
↓ 2 callersMethodincrement_usage_count
! * \brief Increment usage count for the coop. * * In v.5.2.3 the counter m_reference_count is used to * reflect count of references to th
dev/so_5/coop.hpp:1195
↓ 2 callersFunctionis_infinite_wait_timevalue
is_infinite_wait_timevalue ! * \brief Is time value means 'infinite_wait'? * * \since v.5.5.13 */
dev/so_5/mchain.hpp:83
↓ 2 callersFunctionis_known_mbox_msg_pair
dev/so_5/impl/subscr_storage_map_based.cpp:192
↓ 2 callersFunctionis_known_mbox_msg_pair
dev/so_5/impl/subscr_storage_hash_table_based.cpp:159
↓ 2 callersMethodis_target
dev/so_5/agent.cpp:551
↓ 2 callersMethodjoin
dev/so_5/wrapped_env.cpp:415
↓ 2 callersMethodjoin
dev/so_5/disp/nef_one_thread/pub.cpp:437
↓ 2 callersMethodjoin
dev/so_5/disp/prio_one_thread/reuse/work_thread.hpp:191
↓ 2 callersMethodjoin
dev/so_5/experimental/testing/v1/all.cpp:1699
↓ 2 callersMethodlast_extraction_status
dev/so_5/mchain_select.hpp:1267
↓ 2 callersMethodlast_status
dev/so_5/mchain.hpp:1659
↓ 2 callersMethodlock
Lock object.
dev/so_5/spinlocks.hpp:106
↓ 2 callersMethodlock
dev/so_5/details/sync_helpers.hpp:37
↓ 2 callersFunctionlock_t
dev/so_5/disp/mpmc_queue_traits/pub.hpp:90
↓ 2 callersFunctionlock_t
dev/so_5/disp/mpsc_queue_traits/pub.hpp:42
↓ 2 callersMethodmake_c_string
agent_identity_t::pointer_only_t
dev/so_5/agent.cpp:38
↓ 2 callersFunctionmake_handler_with_arg_for_agent
dev/so_5/handler_makers.hpp:265
↓ 2 callersFunctionmake_mchain
dev/test/so_5/bench/prepared_receive/main.cpp:21
↓ 2 callersFunctionmake_params_via_tuner
dev/so_5/wrapped_env.cpp:310
↓ 2 callersFunctionmake_queue_desc_holder
! * \since * v.5.5.4 * * \brief Helper function for creating queue_description_holder object. */
dev/so_5/disp/reuse/thread_pool_stats.hpp:105
↓ 2 callersMethodmake_result
dev/so_5/mchain_select.hpp:1273
↓ 2 callersMethodmake_result
dev/so_5/mchain.hpp:1682
↓ 2 callersFunctionmanager_mbox
dev/test/so_5/coop/introduce_coop_4/main.cpp:27
↓ 2 callersFunctionmanager_mbox
dev/test/so_5/coop/introduce_coop_2/main.cpp:16
↓ 2 callersFunctionmanager_mbox
dev/test/so_5/coop/introduce_coop/main.cpp:13
↓ 2 callersFunctionmanager_mbox
dev/test/so_5/coop/introduce_coop_3/main.cpp:27
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/adv_select_mthread_stop_on/main.cpp:45
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/select_mthread_read/main.cpp:51
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/select_mthread_close3/main.cpp:41
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/select_mthread_close/main.cpp:26
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/adv_select_mthread_read/main.cpp:55
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/adv_select_mthread_empty_timeout/main.cpp:41
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/select_mthread_close2/main.cpp:37
↓ 2 callersFunctionmchain_params
dev/test/so_5/mchain/adv_select_mthread_close/main.cpp:24
↓ 2 callersMethodnearest_time_point
! * \brief Get time point of the next timer. * * \attention Must be called only when \a !empty(). */
dev/so_5/3rd_party/timertt/all.hpp:1903
↓ 2 callersMethodno_handler_hook
dev/so_5/experimental/testing/v1/all.cpp:655
↓ 2 callersMethodnotify_one
dev/test/so_5/mchain/not_empty_notify/main.cpp:22
↓ 2 callersMethodoverflow_drop_newest
dev/so_5/impl/msg_tracing_helpers.hpp:1067
↓ 2 callersMethodoverflow_reaction
Overflow reaction for size-limited chain. ! * \attention Has sence only for size-limited chain. */
dev/so_5/mchain.hpp:338
↓ 2 callersMethodoverflow_remove_oldest
dev/so_5/impl/msg_tracing_helpers.hpp:1073
↓ 2 callersMethodowner_pointer
dev/so_5/impl/message_sink_for_agent.hpp:71
↓ 2 callersMethodperform
dev/so_5/coop.cpp:391
↓ 2 callersFunctionperform_receive
dev/so_5/mchain.hpp:1775
↓ 2 callersMethodpop
Pop demand from the queue. ! * \throw shutdown_ex_t in the case when queue is shut down. */
dev/so_5/disp/prio_one_thread/strictly_ordered/impl/demand_queue.hpp:194
↓ 2 callersMethodpop
Remove the front demand. ! * \note Return processing_continuation_t::disabled if * \a demands_processed exceeds m_max_demands_at_once or if *
dev/so_5/disp/thread_pool/impl/basic_event_queue.hpp:190
↓ 2 callersMethodpre_handler_hook
dev/so_5/experimental/testing/v1/all.cpp:605
↓ 2 callersMethodptr
dev/so_5/3rd_party/timertt/all.hpp:271
↓ 2 callersMethodpush
dev/test/so_5/event_handler/as_event_handler/main.cpp:93
↓ 2 callersMethodpush
dev/test/so_5/coop/msg_loss_at_registration/main.cpp:144
↓ 2 callersMethodpush
Push next demand to queue.
dev/so_5/disp/adv_thread_pool/impl/disp.hpp:133
↓ 2 callersMethodpush
dev/so_5/disp/nef_one_thread/pub.cpp:240
↓ 2 callersMethodpush
dev/so_5/disp/prio_one_thread/strictly_ordered/impl/demand_queue.hpp:115
↓ 2 callersMethodpush
dev/so_5/disp/prio_one_thread/quoted_round_robin/impl/demand_queue.hpp:127
↓ 2 callersMethodpush
Push next demand to queue.
dev/so_5/disp/thread_pool/impl/basic_event_queue.hpp:107
↓ 2 callersMethodpush
! * \name Implementation of event_queue interface. * \{ */
dev/so_5/disp/reuse/work_thread/work_thread.hpp:196
↓ 2 callersMethodpush
dev/so_5/impl/simple_not_mtsafe_st_env_infrastructure.cpp:66
↓ 2 callersMethodpush
! * \note * This method locks the main mutex by itself. */
dev/so_5/impl/simple_mtsafe_st_env_infrastructure.cpp:133
↓ 2 callersMethodpush
dev/so_5/experimental/testing/v1/all.cpp:1312
↓ 2 callersMethodpush_event
dev/so_5/agent.cpp:1402
↓ 2 callersMethodpush_event
dev/so_5/impl/message_sink_with_message_limit.hpp:89
↓ 2 callersMethodpush_to_queue
dev/so_5/impl/msg_tracing_helpers.hpp:751
↓ 2 callersMethodquery_content
dev/so_5/impl/subscr_storage_adaptive.cpp:211
↓ 2 callersMethodquery_fifo
Get FIFO type.
dev/so_5/disp/thread_pool/pub.hpp:197
← previousnext →501–600 of 6,598, ranked by callers