Home
last modified time | relevance | path

Searched refs:msg_type (Results 251 – 275 of 4220) sorted by relevance

1...<<11121314151617181920>>...169

/dports/comms/rtl-433/rtl_433-21.12/src/devices/
H A Dlacrossews.c97 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 DUTMetaData.java43 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 Dcloudbuild_util.py235 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 Dbsp.cpp148 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 Dbsp.cpp148 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 Dpresentation_controller_unittest.cc117 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 Dpresentation_controller_unittest.cc116 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 Dmessages_util.c27 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 Dissue-88331.rs10 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 Dagent.cpp891 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 DPacket.pm289 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 Dround_robin.hpp271 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 Dlogstash_mod.py201 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 Dmessaging.py43 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 Dfsck.h78 #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 Dfsck.h78 #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 Dfsck.h78 #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 Dfsck.h78 #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 Dfsck.h78 #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 Dthread_pool.h29 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 Dlsendcommand.cpp60 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 Dexception.c10 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 Diwpm_msg.c413 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 Diwpm_msg.c413 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 Diwpm_msg.c413 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 …]

1...<<11121314151617181920>>...169