| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mchain/select_send_simple/ |
| H A D | main.cpp | 20 so_5::wrapped_env_t env; in UT_UNIT_TEST()
27 so_5::send< hello >( ch ); in UT_UNIT_TEST()
28 so_5::send< hello >( ch ); in UT_UNIT_TEST()
32 auto r = so_5::select( in UT_UNIT_TEST()
53 so_5::wrapped_env_t env; in UT_UNIT_TEST()
67 auto r = so_5::select( in UT_UNIT_TEST()
106 auto r = so_5::select( in UT_UNIT_TEST()
143 auto r = so_5::select( in UT_UNIT_TEST()
151 so_5::receive( in UT_UNIT_TEST()
195 auto r = so_5::select( in UT_UNIT_TEST()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/doxygen/dox/so_5/ |
| H A D | samples.dox | 2 * \example so_5/chstate/main.cpp
6 * \example so_5/chstate_msg_tracing/main.cpp
10 * \example so_5/coop_listener/main.cpp
14 * \example so_5/coop_notification/main.cpp
22 * \example so_5/disp/main.cpp
34 * \example so_5/hello_all/main.cpp
38 * \example so_5/hello_delay/main.cpp
54 * \example so_5/hello_world/main.cpp
66 * \example so_5/ping_pong/main.cpp
78 * \example so_5/many_timers/main.cpp
[all …]
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/mchains/fixed_size/simple/ |
| H A D | main.cpp | 17 so_5::launch( [&](so_5::environment_t & env) { in __anon7b90a8ac0102()
33 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0102()
35 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0102()
49 so_5::launch( [&](so_5::environment_t & env) { in __anon7b90a8ac0602()
65 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0602()
67 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0602()
77 so_5::launch( [&](so_5::environment_t & env) { in __anon7b90a8ac0a02()
100 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0a02()
102 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0a02()
139 so_5::receive( so_5::from(ch).handle_n(1), in __anon7b90a8ac0f02()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/message_holder/ |
| H A D | main.cpp | 65 so_5::send( in run()
98 so_5::send( in run()
112 so_5::send_delayed( in run()
138 so_5::send_delayed( in run()
274 so_5::launch( in do_test()
303 do_test< so_5::immutable_msg<so5_message>, so_5::message_ownership_t::shared >( in main()
305 do_test< so_5::immutable_msg<so5_message>, so_5::message_ownership_t::unique >( in main()
310 do_test< so_5::mutable_msg<so5_message>, so_5::message_ownership_t::shared >( in main()
312 do_test< so_5::mutable_msg<so5_message>, so_5::message_ownership_t::unique >( in main()
331 do_test< so_5::mutable_msg<user_message>, so_5::message_ownership_t::shared >( in main()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/drop_subscription/ |
| H A D | main.cpp | 15 const so_5::mbox_t m_actual_mbox;
38 virtual so_5::mbox_id_t
76 virtual so_5::mbox_type_t
99 so_5::environment_t &
105 static so_5::mbox_t
126 so_5::environment_t & env, in a_test_t()
162 so_5::send< msg_one >( m_mbox ); in so_evt_start()
163 so_5::send< msg_two >( m_mbox ); in so_evt_start()
181 so_5::send< msg_one >( m_mbox ); in evt_default_two()
278 so_5::mbox_t m_mbox;
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/event_handler/external_subscription/ |
| H A D | main.cpp | 20 so_5::mbox_t m_mbox;
21 const so_5::state_t * m_state;
23 so_5::event_handler_method_t m_handler;
26 so_5::mbox_t mbox, in subscription_data_t()
27 const so_5::state_t & state, in subscription_data_t()
39 so_5::outliving_reference_t< so_5::agent_t > m_agent;
50 const so_5::mbox_t & mbox, in add_handler()
51 const so_5::state_t & state, in add_handler()
85 so_5::thread_safety_t::unsafe, in activate()
149 : so_5::agent_t( std::move(ctx) ) in a_test_t()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mchain/limited_no_app_abort/ |
| H A D | main.cpp | 19 so_5::environment_t & env, in do_check_no_wait_drop_newest_impl()
31 so_5::send< int >( ch, 1 ); in do_check_no_wait_drop_newest_impl()
32 so_5::send< int >( ch, 2 ); in do_check_no_wait_drop_newest_impl()
33 so_5::send< int >( ch, 3 ); in do_check_no_wait_drop_newest_impl()
34 so_5::send< int >( ch, 4 ); in do_check_no_wait_drop_newest_impl()
53 so_5::environment_t & env, in do_check_no_wait_remove_oldest_impl()
65 so_5::send< int >( ch, 1 ); in do_check_no_wait_remove_oldest_impl()
66 so_5::send< int >( ch, 2 ); in do_check_no_wait_remove_oldest_impl()
67 so_5::send< int >( ch, 3 ); in do_check_no_wait_remove_oldest_impl()
68 so_5::send< int >( ch, 4 ); in do_check_no_wait_remove_oldest_impl()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mchain/master_handle/ |
| H A D | main.cpp | 26 const so_5::mchain_t & ch1 ) in check_drop_content1()
34 auto r = so_5::select( in check_drop_content1()
44 const so_5::mchain_t & ch1, in check_drop_content3()
45 const so_5::mchain_t & ch2, in check_drop_content3()
46 const so_5::mchain_t & ch3 ) in check_drop_content3()
58 auto r = so_5::select( in check_drop_content3()
79 auto r = so_5::select( in check_retain_content1()
87 r = so_5::select( in check_retain_content1()
116 auto r = so_5::select( in check_retain_content3()
126 r = so_5::select( in check_retain_content3()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mutable_msg/simple_mchain/ |
| H A D | main.cpp | 34 so_5::send< so_5::mutable_msg<sobj_hello> >( ch, "sh2" ); in do_test()
35 so_5::send< so_5::immutable_msg<sobj_hello> >( ch, "sh3" ); in do_test()
38 so_5::send< so_5::immutable_msg<user_hello> >( ch, "uh2" ); in do_test()
39 so_5::send< so_5::mutable_msg<user_hello> >( ch, "uh3" ); in do_test()
42 so_5::send< so_5::immutable_msg<sig_hello> >( ch ); in do_test()
44 so_5::send_delayed< so_5::mutable_msg<sobj_hello> >( in do_test()
46 so_5::send_delayed< so_5::mutable_msg<user_hello> >( in do_test()
49 auto t1 = so_5::send_periodic< so_5::mutable_msg<sobj_hello> >( in do_test()
55 auto t2 = so_5::send_periodic< so_5::mutable_msg<user_hello> >( in do_test()
100 [&]( so_5::mhood_t< so_5::mutable_msg<sobj_hello> > cmd ) { in do_test()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mutable_msg/receive_mutable_lambda/ |
| H A D | main.cpp | 23 : so_5::agent_t(std::move(ctx)) in sobj_message_tester()
45 so_5::send<so_5::mutable_msg<first>>(*this); in so_evt_start()
46 so_5::send<so_5::mutable_msg<second>>(*this); in so_evt_start()
47 so_5::send<so_5::mutable_msg<third>>(*this); in so_evt_start()
48 so_5::send<so_5::mutable_msg<fourth>>(*this); in so_evt_start()
61 : so_5::agent_t(std::move(ctx)) in user_message_tester()
86 so_5::send<so_5::mutable_msg<first>>(*this); in so_evt_start()
87 so_5::send<so_5::mutable_msg<second>>(*this); in so_evt_start()
88 so_5::send<so_5::mutable_msg<third>>(*this); in so_evt_start()
89 so_5::send<so_5::mutable_msg<fourth>>(*this); in so_evt_start()
[all …]
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/mboxes/retained_msg/delivery_filter/ |
| H A D | main.cpp | 37 so_5::mbox_t control_mbox, in with_delivery_filter_case_t()
38 so_5::mbox_t retained_mbox) in with_delivery_filter_case_t()
39 : so_5::agent_t( std::move(ctx) ) in with_delivery_filter_case_t()
63 const so_5::mbox_t m_control_mbox;
73 so_5::mbox_t control_mbox, in without_delivery_filter_case_t()
74 so_5::mbox_t retained_mbox) in without_delivery_filter_case_t()
75 : so_5::agent_t( std::move(ctx) ) in without_delivery_filter_case_t()
107 : so_5::agent_t{std::move(ctx)} in supervisor_t()
127 [this](so_5::coop_t & coop) { in so_evt_start()
155 so_5::launch( [&](so_5::environment_t & env) { in __anon4396f73e0702()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mchain/auto_close_chains/ |
| H A D | main.cpp | 26 so_5::mchain_t ch1 ) in check_drop_content1()
34 auto r = so_5::select( in check_drop_content1()
44 so_5::mchain_t ch1, in check_drop_content3()
45 so_5::mchain_t ch2, in check_drop_content3()
46 so_5::mchain_t ch3 ) in check_drop_content3()
68 so_5::mchain_t ch1 ) in check_retain_content1()
85 r = so_5::select( in check_retain_content1()
95 so_5::mchain_t ch1, in check_retain_content3()
96 so_5::mchain_t ch2, in check_retain_content3()
97 so_5::mchain_t ch3 ) in check_retain_content3()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/resend_message/ |
| H A D | main.cpp | 21 : so_5::agent_t{ std::move(ctx) } in first_sender_t()
29 so_5::send( m_second, m_message ); in so_evt_start()
33 const so_5::mbox_t m_second;
41 : so_5::agent_t{ std::move(ctx) } in second_sender_t()
48 const so_5::mbox_t m_third;
63 : so_5::agent_t{ std::move(ctx) } in third_sender_t()
72 const so_5::mbox_t m_fourth;
80 so_5::send<resend>( *this ); in on_message()
84 on_resend( so_5::mhood_t<resend> ) in on_resend()
113 so_5::launch( in main()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mutable_msg/receive_mutable/ |
| H A D | main.cpp | 23 : so_5::agent_t(std::move(ctx)) in sobj_message_tester()
34 so_5::send<so_5::mutable_msg<first>>(*this); in so_evt_start()
35 so_5::send<so_5::mutable_msg<second>>(*this); in so_evt_start()
36 so_5::send<so_5::mutable_msg<third>>(*this); in so_evt_start()
37 so_5::send<so_5::mutable_msg<fourth>>(*this); in so_evt_start()
78 : so_5::agent_t(std::move(ctx)) in user_message_tester()
89 so_5::send<so_5::mutable_msg<first>>(*this); in so_evt_start()
90 so_5::send<so_5::mutable_msg<second>>(*this); in so_evt_start()
91 so_5::send<so_5::mutable_msg<third>>(*this); in so_evt_start()
92 so_5::send<so_5::mutable_msg<fourth>>(*this); in so_evt_start()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/timer_thread/resend_delayed_via_mhood_to_mchain/ |
| H A D | main.cpp | 22 : so_5::agent_t(std::move(ctx)) in first_tester()
36 so_5::send_delayed< so_5::immutable_msg<hello> >( in so_evt_start()
42 so_5::mchain_t m_mchain;
46 so_5::send_delayed( in on_hello()
91 so_5::send_delayed< so_5::immutable_msg<hello> >( in so_evt_start()
98 so_5::mchain_t m_mchain;
102 so_5::send_delayed( in on_hello()
149 so_5::send_delayed< so_5::mutable_msg<hello> >( in so_evt_start()
156 so_5::mchain_t m_mchain;
160 so_5::send_delayed( in on_hello()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/sample/so_5/prio_work_stealing/ |
| H A D | main.cpp | 155 : so_5::agent_t( ctx ) in request_generator()
281 so_5::mbox_t m_processor;
337 : so_5::agent_t( ctx in request_acceptor()
339 + so_5::prio::p0 in request_acceptor()
372 auto pos = so_5::to_size_t( so_5::priority_t::p_max ) - in evt_request()
410 : so_5::agent_t( ctx in request_scheduler()
412 + so_5::prio::p1 ) in request_scheduler()
434 so_5::prio::for_each_priority( [&]( so_5::priority_t p ) { in so_evt_start()
466 so_5::coop_t & coop, in create_processor_agent()
535 so_5::send( in try_schedule_work_to()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/resend_message_2/ |
| H A D | main.cpp | 21 : so_5::agent_t{ std::move(ctx) } in first_sender_t()
29 so_5::send( m_second, m_message ); in so_evt_start()
33 const so_5::mbox_t m_second;
41 : so_5::agent_t{ std::move(ctx) } in second_sender_t()
48 const so_5::mbox_t m_third;
63 : so_5::agent_t{ std::move(ctx) } in third_sender_t()
72 const so_5::mbox_t m_fourth;
80 so_5::send<resend>( *this ); in on_message()
84 on_resend( so_5::mhood_t<resend> ) in on_resend()
113 so_5::launch( in main()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/resend_message_as_mutable/ |
| H A D | main.cpp | 21 : so_5::agent_t{ std::move(ctx) } in first_sender_t()
33 const so_5::mbox_t m_second;
34 so_5::message_holder_t< so_5::mutable_msg< message > > m_message;
41 : so_5::agent_t{ std::move(ctx) } in second_sender_t()
48 const so_5::mbox_t m_third;
64 : so_5::agent_t{ std::move(ctx) } in third_sender_t()
73 const so_5::mbox_t m_fourth;
74 so_5::message_holder_t< so_5::mutable_msg<message> > m_message;
82 so_5::send<resend>( *this ); in on_message()
86 on_resend( so_5::mhood_t<resend> ) in on_resend()
[all …]
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/mboxes/collecting_mbox/illegal_usage/ |
| H A D | main.cpp | 12 struct hello final : public so_5::message_t
27 make( const so_5::mbox_t & target ) in make()
41 make( const so_5::mbox_t & target ) in make()
50 using so_5::agent_t::agent_t;
63 so_5::launch( [&](so_5::environment_t & env) { in __anonf163906a0102()
77 catch( const so_5::exception_t & x ) { in __anonf163906a0102()
82 so_5::exception_t ); in __anonf163906a0102()
95 so_5::launch( [&](so_5::environment_t & env) { in __anonf163906a0502()
120 so_5::launch( [&](so_5::environment_t & env) { in __anonf163906a0902()
139 so_5::exception_t ); in __anonf163906a0902()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/resend_message_as_mutable_2/ |
| H A D | main.cpp | 21 : so_5::agent_t{ std::move(ctx) } in first_sender_t()
33 const so_5::mbox_t m_second;
34 so_5::message_holder_t< so_5::mutable_msg<message> > m_message;
41 : so_5::agent_t{ std::move(ctx) } in second_sender_t()
48 const so_5::mbox_t m_third;
64 : so_5::agent_t{ std::move(ctx) } in third_sender_t()
73 const so_5::mbox_t m_fourth;
74 so_5::message_holder_t< so_5::mutable_msg<message> > m_message;
82 so_5::send<resend>( *this ); in on_message()
86 on_resend( so_5::mhood_t<resend> ) in on_resend()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/event_handler/deadletter_handler_formats/ |
| H A D | main.cpp | 71 so_5::send<msg_1>( *this ); in so_evt_start()
72 so_5::send<msg_2>( *this ); in so_evt_start()
73 so_5::send<msg_3>( *this ); in so_evt_start()
74 so_5::send<msg_4>( *this ); in so_evt_start()
75 so_5::send<msg_5>( *this ); in so_evt_start()
76 so_5::send<msg_6>( *this ); in so_evt_start()
79 so_5::send<so_5::mutable_msg<msg_9>>( *this ); in so_evt_start()
80 so_5::send<so_5::mutable_msg<msg_10>>( *this ); in so_evt_start()
81 so_5::send<so_5::mutable_msg<msg_11>>( *this ); in so_evt_start()
82 so_5::send<so_5::mutable_msg<msg_12>>( *this ); in so_evt_start()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/sample/so_5/producer_consumer_mchain/ |
| H A D | main.cpp | 26 so_5::mbox_t make_logger( so_5::coop_t & coop ) in make_logger()
30 using so_5::agent_t::agent_t; in make_logger()
83 : so_5::agent_t{ ctx } in shutdowner()
111 so_5::mbox_t m_who;
132 so_5::mbox_t logger_mbox, in producer()
133 so_5::mbox_t consumer_mbox, in producer()
135 : so_5::agent_t{ ctx } in producer()
149 so_5::send< send_next >( *this ); in so_evt_start()
154 const so_5::mbox_t m_logger_mbox;
251 so_5::mchain_t m_chain;
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/disp/prio_ot_quoted_round_robin/simple_quote/ |
| H A D | main.cpp | 16 so_5::priority_t m_priority;
25 so_5::coop_t & coop, in define_receiver_agent()
27 so_5::priority_t priority, in define_receiver_agent()
37 so_5::priority_t priority, in define_receiver_agent()
38 so_5::mbox_t common_mbox ) in define_receiver_agent()
60 so_5::coop_t & coop, in define_message_sender()
68 : so_5::agent_t{ ctx + so_5::prio::p0 } in define_message_sender()
84 so_5::coop_t & coop, in define_supervison_agent()
156 so_5::coop_t & coop ) in fill_coop()
159 using namespace so_5::prio; in fill_coop()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mchain/adv_prepared_select/ |
| H A D | main.cpp | 44 so_5::wrapped_env_t env; in UT_UNIT_TEST()
86 so_5::wrapped_env_t env; in UT_UNIT_TEST()
98 const so_5::mchain_t & ch1, in do_check_handle_n()
99 const so_5::mchain_t & ch2 ) in do_check_handle_n()
115 so_5::send< int >( ch1, 0 ); in do_check_handle_n()
141 so_5::wrapped_env_t env; in UT_UNIT_TEST()
154 const so_5::mchain_t & ch1, in do_check_extract_n()
200 so_5::wrapped_env_t env; in UT_UNIT_TEST()
213 const so_5::mchain_t & ch1, in do_check_stop_pred()
289 const so_5::mchain_t & ch, in do_check_parallel_select()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/timer_thread/resend_periodic_via_mhood_to_mchain/ |
| H A D | main.cpp | 22 : so_5::agent_t(std::move(ctx)) in first_tester()
36 m_timer = so_5::send_periodic< so_5::immutable_msg<hello> >( in so_evt_start()
43 so_5::timer_id_t m_timer;
44 so_5::mchain_t m_mchain;
104 m_timer = so_5::send_periodic< so_5::immutable_msg<hello> >( in so_evt_start()
112 so_5::timer_id_t m_timer;
113 so_5::mchain_t m_mchain;
175 m_timer = so_5::send_periodic< so_5::mutable_msg<hello> >( in so_evt_start()
183 so_5::timer_id_t m_timer;
184 so_5::mchain_t m_mchain;
[all …]
|