| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/mboxes/ |
| H A D | retained_msg.hpp | 414 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
420 msg_type, message, overlimit_reaction_deep }; in do_deliver_message()
428 overlimit_reaction_deep ); in do_deliver_message()
542 unsigned int overlimit_reaction_deep ) in do_deliver_message_impl() argument
562 overlimit_reaction_deep ); in do_deliver_message_impl()
574 unsigned int overlimit_reaction_deep ) const in do_deliver_message_to_subscriber()
591 overlimit_reaction_deep, in do_deliver_message_to_subscriber()
623 const unsigned int overlimit_reaction_deep = 0; in try_deliver_retained_message_to() local
631 overlimit_reaction_deep }; in try_deliver_retained_message_to()
639 overlimit_reaction_deep ); in try_deliver_retained_message_to()
|
| H A D | round_robin.hpp | 273 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
279 msg_type, message, overlimit_reaction_deep }; in do_deliver_message()
285 overlimit_reaction_deep ); in do_deliver_message()
319 unsigned int overlimit_reaction_deep ) in do_deliver_message_impl() argument
334 overlimit_reaction_deep ); in do_deliver_message_impl()
346 unsigned int overlimit_reaction_deep ) in do_deliver_message_to_subscriber() argument
356 overlimit_reaction_deep, in do_deliver_message_to_subscriber()
|
| H A D | proxy.hpp | 237 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
242 overlimit_reaction_deep ); in do_deliver_message()
|
| H A D | broadcast.hpp | 164 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
172 m->do_deliver_message( msg_type, message, overlimit_reaction_deep ); in do_deliver_message()
|
| H A D | collecting_mbox.hpp | 689 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
697 msg_type, message, overlimit_reaction_deep }; in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/impl/ |
| H A D | mpsc_mbox.hpp | 123 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
129 msg_type, message, overlimit_reaction_deep }; in do_deliver_message()
142 overlimit_reaction_deep, in do_deliver_message()
337 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
343 msg_type, message, overlimit_reaction_deep }; in do_deliver_message()
356 overlimit_reaction_deep, in do_deliver_message()
|
| H A D | named_local_mbox.cpp | 74 unsigned int overlimit_reaction_deep ) in do_deliver_message() argument
76 m_mbox->do_deliver_message( msg_type, message, overlimit_reaction_deep ); in do_deliver_message()
|
| H A D | local_mbox.hpp | 818 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
824 msg_type, message, overlimit_reaction_deep }; in do_deliver_message()
832 overlimit_reaction_deep ); in do_deliver_message()
946 unsigned int overlimit_reaction_deep ) in do_deliver_message_impl() argument
959 overlimit_reaction_deep ); in do_deliver_message_impl()
971 unsigned int overlimit_reaction_deep ) const in do_deliver_message_to_subscriber()
990 overlimit_reaction_deep, in do_deliver_message_to_subscriber()
|
| H A D | named_local_mbox.hpp | 74 unsigned int overlimit_reaction_deep ) override;
|
| H A D | message_limit_internals.hpp | 466 unsigned int overlimit_reaction_deep, in try_to_deliver_to_agent() argument
481 overlimit_reaction_deep, in try_to_deliver_to_agent()
|
| H A D | msg_tracing_helpers.hpp | 635 const unsigned int overlimit_reaction_deep ) in deliver_op_tracer() argument
641 , m_overlimit_deep( overlimit_reaction_deep ) in deliver_op_tracer()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/custom_mbox_simple/ |
| H A D | main.cpp | 67 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
70 msg_type, message, overlimit_reaction_deep ); 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 | 38 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
41 type_index, message_ref, overlimit_reaction_deep ); in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/enveloped_msg/ |
| H A D | common_stuff.hpp | 161 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
171 overlimit_reaction_deep ); in do_deliver_message()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/shutdowner/ |
| H A D | shutdowner.hpp | 613 constexpr unsigned int overlimit_reaction_deep = 0u; in send_shutdown_initated_to_all() local
619 msg_type, message, overlimit_reaction_deep }; in send_shutdown_initated_to_all()
631 overlimit_reaction_deep, in send_shutdown_initated_to_all()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/adaptive_subscr_storage/ |
| H A D | main.cpp | 48 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
51 type_index, message_ref, overlimit_reaction_deep ); 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 | 48 unsigned int overlimit_reaction_deep ) override in do_deliver_message() argument
51 type_index, message_ref, overlimit_reaction_deep ); in do_deliver_message()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/ |
| H A D | mbox.hpp | 233 unsigned int overlimit_reaction_deep ) = 0;
|