Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Stiffstream/sobjectizer
/ functions
Functions
6,598 in github.com/Stiffstream/sobjectizer
⨍
Functions
6,598
◇
Types & classes
2,766
↓ 859 callers
Method
event
dev/test/so_5/disp/private_dispatchers/env_stop/main.cpp:37
↓ 436 callers
Function
run_with_time_limit
dev/test/3rd_party/various_helpers/time_limited_execution.hpp:20
↓ 413 callers
Function
launch
dev/so_5/api.hpp:141
↓ 325 callers
Function
so_subscribe_self
! * \brief Initiate subscription to agent's direct mbox. * * Note that is just a short form of: * \code * void a_sample_t::so_define_ag
dev/so_5/agent.hpp:1460
↓ 283 callers
Method
introduce_coop
dev/so_5/environment.hpp:2190
↓ 257 callers
Method
event
dev/so_5/agent.hpp:3652
↓ 221 callers
Function
to_string
dev/test/so_5/mbox/sink_binding/multi_sink_unbind/main.cpp:23
↓ 212 callers
Method
binder
Get a binder for that dispatcher.
dev/so_5/disp/active_obj/pub.hpp:153
↓ 203 callers
Function
ensure_or_die
! * \brief A helper function which calls std::abort if some condition is not meet. * * \note Prints \a explanation_msg to std::cerr before calling
dev/test/3rd_party/various_helpers/ensure.hpp:95
↓ 193 callers
Method
create_mbox
dev/so_5/environment.cpp:523
↓ 184 callers
Function
make_dispatcher
! * \brief Create an instance of %active_obj dispatcher. * * \par Usage sample \code auto disp = so_5::disp::active_obj::make_dispatcher( env, "d
dev/so_5/disp/active_obj/pub.hpp:222
↓ 172 callers
Method
scenario
dev/so_5/experimental/testing/v1/all.cpp:1711
↓ 143 callers
Method
get
! * \name Access to object. * \{ */
dev/so_5/3rd_party/timertt/all.hpp:379
↓ 135 callers
Method
create_mchain
dev/so_5/environment.cpp:548
↓ 120 callers
Function
swap
dev/so_5/agent.cpp:149
↓ 106 callers
Method
handle_n
Set limit for count of messages to be handled. ! * When handled_n() is used then receive() will be finished * after handling of the specified nu
dev/so_5/mchain.hpp:1347
↓ 101 callers
Function
ensure
! * \since v.1.0.2 * \brief Very simple form of ensure helper function. * * \par Purpose * Checks the \a p argument and throws an exception if \a
dev/test/3rd_party/various_helpers/ensure.hpp:30
↓ 98 callers
Method
stop
dev/test/so_5/environment/stop_guards/simple/main.cpp:26
↓ 93 callers
Function
receive
dev/so_5/mchain.hpp:1882
↓ 91 callers
Function
from
from ! * \brief A helper function for simplification of creation of %mchain_receive_params instance. * * \attention * Since v.5.6.0 at least hand
dev/so_5/mchain.hpp:1594
↓ 89 callers
Function
outliving_mutable
dev/so_5/outliving.hpp:130
↓ 86 callers
Function
receive_case
dev/so_5/mchain_select.hpp:1532
↓ 83 callers
Function
so_drop_subscription
dev/so_5/agent.hpp:1556
↓ 78 callers
Method
on_enter
dev/test/so_5/state/const_enter_exit_handlers/main.cpp:64
↓ 78 callers
Method
register_coop
dev/so_5/environment.cpp:611
↓ 73 callers
Method
push_back
Add a new item to the end of the queue.
dev/so_5/impl/mchain_details.hpp:121
↓ 72 callers
Method
on_exit
dev/test/so_5/state/const_enter_exit_handlers/main.cpp:69
↓ 70 callers
Method
end
dev/so_5/impl/local_mbox.hpp:542
↓ 70 callers
Method
size
! * \brief Get agent count in the cooperation. * \note Just an alias for query_agent_count(). * * \since v.5.5.16 */
dev/so_5/coop.hpp:856
↓ 65 callers
Method
make_coop
dev/so_5/environment.cpp:571
↓ 64 callers
Method
join
dev/test/so_5/disp/custom_work_thread.hpp:41
↓ 64 callers
Function
select
dev/so_5/mchain_select.hpp:1690
↓ 63 callers
Function
from_all
from_all ! * \brief Helper function for creation of mchain_select_params instance * with default values. * * \attention * Since v.5.6.0 at least
dev/so_5/mchain_select.hpp:213
↓ 61 callers
Method
handled
Count of handled messages.
dev/so_5/mchain.hpp:997
↓ 59 callers
Function
is_arg
dev/test/3rd_party/various_helpers/cmd_line_args_helpers.hpp:11
↓ 56 callers
Method
id
dev/so_5/impl/named_local_mbox.cpp:35
↓ 55 callers
Method
define_step
dev/so_5/experimental/testing/v1/all.cpp:1607
↓ 54 callers
Method
get
dev/so_5/coop.hpp:1378
↓ 52 callers
Function
create_mchain
! * \brief Create size-unlimited chain. * * \code so_5::environment_t & env = ...; auto ch = create_mchain( env ); // Or as more verbose altern
dev/so_5/mchain_helper_functions.hpp:41
↓ 52 callers
Method
find
dev/so_5/impl/local_mbox.hpp:524
↓ 49 callers
Method
extracted
Count of extracted messages.
dev/so_5/mchain.hpp:992
↓ 48 callers
Method
drop_subscription
dev/test/so_5/bench/subscribe_unsubscribe/main.cpp:228
↓ 46 callers
Method
result
dev/so_5/experimental/testing/v1/all.cpp:1614
↓ 45 callers
Method
empty
Is prefix empty?
dev/so_5/stats/prefix.hpp:97
↓ 45 callers
Method
erase
dev/so_5/impl/local_mbox.hpp:509
↓ 45 callers
Method
handle_all
A directive to handle all messages until chain will be closed or receiving will be stopped manually. ! * Usage example: * \code * so_5::recei
dev/so_5/mchain.hpp:1313
↓ 45 callers
Method
run_for
dev/so_5/experimental/testing/v1/all.cpp:1620
↓ 43 callers
Function
build_mchain_params
dev/test/so_5/mchain/mchain_params.hpp:9
↓ 43 callers
Function
factory
! * \brief A factory for creation of simple thread-safe * single-thread environment infrastructure object with * default parameters. * * Usage ex
dev/so_5/env_infrastructures.hpp:149
↓ 43 callers
Method
reserve
! * \brief Reserve a space for vector for holding agents list. * * This method can help avoid reallocations of agents list during * fillin
dev/so_5/coop.hpp:882
↓ 39 callers
Method
mbox
dev/sample/so_5/custom_work_thread_factory/main.cpp:228
↓ 39 callers
Function
query_current_thread_id
Get the ID of the current thread.
dev/so_5/current_thread_id.hpp:29
↓ 38 callers
Method
name
dev/test/so_5/mbox/sink_binding/bind_then_transform_signal/main.cpp:169
↓ 36 callers
Method
activate
dev/test/so_5/event_handler/external_subscription/main.cpp:76
↓ 36 callers
Function
mandatory_arg_to_value
dev/test/3rd_party/various_helpers/cmd_line_args_helpers.hpp:45
↓ 35 callers
Method
message
dev/test/so_5/messages/resend_message/main.cpp:14
↓ 35 callers
Method
size
dev/so_5/impl/mchain_details.hpp:470
↓ 34 callers
Function
introduce_child_coop
dev/so_5/environment.hpp:2299
↓ 34 callers
Function
send
dev/so_5/send_functions.hpp:227
↓ 33 callers
Method
end
Get the past-the-end iterator for the path.
dev/so_5/state.hpp:1879
↓ 33 callers
Method
get
dev/test/so_5/environment/reg_coop_after_stop/main.cpp:29
↓ 33 callers
Method
get
dev/test/so_5/mbox/custom_direct_mbox_factory/main.cpp:35
↓ 33 callers
Method
take_under_control
dev/so_5/coop.hpp:709
↓ 32 callers
Method
insert
dev/so_5/impl/local_mbox.hpp:484
↓ 32 callers
Function
invoke_noexcept_code
dev/so_5/details/invoke_noexcept_code.hpp:29
↓ 32 callers
Function
to_size_t
! * \since * v.5.5.8 * * \brief Helper function for conversion from priority to size_t. */
dev/so_5/priority.hpp:47
↓ 31 callers
Method
c_str
Access to prefix value.
dev/so_5/stats/prefix.hpp:78
↓ 31 callers
Method
content
dev/test/so_5/enveloped_msg/common_stuff.hpp:22
↓ 28 callers
Method
begin
Get iterator for the very first item of the path.
dev/so_5/state.hpp:1871
↓ 28 callers
Method
begin
dev/so_5/impl/local_mbox.hpp:533
↓ 28 callers
Method
reset
! * \since * v.5.2.2 * * \brief Drop controlled object. */
dev/so_5/atomic_refcounted.hpp:201
↓ 27 callers
Method
id
dev/test/so_5/mbox/custom_mbox_simple/main.cpp:25
↓ 27 callers
Function
so_drop_subscription_for_all_states
dev/so_5/agent.hpp:1756
↓ 27 callers
Function
wrap_to_msink
dev/so_5/mbox.cpp:108
↓ 26 callers
Method
on_enter
dev/so_5/agent.hpp:4037
↓ 26 callers
Function
so_set_delivery_filter
dev/so_5/agent.hpp:2470
↓ 25 callers
Method
emplace
dev/so_5/impl/local_mbox.hpp:502
↓ 24 callers
Method
stop
dev/sample/so_5/stop_guard/main.cpp:25
↓ 23 callers
Function
close_retain_content
dev/so_5/mchain.hpp:719
↓ 23 callers
Function
make_trace
dev/so_5/impl/msg_tracing_helpers.hpp:556
↓ 23 callers
Method
thread_count
Getter for thread count.
dev/so_5/disp/thread_pool/pub.hpp:92
↓ 22 callers
Method
notify_one
dev/so_5/disp/mpsc_queue_traits/pub.hpp:231
↓ 21 callers
Function
do_with_rollback_on_exception
dev/so_5/details/rollback_on_exception.hpp:84
↓ 20 callers
Method
lock_and_perform
dev/so_5/details/sync_helpers.hpp:129
↓ 19 callers
Method
empty
dev/so_5/impl/mchain_details.hpp:464
↓ 19 callers
Function
make_unlimited_mchain_params
! * \brief Create parameters for size-unlimited %mchain. * * \par Usage example: \code so_5::environment_t & env = ...; auto chain = env.create_
dev/so_5/mchain.hpp:859
↓ 19 callers
Method
stored_msg_inspection_result
dev/so_5/experimental/testing/v1/all.cpp:1643
↓ 18 callers
Function
create_child_coop
dev/so_5/environment.hpp:2220
↓ 18 callers
Function
ensure_expected_value
dev/test/so_5/messages/make_transformed_message_holder/main.cpp:28
↓ 18 callers
Function
make_transformed
dev/so_5/transformed_message.hpp:220
↓ 18 callers
Function
send_case
dev/so_5/mchain_select.hpp:1564
↓ 18 callers
Function
so_subscribe_deadletter_handler
dev/so_5/agent.hpp:2124
↓ 18 callers
Method
wait
dev/so_5/disp/mpmc_queue_traits/pub.cpp:66
↓ 17 callers
Function
SO_5_LOG_ERROR
dev/so_5/agent.cpp:1199
↓ 17 callers
Method
add_dereg_notificator
dev/so_5/coop.cpp:145
↓ 17 callers
Function
combined_lock_factory
combined_lock_factory ! * \brief Factory for creation of combined queue lock with default waiting time. * * \par Usage example: \code using name
dev/so_5/disp/mpmc_queue_traits/pub.hpp:194
↓ 17 callers
Method
status
Status of send operation.
dev/so_5/mchain.hpp:1065
↓ 17 callers
Method
turn_on
dev/so_5/stats/impl/std_controller.cpp:43
↓ 16 callers
Method
append
dev/test/so_5/enveloped_msg/common_stuff.hpp:15
↓ 16 callers
Function
make_unique_subscribers_mbox
dev/so_5/unique_subscribers_mbox.hpp:366
next →
1–100 of 6,598, ranked by callers