Home
last modified time | relevance | path

Searched refs:m_msg_type (Results 1 – 25 of 45) sorted by relevance

12

/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/
H A Dexecution_demand.hpp69 std::type_index m_msg_type; member
80 , m_msg_type( typeid(void) ) in execution_demand_t()
94 , m_msg_type( msg_type ) in execution_demand_t()
215 std::type_index m_msg_type; member
229 : m_msg_type{ typeid(void) } in msg_type_and_handler_pair_t()
241 : m_msg_type{ std::move(msg_type) } in msg_type_and_handler_pair_t()
259 : m_msg_type{ o.m_msg_type } in msg_type_and_handler_pair_t()
266 : m_msg_type{ std::move(o.m_msg_type) } in msg_type_and_handler_pair_t()
277 std::swap( a.m_msg_type, b.m_msg_type ); in swap()
304 return m_msg_type < o.m_msg_type; in operator <()
[all …]
H A Dmessage_limit.cpp64 << " msg_type: " << ctx.m_msg_type.name() in abort_app_reaction()
88 << " msg_type: " << ctx.m_msg_type.name() in redirect_reaction()
101 ctx.m_msg_type, in redirect_reaction()
126 << " original_msg_type: " << ctx.m_msg_type.name() in transform_reaction()
H A Dhandler_makers.cpp61 if( it != right && it->m_msg_type == key.m_msg_type ) in find_and_use_handler()
H A Dmchain.hpp154 std::type_index m_msg_type; member
160 : m_msg_type( typeid(void) ) in demand_t()
166 : m_msg_type{ std::move(msg_type) } in demand_t()
176 swap( a.m_msg_type, b.m_msg_type ); in swap()
1511 extracted_demand.m_msg_type, in handle_next()
H A Denvironment.cpp557 " msg_type=" + std::string(params.m_msg_type.name()) ); in so_schedule_timer()
563 "MPMC mbox, msg_type=" + std::string(params.m_msg_type.name()) ); in so_schedule_timer()
567 params.m_msg_type, in so_schedule_timer()
591 "MPMC mbox, msg_type=" + std::string(params.m_msg_type.name()) ); in so_single_timer()
594 params.m_msg_type, in so_single_timer()
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/impl/
H A Dsubscr_storage_hash_table_based.cpp43 std::type_index m_msg_type; member
50 , m_msg_type( typeid(void) ) in key_t()
60 , m_msg_type( msg_type ) in key_t()
70 , m_msg_type( msg_type ) in key_t()
81 if( m_msg_type < o.m_msg_type ) in operator <()
83 else if( m_msg_type == o.m_msg_type ) in operator <()
94 m_msg_type == o.m_msg_type && in operator ==()
102 m_msg_type == o.m_msg_type; in is_same_mbox_msg_pair()
400 << v.first.m_msg_type.name() << ", " in debug_dump()
418 i.first.m_msg_type, in destroy_all_subscriptions()
[all …]
H A Dmessage_limit_internals.hpp44 std::type_index m_msg_type; member
57 : m_msg_type( std::move( msg_type ) ) in info_block_t()
165 d.m_msg_type, in build_blocks()
196 return blk.m_msg_type == msg_type; in find_block_in_small_container()
219 if( middle->m_msg_type == msg_type ) in find_block_in_large_container()
221 else if( middle->m_msg_type < msg_type ) in find_block_in_large_container()
304 result.emplace( d.m_msg_type, in build_blocks()
339 return a.m_msg_type < b.m_msg_type; in prepare()
346 return a.m_msg_type == b.m_msg_type; in prepare()
351 "msg_type: " ) + duplicate->m_msg_type.name() ); in prepare()
[all …]
H A Dsubscr_storage_map_based.cpp99 std::type_index m_msg_type; member
107 , m_msg_type( std::move( msg_type ) ) in key_t()
118 if( m_msg_type < o.m_msg_type ) in operator <()
120 else if( m_msg_type == o.m_msg_type ) in operator <()
173 return m_id == k.m_mbox_id && m_type == k.m_msg_type; in operator ()()
181 it->first.m_mbox_id, it->first.m_msg_type }; in is_known_mbox_msg_pair()
350 << e.first.m_msg_type.name() << ", " in debug_dump()
367 cur->first.m_msg_type }( it->first ) ) in destroy_all_subscriptions()
370 cur->first.m_msg_type, in destroy_all_subscriptions()
403 e.first.m_msg_type, in query_content()
[all …]
H A Dsubscr_storage_vector_based.cpp116 m_type == info.m_msg_type; in operator ()()
141 o.m_msg_type == msg_type && in find()
265 i.m_msg_type == msg_type; in drop_subscription_for_all_states()
296 << e.m_msg_type.name() << ", " in debug_dump()
313 const type_index * m_msg_type; in destroy_all_subscriptions() member
320 (*m_msg_type) < (*o.m_msg_type) ); in destroy_all_subscriptions()
327 (*m_msg_type) == (*o.m_msg_type); in destroy_all_subscriptions()
339 return mbox_msg_type_pair_t{ i.m_mbox.get(), &i.m_msg_type }; in destroy_all_subscriptions()
350 m.m_mbox->unsubscribe_event_handlers( *m.m_msg_type, *owner() ); in destroy_all_subscriptions()
H A Ddelivery_filter_storage.hpp50 std::type_index m_msg_type; member
57 return a < b || ( a == b && m_msg_type < o.m_msg_type ); in operator <()
77 p.first.m_msg_type, in drop_all()
H A Dmsg_tracing_helpers.hpp112 optional<std::type_index> m_msg_type; member in so_5::impl::msg_tracing_helpers::details::actual_trace_data_t
624 const std::type_index & m_msg_type; member in so_5::impl::msg_tracing_helpers::tracing_enabled_base::deliver_op_tracer
639 , m_msg_type( msg_type ) in deliver_op_tracer()
657 details::original_msg_type{ m_msg_type }, in make_trace()
757 details::original_msg_type{ demand.m_msg_type }, in trace_event_handler_search_result()
780 details::original_msg_type{ demand.m_msg_type }, in trace_deadletter_handler_search_result()
940 details::original_msg_type{ d.m_msg_type }, in trace_extracted_demand()
955 details::original_msg_type{ d.m_msg_type }, in trace_demand_drop_on_close()
965 const std::type_index & m_msg_type; member in so_5::impl::msg_tracing_helpers::mchain_tracing_enabled_base::deliver_op_tracer
979 details::original_msg_type{ m_msg_type }, in make_trace()
[all …]
H A Dmsg_tracing_helpers.cpp42 return m_msg_type; in msg_type()
91 m_msg_type = msg_type; in set_msg_type()
H A Dsubscription_storage_iface.hpp88 std::type_index m_msg_type; member
100 , m_msg_type( std::move( msg_type ) ) in subscr_info_t()
/dports/devel/cpprestsdk/cpprestsdk-2.10.16/Release/include/cpprest/
H A Dws_msg.h146 websocket_message_type m_msg_type; variable
158 m_msg_type = websocket_message_type::ping; in set_message_ping()
164 m_msg_type = websocket_message_type::pong; in set_message_pong()
172 m_msg_type = websocket_message_type::text_message; in set_message()
179 m_msg_type = msg_type; in set_message()
224 websocket_message_type messge_type() const { return m_msg_type; } in messge_type()
230 websocket_message_type message_type() const { return m_msg_type; } in message_type()
242 websocket_message_type m_msg_type; variable
/dports/science/chrono/chrono-7.0.1/src/chrono_synchrono/flatbuffer/message/
H A DSynMessage.h71 SynFlatBuffers::Type GetMessageType() { return m_msg_type; } in GetMessageType()
72 void SetMessageType(SynFlatBuffers::Type msg_type) { m_msg_type = msg_type; } in SetMessageType()
85 m_msg_type(SynFlatBuffers::Type::Type_NONE) {}
90 SynFlatBuffers::Type m_msg_type; ///< Type of message that we contain variable
/dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/enveloped_msg/
H A Dsend_functions.hpp48 std::type_index m_msg_type; member
92 m_data->m_msg_type, in envelope()
112 m_data->m_msg_type, in send_to()
125 m_data->m_msg_type, in send_delayed_to()
152 m_data->m_msg_type, in send_periodic_to()
/dports/devel/libassa/libassa-3.5.1/examples/logserver/server/
H A DConn.cpp74 m_msg_type = m_msg_size = 0; in handle_read()
76 get_stream () >> preamble >> m_msg_type >> m_msg_size; in handle_read()
84 DL((LSVR,"rcvd: Type = %d\n", m_msg_type)); in handle_read()
87 switch (m_msg_type) in handle_read()
/dports/devel/cpprestsdk/cpprestsdk-2.10.16/Release/tests/functional/websockets/utilities/
H A Dtest_websocket_server.h87 test_websocket_message_type msg_type() const { return m_msg_type; } in msg_type()
88 void set_msg_type(test_websocket_message_type type) { m_msg_type = type; } in set_msg_type()
92 test_websocket_message_type m_msg_type; variable
/dports/devel/cpprestsdk/cpprestsdk-2.10.16/Release/src/websockets/client/
H A Dws_client_wspp.cpp308 incoming_msg.m_msg_type = websocket_message_type::binary_message; in connect_impl()
311 incoming_msg.m_msg_type = websocket_message_type::text_message; in connect_impl()
316 … incoming_msg.m_msg_type = static_cast<websocket_message_type>(msg->get_opcode()); in connect_impl()
334 incoming_msg.m_msg_type = websocket_message_type::ping; in connect_impl()
348 incoming_msg.m_msg_type = websocket_message_type::pong; in connect_impl()
460 switch (msg.m_msg_type) in send()
470 if (length == 0 && msg.m_msg_type != websocket_message_type::ping && in send()
471 msg.m_msg_type != websocket_message_type::pong) in send()
715 switch (msg.m_msg_type) in send_msg_impl()
/dports/security/munge/munge-munge-0.5.14/src/libcommon/
H A Dm_msg.h67 enum m_msg_type { /* message type */ enum
117 typedef enum m_msg_type m_msg_type_t;
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/experimental/testing/v1/
H A Dall.hpp55 const std::type_index m_msg_type; member
64 , m_msg_type( msg_type ) in incident_info_t()
146 const std::type_index m_msg_type; member in so_5::experimental::testing::v1::details::trigger_t
239 std::type_index m_msg_type; member
245 : m_msg_type( std::move(msg_type) ) in trigger_source_t()
251 : m_msg_type( std::move(msg_type) ) in trigger_source_t()
1623 src.m_msg_type, in operator &()
/dports/editors/encryptpad/EncryptPad-0.5.0.1/deps/botan/src/lib/tls/
H A Dtls_handshake_io.cpp290 if(m_msg_type == HANDSHAKE_NONE) in add_fragment()
293 m_msg_type = msg_type; in add_fragment()
297 if(msg_type != m_msg_type || msg_length != m_msg_length || epoch != m_epoch) in add_fragment()
336 return (m_msg_type != HANDSHAKE_NONE && m_message.size() == m_msg_length); in complete()
345 return std::make_pair(static_cast<Handshake_Type>(m_msg_type), m_message); in message()
/dports/mail/thunderbird/thunderbird-91.8.0/comm/third_party/botan/src/lib/tls/
H A Dtls_handshake_io.cpp290 if(m_msg_type == HANDSHAKE_NONE) in add_fragment()
293 m_msg_type = msg_type; in add_fragment()
297 if(msg_type != m_msg_type || msg_length != m_msg_length || epoch != m_epoch) in add_fragment()
336 return (m_msg_type != HANDSHAKE_NONE && m_message.size() == m_msg_length); in complete()
345 return std::make_pair(static_cast<Handshake_Type>(m_msg_type), m_message); in message()
/dports/security/botan2/Botan-2.18.2/src/lib/tls/
H A Dtls_handshake_io.cpp290 if(m_msg_type == HANDSHAKE_NONE) in add_fragment()
293 m_msg_type = msg_type; in add_fragment()
297 if(msg_type != m_msg_type || msg_length != m_msg_length || epoch != m_epoch) in add_fragment()
336 return (m_msg_type != HANDSHAKE_NONE && m_message.size() == m_msg_length); in complete()
345 return std::make_pair(static_cast<Handshake_Type>(m_msg_type), m_message); in message()
/dports/devel/gdb/gdb-11.1/gdb/
H A Dmaint.h48 bool m_msg_type; variable

12