/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/ |
H A D | execution_demand.hpp | 69 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 D | message_limit.cpp | 64 << " 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 D | handler_makers.cpp | 61 if( it != right && it->m_msg_type == key.m_msg_type ) in find_and_use_handler()
|
H A D | mchain.hpp | 154 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 D | environment.cpp | 557 " 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 D | subscr_storage_hash_table_based.cpp | 43 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 D | message_limit_internals.hpp | 44 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 D | subscr_storage_map_based.cpp | 99 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 D | subscr_storage_vector_based.cpp | 116 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 D | delivery_filter_storage.hpp | 50 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 D | msg_tracing_helpers.hpp | 112 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 D | msg_tracing_helpers.cpp | 42 return m_msg_type; in msg_type() 91 m_msg_type = msg_type; in set_msg_type()
|
H A D | subscription_storage_iface.hpp | 88 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 D | ws_msg.h | 146 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 D | SynMessage.h | 71 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 D | send_functions.hpp | 48 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 D | Conn.cpp | 74 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 D | test_websocket_server.h | 87 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 D | ws_client_wspp.cpp | 308 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 D | m_msg.h | 67 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 D | all.hpp | 55 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 D | tls_handshake_io.cpp | 290 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 D | tls_handshake_io.cpp | 290 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 D | tls_handshake_io.cpp | 290 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 D | maint.h | 48 bool m_msg_type; variable
|