/dports/comms/rtl-433/rtl_433-21.12/src/devices/ |
H A D | lacrossews.c | 97 uint8_t ws_id, msg_type, sensor_id; in lacrossews_callback() local 109 msg_type = ((msg_nybbles[2] >> 1) & 0x4) + (msg_nybbles[2] & 0x3); in lacrossews_callback() 118 switch (msg_type) { in lacrossews_callback() 181 ws_id, sensor_id, msg_type == 3 ? "Wind" : "Gust"); in lacrossews_callback() 190 …"wind_avg_m_s", "Wind speed", DATA_COND, msg_type == 3, DATA_FORMAT, "%3.1f m/s", DATA_DOU… in lacrossews_callback() 191 …"wind_max_m_s", "Gust speed", DATA_COND, msg_type != 3, DATA_FORMAT, "%3.1f m/s", DATA_DOU… in lacrossews_callback() 203 ws_id, sensor_id, msg_type, msg_value_bcd, msg_value_bin); in lacrossews_callback()
|
/dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/peermanager/messaging/bittorrent/ltep/ |
H A D | UTMetaData.java | 43 private int msg_type; field in UTMetaData 53 msg_type = MSG_TYPE_REQUEST; in UTMetaData() 65 msg_type = _data==null?MSG_TYPE_REJECT:MSG_TYPE_DATA; in UTMetaData() 84 msg_type = ((Long)map.get( "msg_type" )).intValue(); in UTMetaData() 137 return( msg_type ); in getMessageType() 166 payload_map.put( "msg_type", new Long( msg_type )); in getData() 177 if ( msg_type == MSG_TYPE_DATA ){ in getData()
|
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/api_lib/cloudbuild/ |
H A D | cloudbuild_util.py | 235 def _UnpackCheckUnused(obj, msg_type): argument 248 msg = apitools_encoding.DictToMessage(obj, msg_type) 283 msg_type, argument 316 return _YamlToMessage(structured_data, msg_type, msg_friendly_name, 321 msg_type, argument 359 msg_type, argument 387 msg = _UnpackCheckUnused(structured_data, msg_type) 398 msg_type, argument 421 return LoadMessageFromStream(f, msg_type, msg_friendly_name, 426 msg_type, argument [all …]
|
/dports/science/py-dlib/dlib-19.22/dlib/bsp/ |
H A D | bsp.cpp | 148 deserialize(msg.msg_type, con->stream); in read_thread() 151 if (msg.msg_type == MESSAGE_HEADER) in read_thread() 160 if (msg.msg_type == NODE_TERMINATE) in read_thread() 176 msg.msg_type = READ_ERROR; in read_thread() 191 msg.msg_type = READ_ERROR; in read_thread() 236 if (msg.msg_type == impl2::NODE_TERMINATE) in close_all_connections_gracefully() 241 else if (msg.msg_type == impl2::READ_ERROR) in close_all_connections_gracefully() 245 else if (msg.msg_type == impl2::MESSAGE_HEADER) in close_all_connections_gracefully() 249 else if (msg.msg_type == impl2::GOT_MESSAGE) in close_all_connections_gracefully() 254 else if (msg.msg_type == impl2::SENT_MESSAGE) in close_all_connections_gracefully() [all …]
|
/dports/science/dlib-cpp/dlib-19.22/dlib/bsp/ |
H A D | bsp.cpp | 148 deserialize(msg.msg_type, con->stream); in read_thread() 151 if (msg.msg_type == MESSAGE_HEADER) in read_thread() 160 if (msg.msg_type == NODE_TERMINATE) in read_thread() 176 msg.msg_type = READ_ERROR; in read_thread() 191 msg.msg_type = READ_ERROR; in read_thread() 236 if (msg.msg_type == impl2::NODE_TERMINATE) in close_all_connections_gracefully() 241 else if (msg.msg_type == impl2::READ_ERROR) in close_all_connections_gracefully() 245 else if (msg.msg_type == impl2::MESSAGE_HEADER) in close_all_connections_gracefully() 249 else if (msg.msg_type == impl2::GOT_MESSAGE) in close_all_connections_gracefully() 254 else if (msg.msg_type == impl2::SENT_MESSAGE) in close_all_connections_gracefully() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/osp/impl/presentation/ |
H A D | presentation_controller_unittest.cc | 117 msgs::Type msg_type; in ExpectAvailabilityRequest() local 123 msg_type = message_type; in ExpectAvailabilityRequest() 205 msgs::Type msg_type; in ExpectCloseRequest() local 211 msg_type = message_type; in ExpectCloseRequest() 262 msgs::Type msg_type; in StartPresentation() local 264 .WillOnce(Invoke([&request, &msg_type]( in StartPresentation() 268 msg_type = message_type; in StartPresentation() 410 msgs::Type msg_type; in TEST_F() local 416 msg_type = message_type; in TEST_F() 501 msgs::Type msg_type; in TEST_F() local [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/osp/impl/presentation/ |
H A D | presentation_controller_unittest.cc | 116 msgs::Type msg_type; in ExpectAvailabilityRequest() local 122 msg_type = message_type; in ExpectAvailabilityRequest() 204 msgs::Type msg_type; in ExpectCloseRequest() local 210 msg_type = message_type; in ExpectCloseRequest() 261 msgs::Type msg_type; in StartPresentation() local 263 .WillOnce(Invoke([&request, &msg_type]( in StartPresentation() 267 msg_type = message_type; in StartPresentation() 409 msgs::Type msg_type; in TEST_F() local 415 msg_type = message_type; in TEST_F() 500 msgs::Type msg_type; in TEST_F() local [all …]
|
/dports/net/samba412/samba-4.12.15/source3/lib/ |
H A D | messages_util.c | 27 void message_hdr_put(uint8_t buf[MESSAGE_HDR_LENGTH], uint32_t msg_type, in message_hdr_put() argument 32 SIVAL(buf, 2 * SERVER_ID_BUF_LENGTH, msg_type); in message_hdr_put() 35 void message_hdr_get(uint32_t *msg_type, struct server_id *src, in message_hdr_get() argument 41 *msg_type = IVAL(buf, 2 * SERVER_ID_BUF_LENGTH); in message_hdr_get()
|
/dports/lang/rust/rustc-1.58.1-src/src/test/ui/closures/2229_closure_analysis/match/ |
H A D | issue-88331.rs | 10 pub fn example1(msg_type: Opcode) -> impl FnMut(&[u8]) { in example1() 11 move |i| match msg_type { in example1() 25 pub fn example2(msg_type: Opcode2) -> impl FnMut(&[u8]) { in example2() 27 move |i| match msg_type { in example2()
|
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/ |
H A D | agent.cpp | 891 std::type_index msg_type, in so_create_event_subscription() argument 905 msg_type, in so_create_event_subscription() 916 const std::type_index & msg_type, in so_create_deadletter_subscription() argument 924 msg_type, in so_create_deadletter_subscription() 960 msg_type.name() ); in detect_limit_for_message_type() 969 const std::type_index & msg_type, in do_drop_subscription() argument 999 const std::type_index & msg_type, in do_check_subscription_presence() argument 1066 std::type_index msg_type, in push_event() argument 1079 msg_type, in push_event() 1305 const std::type_index & msg_type, in do_set_delivery_filter() argument [all …]
|
/dports/dns/p5-Net-RNDC/Net-RNDC-0.003/lib/Net/RNDC/ |
H A D | Packet.pm | 289 my $msg_type = pack('c', ISCCC_CCMSGTYPE_TABLE); 290 return $msg_type . pack('N', length($table)) . $table; 310 my $msg_type = pack('c', ISCCC_CCMSGTYPE_LIST); 317 return $msg_type . pack('N', length($list)) . $list; 326 my $msg_type = unpack('c', $$wire); 336 if ($msg_type == ISCCC_CCMSGTYPE_BINARYDATA) { 338 } elsif ($msg_type == ISCCC_CCMSGTYPE_TABLE) { 340 } elsif ($msg_type == ISCCC_CCMSGTYPE_LIST) { 344 "Unknown message type '$msg_type' in _value_fromwire"
|
/dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/mboxes/ |
H A D | round_robin.hpp | 271 const std::type_index & msg_type, in do_deliver_message() argument 279 msg_type, message, overlimit_reaction_deep }; in do_deliver_message() 283 msg_type, in do_deliver_message() 317 const std::type_index & msg_type, in do_deliver_message_impl() argument 323 auto it = this->m_subscribers.find( msg_type ); in do_deliver_message_impl() 332 msg_type, in do_deliver_message_impl() 344 const std::type_index & msg_type, in do_deliver_message_to_subscriber() argument 354 msg_type, in do_deliver_message_to_subscriber() 365 msg_type, in do_deliver_message_to_subscriber()
|
/dports/sysutils/py-salt/salt-3004.1/salt/log/handlers/ |
H A D | logstash_mod.py | 201 msg_type = __opts__["logstash_udp_handler"].get("msg_type", "logstash") 210 logstash_formatter = LogstashFormatter(msg_type=msg_type, version=version) 265 def __init__(self, msg_type="logstash", msg_path="logstash", version=0): argument 267 self.msg_type = msg_type 290 "@source": "{}://{}/{}".format(self.msg_type, host, self.msg_path), 294 "@type": self.msg_type, 356 "type": self.msg_type,
|
/dports/net/samba412/samba-4.12.15/python/samba/tests/ |
H A D | messaging.py | 43 msg_type = x.register((callback, None)) 44 self.assertTrue(isinstance(msg_type, integer_types)) 45 x.deregister(callback, msg_type) 87 def ping_callback(got_ping, msg_type, src, data): argument 93 def pong_callback(got_pong, msg_type, src, data): argument 129 def ping_callback(got_ping, msg_type, src, data): argument 135 def pong_callback(got_pong, msg_type, src, data): argument
|
/dports/devel/git-svn/git-2.34.1/ |
H A D | fsck.h | 78 #define MSG_ID(id, msg_type) FSCK_MSG_##id, argument 90 enum fsck_msg_type msg_type); 92 const char *msg_id, const char *msg_type); 94 int is_valid_msg_type(const char *msg_id, const char *msg_type); 110 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 115 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 120 enum fsck_msg_type msg_type, 128 enum fsck_msg_type *msg_type; member
|
/dports/devel/git-gui/git-2.34.1/ |
H A D | fsck.h | 78 #define MSG_ID(id, msg_type) FSCK_MSG_##id, argument 90 enum fsck_msg_type msg_type); 92 const char *msg_id, const char *msg_type); 94 int is_valid_msg_type(const char *msg_id, const char *msg_type); 110 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 115 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 120 enum fsck_msg_type msg_type, 128 enum fsck_msg_type *msg_type; member
|
/dports/devel/git-p4/git-2.34.1/ |
H A D | fsck.h | 78 #define MSG_ID(id, msg_type) FSCK_MSG_##id, argument 90 enum fsck_msg_type msg_type); 92 const char *msg_id, const char *msg_type); 94 int is_valid_msg_type(const char *msg_id, const char *msg_type); 110 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 115 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 120 enum fsck_msg_type msg_type, 128 enum fsck_msg_type *msg_type; member
|
/dports/devel/git/git-2.34.1/ |
H A D | fsck.h | 78 #define MSG_ID(id, msg_type) FSCK_MSG_##id, argument 90 enum fsck_msg_type msg_type); 92 const char *msg_id, const char *msg_type); 94 int is_valid_msg_type(const char *msg_id, const char *msg_type); 110 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 115 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 120 enum fsck_msg_type msg_type, 128 enum fsck_msg_type *msg_type; member
|
/dports/devel/git-cvs/git-2.34.1/ |
H A D | fsck.h | 78 #define MSG_ID(id, msg_type) FSCK_MSG_##id, argument 90 enum fsck_msg_type msg_type); 92 const char *msg_id, const char *msg_type); 94 int is_valid_msg_type(const char *msg_id, const char *msg_type); 110 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 115 enum fsck_msg_type msg_type, enum fsck_msg_id msg_id, 120 enum fsck_msg_type msg_type, 128 enum fsck_msg_type *msg_type; member
|
/dports/games/nxengine/nxengine-evo-2.6.5-1/deps/spdlog/details/ |
H A D | thread_pool.h | 29 async_msg_type msg_type; member 47 async_msg(async_msg &&other) SPDLOG_NOEXCEPT : msg_type(other.msg_type), in async_msg() 60 msg_type = other.msg_type; 77 : msg_type(the_type) in async_msg() 89 : msg_type(the_type) in async_msg() 213 switch (incoming_async_msg.msg_type) in process_next_msg_()
|
/dports/sysutils/lineakd/lineakd-0.9/utils/ |
H A D | lsendcommand.cpp | 60 msg.msg_type = msgPasser::GETDATA; in main() 73 msg.msg_type = msgPasser::SEND_KEY; in main() 109 msg.msg_type = msgPasser::COMMAND; in main() 124 msg.msg_type = msgPasser::GETDATA; in main() 127 msg.msg_type = msgPasser::SENDDATA; in main()
|
/dports/graphics/netpbm/netpbm-10.91.01/converter/other/pamtosvg/ |
H A D | exception.c | 10 e.msg_type = 0; in at_exception_new() 22 return (exception->msg_type == AT_MSG_FATAL); in at_exception_got_fatal() 32 exception->msg_type = AT_MSG_FATAL; in at_exception_fatal() 48 exception->msg_type = AT_MSG_WARNING; in at_exception_warning()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/core/ |
H A D | iwpm_msg.c | 413 resp_reg_policy, nltb, msg_type)) in iwpm_register_pid_cb() 481 const char *msg_type; in iwpm_add_mapping_cb() local 484 msg_type = "Add Mapping response"; in iwpm_add_mapping_cb() 486 resp_add_policy, nltb, msg_type)) in iwpm_add_mapping_cb() 560 const char *msg_type; in iwpm_add_and_query_mapping_cb() local 564 msg_type = "Query Mapping response"; in iwpm_add_and_query_mapping_cb() 566 resp_query_policy, nltb, msg_type)) in iwpm_add_and_query_mapping_cb() 642 const char *msg_type; in iwpm_remote_info_cb() local 646 msg_type = "Remote Mapping info"; in iwpm_remote_info_cb() 813 map_error_policy, nltb, msg_type)) in iwpm_mapping_error_cb() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/core/ |
H A D | iwpm_msg.c | 413 resp_reg_policy, nltb, msg_type)) in iwpm_register_pid_cb() 481 const char *msg_type; in iwpm_add_mapping_cb() local 484 msg_type = "Add Mapping response"; in iwpm_add_mapping_cb() 486 resp_add_policy, nltb, msg_type)) in iwpm_add_mapping_cb() 560 const char *msg_type; in iwpm_add_and_query_mapping_cb() local 564 msg_type = "Query Mapping response"; in iwpm_add_and_query_mapping_cb() 566 resp_query_policy, nltb, msg_type)) in iwpm_add_and_query_mapping_cb() 642 const char *msg_type; in iwpm_remote_info_cb() local 646 msg_type = "Remote Mapping info"; in iwpm_remote_info_cb() 813 map_error_policy, nltb, msg_type)) in iwpm_mapping_error_cb() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/core/ |
H A D | iwpm_msg.c | 413 resp_reg_policy, nltb, msg_type)) in iwpm_register_pid_cb() 481 const char *msg_type; in iwpm_add_mapping_cb() local 484 msg_type = "Add Mapping response"; in iwpm_add_mapping_cb() 486 resp_add_policy, nltb, msg_type)) in iwpm_add_mapping_cb() 560 const char *msg_type; in iwpm_add_and_query_mapping_cb() local 564 msg_type = "Query Mapping response"; in iwpm_add_and_query_mapping_cb() 566 resp_query_policy, nltb, msg_type)) in iwpm_add_and_query_mapping_cb() 642 const char *msg_type; in iwpm_remote_info_cb() local 646 msg_type = "Remote Mapping info"; in iwpm_remote_info_cb() 813 map_error_policy, nltb, msg_type)) in iwpm_mapping_error_cb() [all …]
|