Searched refs:message_ref_t (Results 51 – 68 of 68) sorted by relevance
123
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/async_op/ |
| H A D | time_limited.hpp | 358 ::so_5::message_ref_t & /*msg*/ ) in make_default_timeout_handler_if_necessary()
862 ::so_5::message_ref_t & msg ) in completed_on_impl()
941 ::so_5::message_ref_t & msg ) in create_actual_timeout_handler()
|
| H A D | time_unlimited.hpp | 208 ::so_5::message_ref_t & msg ) in add_completion_handler()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/ |
| H A D | message_limit.cpp | 113 const message_ref_t & message ) in transform_reaction()
|
| H A D | mchain.hpp | 156 so_5::message_ref_t m_message_ref;
165 so_5::message_ref_t message_ref ) in demand_t()
544 const message_ref_t & message,
|
| H A D | agent.cpp | 728 message_ref_t(), in so_bind_to_dispatcher()
861 message_ref_t(), in shutdown_agent()
1027 const message_ref_t & msg ) in select_demand_handler_for_message()
1067 const message_ref_t & message ) in push_event()
|
| H A D | mchain_select.hpp | 305 message_ref_t m_message;
312 message_ref_t message ) in send_select_case_t()
443 message_ref_t message, in actual_send_select_case_t()
454 message_ref_t message, in actual_send_select_case_t()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/impl/ |
| H A D | enveloped_msg_details.hpp | 49 const message_ref_t & src_msg ) in message_to_envelope()
|
| H A D | message_limit_internals.hpp | 464 const message_ref_t & what_to_deliver, in try_to_deliver_to_agent()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/sample/so_5_extra/enveloped_msg/delivery_receipt/ |
| H A D | main.cpp | 71 so_5::message_ref_t payload, in custom_envelope_t()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/coop/parent_child_4/ |
| H A D | main.cpp | 39 so_5::message_ref_t original_msg{ std::move(original_msg_uptr) }; in so_define_agent()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/mboxes/ |
| H A D | broadcast.hpp | 163 const message_ref_t & message, in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/custom_mbox_simple/ |
| H A D | main.cpp | 66 const so_5::message_ref_t & message, in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/hanging_subscriptions/ |
| H A D | main.cpp | 37 const so_5::message_ref_t & message_ref, in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/event_handler/external_subscription/ |
| H A D | main.cpp | 63 [this, user_handler]( so_5::message_ref_t & msg ) in add_handler()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/adaptive_subscr_storage/ |
| H A D | main.cpp | 47 const so_5::message_ref_t & message_ref, in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/drop_subscription/ |
| H A D | main.cpp | 47 const so_5::message_ref_t & message_ref, in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/experimental/testing/v1/ |
| H A D | all.cpp | 808 message_ref_t m_message;
980 message_ref_t new_env{ in push()
|
| H A D | all.hpp | 826 message_ref_t msg{ in impact()
|
123