| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/ |
| H A D | enveloped_msg.hpp | 47 mutable message_ref_t m_message;
52 message_ref_t message ) in payload_info_t()
61 message_ref_t &
232 const message_ref_t & envelope );
254 optional< message_ref_t >
256 const message_ref_t & msg_or_envelope );
|
| H A D | handler_makers.hpp | 86 make_arg( message_ref_t & mf ) in make_arg()
111 make_arg( message_ref_t & mf ) in make_arg()
135 make_arg( message_ref_t & mf ) in make_arg()
160 make_arg( message_ref_t & mf ) in make_arg()
182 make_arg( message_ref_t & ) { return {}; } in make_arg()
201 make_arg( message_ref_t & ) { return {}; } in make_arg()
246 auto method = [lambda](message_ref_t & message_ref) mutable in make_handler_with_arg()
307 auto method = [agent, pfn](message_ref_t & message_ref) in make_handler_with_arg_for_agent()
482 message_ref_t & message );
538 message_ref_t & message ) const in handle()
[all …]
|
| H A D | mbox.hpp | 231 const message_ref_t & message,
307 const message_ref_t & message );
346 const message_ref_t & message ) in delegate_deliver_message_from_timer()
385 message_ref_t{ msg.release() }, in deliver_message()
409 message_ref_t msg ) in deliver_message()
440 message_ref_t(), in deliver_signal()
|
| H A D | enveloped_msg.cpp | 76 const message_ref_t & envelope_to_process ) noexcept in try_get_payload()
97 const message_ref_t & envelope_to_process ) in extract_payload_for_message_transformation()
106 optional< message_ref_t >
108 const message_ref_t & msg_or_envelope ) in message_to_be_inspected()
110 message_ref_t result = msg_or_envelope; in message_to_be_inspected()
|
| H A D | mhood.hpp | 76 mhood_base_t( message_ref_t & mf ) noexcept in mhood_base_t()
144 mhood_base_t( message_ref_t & mf ) noexcept in mhood_base_t()
230 mhood_base_t( message_ref_t & ) {} in mhood_base_t() argument
249 mhood_base_t( message_ref_t & ) {} in mhood_base_t() argument
274 mhood_base_t( message_ref_t & mf ) noexcept in mhood_base_t()
339 mhood_base_t( message_ref_t & mf ) noexcept in mhood_base_t()
574 mhood_t( message_ref_t & mf ) : base_type_t{ mf } {} in mhood_t()
599 message_ref_t ref{ msg.make_reference() }; in to_immutable()
609 message_ref_t ref; in to_immutable()
|
| H A D | message.hpp | 275 using message_ref_t = intrusive_ptr_t< message_t >; typedef
684 extract_payload_ptr( message_ref_t & msg ) in extract_payload_ptr()
694 extract_envelope_ptr( message_ref_t & msg ) in extract_envelope_ptr()
755 extract_payload_ptr( message_ref_t & msg ) in extract_payload_ptr()
767 extract_envelope_ptr( message_ref_t & msg ) in extract_envelope_ptr()
833 mark_as_mutable_if_necessary( message_ref_t & msg ) in mark_as_mutable_if_necessary()
855 mark_as_mutable_if_necessary( message_ref_t & /*msg*/ ) in mark_as_mutable_if_necessary() argument
962 const message_ref_t & m_message;
984 const message_ref_t & message, in overlimit_context_t()
|
| H A D | timers.cpp | 109 message_ref_t m_msg;
115 message_ref_t msg ) in timer_action_for_timer_thread_t()
169 const message_ref_t & msg, in schedule()
187 const message_ref_t & msg, in schedule_anonymous()
228 message_ref_t m_msg;
236 message_ref_t msg ) in timer_action_for_timer_manager_t()
295 const message_ref_t & msg, in schedule()
314 const message_ref_t & msg, in schedule_anonymous()
|
| H A D | send_functions.hpp | 73 message_ref_t{ make_instance( std::forward<Args>(args)... ) }, in send_delayed()
88 message_ref_t{ make_instance( std::forward<Args>(args)... ) }, in send_periodic()
115 message_ref_t{}, in send_delayed()
128 message_ref_t{}, in send_periodic()
515 message_ref_t{}, in send_delayed()
773 message_ref_t{}, in send_periodic()
|
| H A D | timers.hpp | 174 const message_ref_t & msg,
192 const message_ref_t & msg,
453 message_ref_t msg ) = 0;
484 const message_ref_t & msg,
502 const message_ref_t & msg,
|
| H A D | execution_demand.hpp | 34 using event_handler_method_t = std::function< void(message_ref_t &) >;
71 message_ref_t m_message_ref;
89 message_ref_t message_ref, in execution_demand_t()
|
| H A D | handler_makers.cpp | 26 message_ref_t & message ) in process_envelope_when_handler_found()
55 message_ref_t & message ) in find_and_use_handler()
|
| H A D | message_limit.hpp | 403 const message_ref_t & message );
476 m_message = message_ref_t( msg.release() ); in transformed_message_t()
499 const message_ref_t &
525 message_ref_t m_message;
775 [&]( const message_ref_t & msg_to_transform ) { in limit_then_transform()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/mboxes/ |
| H A D | collecting_mbox.hpp | 177 message_ref_t msg ) in store_collected_messages()
222 message_ref_t ref{ this->storage()[ index ] }; in with_nth()
252 for( message_ref_t ref : this->storage() ) in for_each()
286 message_ref_t ref{ this->storage()[ index ] }; in for_each_with_index()
308 inline optional< message_ref_t >
309 detect_message_to_store( message_ref_t what ) in detect_message_to_store()
360 message_ref_t message, in store()
458 message_ref_t /*message*/, in store() argument
688 const message_ref_t & message, in do_deliver_message()
750 const message_ref_t & message ) in collect_new_message()
[all …]
|
| H A D | retained_msg.hpp | 280 message_ref_t m_retained_msg;
413 const message_ref_t & message, in do_deliver_message()
541 const message_ref_t & message, in do_deliver_message_impl()
573 const message_ref_t & message, in do_deliver_message_to_subscriber()
617 const message_ref_t & retained_msg, in try_deliver_retained_message_to()
652 const message_ref_t & what ) const in ensure_immutable_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/execution_hint/basic_checks/ |
| H A D | main.cpp | 76 message_ref_t(), in UT_UNIT_TEST()
90 message_ref_t(), in UT_UNIT_TEST()
104 message_ref_t(), in UT_UNIT_TEST()
131 message_ref_t(), in UT_UNIT_TEST()
152 message_ref_t(), in UT_UNIT_TEST()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/enveloped_msg/ |
| H A D | common_stuff.hpp | 39 so_5::message_ref_t m_payload;
51 so_5::message_ref_t payload ) in test_envelope_t()
160 const so_5::message_ref_t & message, in do_deliver_message()
170 so_5::message_ref_t{ std::move(envelope) }, in do_deliver_message()
201 const so_5::message_ref_t & message ) override in do_deliver_message_from_timer()
211 so_5::message_ref_t{ std::move(envelope) } ); in do_deliver_message_from_timer()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/revocable_msg/ |
| H A D | pub.hpp | 81 so_5::message_ref_t m_payload;
117 envelope_t( so_5::message_ref_t payload ) in envelope_t()
306 message_ref_t payload ) in make_envelope_and_deliver()
331 message_ref_t payload{ in send()
358 message_ref_t{} ); in send()
523 message_ref_t{} ); in send()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/enveloped_msg/mchain_handled_count/ |
| H A D | main.cpp | 14 so_5::message_ref_t m_payload;
26 special_wrapper_t( so_5::message_ref_t payload ) in special_wrapper_t()
61 so_5::message_ref_t msg1{ std::make_unique<just_test_msg>(0) }; in run_test()
62 so_5::message_ref_t msg2{ std::make_unique<just_test_msg>(1) }; in run_test()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/enveloped_msg/ |
| H A D | just_envelope.hpp | 84 mutable message_ref_t m_payload;
97 message_ref_t &
123 so_5::message_ref_t payload ) in just_envelope_t()
|
| H A D | send_functions.hpp | 50 message_ref_t m_message;
69 message_ref_t message ) in payload_holder_t()
85 message_ref_t envelope{ in envelope()
260 message_ref_t message{ in make()
|
| H A D | time_limited_delivery.hpp | 65 message_ref_t message, in time_limited_delivery_t()
79 message_ref_t message, in time_limited_delivery_t()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/env_infrastructures/asio/impl/ |
| H A D | common.hpp | 60 const message_ref_t m_msg;
72 const message_ref_t & msg, in singleshot_timer_holder_t()
130 const message_ref_t m_msg;
143 const message_ref_t & msg, in periodic_timer_holder_t()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/impl/ |
| H A D | msg_tracing_helpers.hpp | 386 make_trace_to_1( std::ostream & s, const message_ref_t & message ) in make_trace_to_1()
402 const message_ref_t & message ) in fill_trace_data_1()
558 const message_ref_t &, in deliver_op_tracer() argument
625 const message_ref_t & m_message;
634 const message_ref_t & message, in deliver_op_tracer()
722 const message_ref_t & transformed ) const noexcept override in reaction_transform()
861 const message_ref_t & ) in deliver_op_tracer() argument
893 message_kind_to_string( const message_ref_t & what ) in message_kind_to_string()
966 const message_ref_t & m_message;
989 const message_ref_t & message ) in deliver_op_tracer()
|
| H A D | mchain_details.hpp | 369 const message_ref_t & message, in do_deliver_message()
532 const message_ref_t & message, in push()
596 const message_ref_t & message ) override in do_deliver_message_from_timer()
659 const message_ref_t & message ) in try_to_store_message_to_queue()
765 const message_ref_t & message ) in try_to_store_message_from_timer_to_queue()
883 const message_ref_t & message ) in complete_store_message_to_queue()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/enveloped_msg/simplest/ |
| H A D | main.cpp | 19 so_5::message_ref_t m_payload;
34 so_5::message_ref_t payload ) in test_envelope_t()
74 so_5::message_ref_t msg{ in post_enveloped()
76 so_5::message_ref_t enveloped{ in post_enveloped()
|