/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/mqtt/ |
H A D | Makefile.am | 23 modules/mqtt/mqtt-plugins.c \ 24 modules/mqtt/mqtt-grammar.y \ 25 modules/mqtt/mqtt-options.c \ 26 modules/mqtt/mqtt-options.h \ 27 modules/mqtt/mqtt-parser.c \ 28 modules/mqtt/mqtt-parser.h 34 modules/mqtt modules/mqtt/ mod-mqtt: modules/mqtt/libmqtt.la 38 modules/mqtt/mqtt-grammar.y \ 39 modules/mqtt/mqtt-grammar.c \ 40 modules/mqtt/mqtt-grammar.h [all …]
|
/dports/security/suricata/suricata-6.0.4/doc/userguide/rules/ |
H A D | mqtt-keywords.rst | 22 mqtt.type 53 mqtt.flags 69 mqtt.qos 93 mqtt.type:UNSUBACK; mqtt.reason_code:17; 96 mqtt.type:PUBACK; mqtt.reason_code:16; 99 mqtt.CONNACK; mqtt.reason_code:138; 102 mqtt.CONNACK; mqtt.reason_code:134; 105 mqtt.DISCONNECT; mqtt.reason_code:139; 117 mqtt.CONNACK; mqtt.connack.session_present:true; 259 * MQTT 3.1.1: `<https://docs.oasis-open.org/mqtt/mqtt/v3.1.1/mqtt-v3.1.1.html>`_ [all …]
|
/dports/net-im/purple-facebook/purple-facebook-0.9.6/pidgin/libpurple/protocols/facebook/ |
H A D | mqtt.c | 74 fb_mqtt_close(mqtt); in fb_mqtt_dispose() 161 mqtt->priv = priv; in fb_mqtt_init() 223 FbMqtt *mqtt; in fb_mqtt_new() local 229 priv = mqtt->priv; in fb_mqtt_new() 232 return mqtt; in fb_mqtt_new() 241 priv = mqtt->priv; in fb_mqtt_close() 440 priv = mqtt->priv; in fb_mqtt_read() 563 priv = mqtt->priv; in fb_mqtt_write() 627 priv = mqtt->priv; in fb_mqtt_open() 673 priv = mqtt->priv; in fb_mqtt_connected() [all …]
|
/dports/irc/bitlbee-facebook/bitlbee-facebook-1.2.2/facebook/ |
H A D | facebook-mqtt.c | 63 fb_mqtt_close(mqtt); in fb_mqtt_dispose() 149 mqtt->priv = priv; in fb_mqtt_init() 218 priv = mqtt->priv; in fb_mqtt_close() 268 FbMqtt *mqtt = data; in fb_mqtt_cb_timeout() local 418 priv = mqtt->priv; in fb_mqtt_read() 543 priv = mqtt->priv; in fb_mqtt_write() 594 priv = mqtt->priv; in fb_mqtt_open() 638 priv = mqtt->priv; in fb_mqtt_connected() 671 priv = mqtt->priv; in fb_mqtt_publish() 699 priv = mqtt->priv; in fb_mqtt_subscribe() [all …]
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_mqtt/priv/schema/ |
H A D | rabbitmq_mqtt.schema | 4 %% See https://github.com/rabbitmq/rabbitmq-mqtt/blob/stable/README.md 18 {mapping, "mqtt.default_user", "rabbitmq_mqtt.default_user", [ 22 {mapping, "mqtt.default_pass", "rabbitmq_mqtt.default_pass", [ 28 list_to_binary(cuttlefish:conf_get("mqtt.default_user", Conf)) 33 list_to_binary(cuttlefish:conf_get("mqtt.default_pass", Conf)) 54 list_to_binary(cuttlefish:conf_get("mqtt.vhost", Conf)) 65 list_to_binary(cuttlefish:conf_get("mqtt.exchange", Conf)) 88 {mapping, "mqtt.prefetch", "rabbitmq_mqtt.prefetch", 95 {mapping, "mqtt.sparkplug", "rabbitmq_mqtt.sparkplug", 116 {mapping, "mqtt.listeners.tcp", "rabbitmq_mqtt.tcp_listeners",[ [all …]
|
/dports/comms/rtl-433/rtl_433-21.12/src/ |
H A D | output_mqtt.c | 355 expand_topic(mqtt->topic, mqtt->states, data, mqtt->hostname); in print_mqtt_data() 367 expand_topic(mqtt->topic, mqtt->events, data, mqtt->hostname); in print_mqtt_data() 368 mqtt_client_publish(mqtt->mqc, mqtt->topic, message); in print_mqtt_data() 377 end = expand_topic(mqtt->topic, mqtt->devices, data, mqtt->hostname); in print_mqtt_data() 402 mqtt_client_publish(mqtt->mqc, mqtt->topic, str); in print_mqtt_string() 435 if (!mqtt) in data_output_mqtt_free() 446 free(mqtt); in data_output_mqtt_free() 473 if (!mqtt) in data_output_mqtt_create() 476 gethostname(mqtt->hostname, sizeof(mqtt->hostname) - 1); in data_output_mqtt_create() 477 mqtt->hostname[sizeof(mqtt->hostname) - 1] = '\0'; in data_output_mqtt_create() [all …]
|
/dports/net-im/purple-facebook/purple-facebook-0.9.6/patches/ |
H A D | 04-revert-gio.patch | 26 #include "mqtt.h" 61 fb_mqtt_close(mqtt); 68 mqtt->priv = priv; 96 priv = mqtt->priv; 166 - FbMqtt *mqtt = data; 190 FbMqtt *mqtt = data; 228 - priv = mqtt->priv; 345 FbMqtt *mqtt = data; 426 - priv = mqtt->priv; 462 priv = mqtt->priv; [all …]
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/mqtt/destination/ |
H A D | Makefile.am | 2 noinst_LTLIBRARIES += modules/mqtt/destination/libmqtt_destination.la 4 modules/mqtt/destination/mqtt-worker.h \ 5 modules/mqtt/destination/mqtt-worker.c \ 6 modules/mqtt/destination/mqtt-destination.h \ 7 modules/mqtt/destination/mqtt-destination.c 12 -I$(top_srcdir)/modules/mqtt/destination/ \ 13 -I$(top_builddir)/modules/mqtt/destination/ \ 14 -I$(top_srcdir)/modules/mqtt/ \ 15 -I$(top_builddir)/modules/mqtt/ 23 modules/mqtt/destination/CMakeLists.txt
|
/dports/net/libwebsockets/libwebsockets-v4.2.2/lib/secure-streams/protocols/ |
H A D | ss-mqtt.c | 54 if (h->u.mqtt.heap_baggage) { in secstream_mqtt() 56 h->u.mqtt.heap_baggage = NULL; in secstream_mqtt() 83 if (h->u.mqtt.heap_baggage) { in secstream_mqtt() 127 if (h->policy->u.mqtt.topic) in secstream_mqtt() 242 h->u.mqtt.sub_top.qos = h->policy->u.mqtt.qos; in secstream_mqtt() 243 memset(&h->u.mqtt.sub_info, 0, sizeof(h->u.mqtt.sub_info)); in secstream_mqtt() 245 h->u.mqtt.sub_info.topic = &h->u.mqtt.sub_top; in secstream_mqtt() 373 h->policy->u.mqtt.topic in secstream_connect_munge_mqtt() 445 h->u.mqtt.topic_qos.qos = h->policy->u.mqtt.qos; in secstream_connect_munge_mqtt() 481 if (!h->u.mqtt.heap_baggage) in secstream_connect_munge_mqtt() [all …]
|
/dports/lang/sagittarius-scheme/sagittarius-0.9.8/doc/utils/net/ |
H A D | mqtt.scrbl | 3 @subsection[:tag "net.mqtt"]{(net mq mqtt) - MQTT library} 5 @define[Library]{@name{(net mq mqtt)}} 8 Reference @hyperlink[:href "http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/mqtt-v3.1.1.html"]{OASIS MQ… 14 (import (rnrs) (net mq mqtt)) 30 (mqtt-unsubscribe conn "topic") 31 (close-mqtt-connection! conn)) 35 (import (rnrs) (net mq mqtt)) 40 (close-mqtt-connection! conn)) 67 @define[Constant]{+mqtt-3.1+} 68 @define[Constant]{+mqtt-3.1.1+} [all …]
|
/dports/sysutils/monit/monit-5.29.0/src/protocols/ |
H A D | mqtt.c | 246 if (mqtt->port->parameters.mqtt.username) { in _connectRequest() 247 … _payload(&connect, mqtt->port->parameters.mqtt.username, MQTT_ConnectRequest_Username); in _connectRequest() 251 if (mqtt->port->parameters.mqtt.password) { in _connectRequest() 252 … _payload(&connect, mqtt->port->parameters.mqtt.password, MQTT_ConnectRequest_Password); in _connectRequest() 260 mqtt->state = MQTT_ConnectSent; in _connectRequest() 278 mqtt->state = MQTT_Connected; in _connectResponse() 282 static void _disconnect(mqtt_t *mqtt) { in _disconnect() argument 293 mqtt->state = MQTT_Init; in _disconnect() 308 _connectRequest(&mqtt); in check_mqtt() 309 _connectResponse(&mqtt); in check_mqtt() [all …]
|
/dports/benchmarks/tsung/tsung-1.7.0/src/lib/ |
H A D | mqtt_frame.erl | 39 encode(#mqtt{} = Message) -> 155 Message#mqtt{ 177 Message#mqtt{ 183 Message#mqtt{ 194 Message#mqtt{ 199 Message#mqtt{ 211 Message#mqtt{ 216 Message#mqtt{ 222 Message#mqtt{ 298 Message#mqtt.qos > 0 -> [all …]
|
/dports/net/kamailio/kamailio-5.4.5/src/modules/mqtt/ |
H A D | README | 118 5.3. mqtt:message 259 the values are: 'mqtt:connected', 'mqtt:disconnected', 'mqtt:message'. 434 5.1. mqtt:connected 436 5.3. mqtt:message 438 5.1. mqtt:connected 452 5.2. mqtt:disconnected 465 5.3. mqtt:message 473 xlog("mqtt message received: $mqtt(topic) -> $mqtt(msg) !\n"); 479 * $mqtt(topic) - Received topic (only in mqtt:message) 480 * $mqtt(msg) - Received message (only in mqtt:message) [all …]
|
/dports/audio/baresip/baresip-0.5.8/modules/mqtt/ |
H A D | mqtt.c | 16 static struct mqtt s_mqtt; 21 struct mqtt *mqtt = arg; in fd_handler() local 23 mosquitto_loop_read(mqtt->mosq, 1); in fd_handler() 25 mosquitto_loop_write(mqtt->mosq, 1); in fd_handler() 32 struct mqtt *mqtt = data; in tmr_handler() local 35 tmr_start(&mqtt->tmr, 500, tmr_handler, mqtt); in tmr_handler() 37 ret = mosquitto_loop_misc(mqtt->mosq); in tmr_handler() 50 struct mqtt *mqtt = obj; in connect_callback() local 52 (void)mqtt; in connect_callback() 63 err = mqtt_subscribe_start(mqtt); in connect_callback() [all …]
|
H A D | mqtt.h | 3 struct mqtt { struct 14 int mqtt_subscribe_init(struct mqtt *mqtt); argument 15 int mqtt_subscribe_start(struct mqtt *mqtt); 23 int mqtt_publish_init(struct mqtt *mqtt); 25 int mqtt_publish_message(struct mqtt *mqtt, const char *topic,
|
H A D | subscribe.c | 24 static void handle_command(struct mqtt *mqtt, const struct pl *msg) in handle_command() argument 75 err = mqtt_publish_message(mqtt, resp_topic, in handle_command() 95 struct mqtt *mqtt = obj; in message_callback() local 111 handle_command(mqtt, &msg); in message_callback() 116 int mqtt_subscribe_init(struct mqtt *mqtt) in mqtt_subscribe_init() argument 118 if (!mqtt) in mqtt_subscribe_init() 121 mosquitto_message_callback_set(mqtt->mosq, message_callback); in mqtt_subscribe_init() 127 int mqtt_subscribe_start(struct mqtt *mqtt) in mqtt_subscribe_start() argument 131 ret = mosquitto_subscribe(mqtt->mosq, NULL, subscription_pattern, 0); in mqtt_subscribe_start()
|
H A D | publish.c | 27 struct mqtt *mqtt = arg; in ua_event_handler() local 39 err = mqtt_publish_message(mqtt, "/baresip/event", "%H", in ua_event_handler() 51 int mqtt_publish_message(struct mqtt *mqtt, const char *topic, in mqtt_publish_message() argument 59 if (!mqtt || !topic || !fmt) in mqtt_publish_message() 69 ret = mosquitto_publish(mqtt->mosq, in mqtt_publish_message() 89 int mqtt_publish_init(struct mqtt *mqtt) in mqtt_publish_init() argument 93 err = uag_event_register(ua_event_handler, mqtt); in mqtt_publish_init()
|
/dports/net/p5-Net-MQTT/Net-MQTT-1.143260/t/ |
H A D | 01-message.t | 13 my $mqtt = Net::MQTT::Message->new(message_type => 15, 15 ok($mqtt, 'unknown long message'); 16 is($mqtt->string(' '), 23 is((unpack 'H*', $mqtt->bytes), 43 $mqtt = Net::MQTT::Message->new_from_bytes($bytes, 1); 44 ok($mqtt, 'new_from_bytes w/splice'); 46 is($mqtt->string, 52 is((unpack 'H*', $mqtt->bytes), q{008101}.('58'x129), '... bytes'); 54 $mqtt = Net::MQTT::Message->new(message_type => 1); 55 ok($mqtt, 'new - connect message'); [all …]
|
/dports/net/savvycan/SavvyCAN-1.0.245/ |
H A D | SavvyCAN.pro | 24 mqtt/qmqtt_client.cpp \ 25 mqtt/qmqtt_client_p.cpp \ 26 mqtt/qmqtt_frame.cpp \ 27 mqtt/qmqtt_message.cpp \ 28 mqtt/qmqtt_network.cpp \ 29 mqtt/qmqtt_router.cpp \ 31 mqtt/qmqtt_socket.cpp \ 33 mqtt/qmqtt_timer.cpp \ 101 mqtt/qmqtt.h \ 102 mqtt/qmqtt_client.h \ [all …]
|
/dports/security/suricata/suricata-6.0.4/rules/ |
H A D | mqtt-events.rules | 7 alert mqtt any any -> any any (msg:"SURICATA MQTT CONNECT not seen before CONNACK"; app-layer-event… 8 alert mqtt any any -> any any (msg:"SURICATA MQTT PUBLISH not seen before PUBACK/PUBREL/PUBREC/PUBC… 9 alert mqtt any any -> any any (msg:"SURICATA MQTT SUBSCRIBE not seen before SUBACK"; app-layer-even… 10 alert mqtt any any -> any any (msg:"SURICATA MQTT UNSUBSCRIBE not seen before UNSUBACK"; app-layer-… 11 alert mqtt any any -> any any (msg:"SURICATA MQTT duplicate CONNECT"; app-layer-event:mqtt.double_c… 12 alert mqtt any any -> any any (msg:"SURICATA MQTT message seen before CONNECT/CONNACK completion"; … 13 alert mqtt any any -> any any (msg:"SURICATA MQTT invalid QOS level"; app-layer-event:mqtt.invalid_… 14 alert mqtt any any -> any any (msg:"SURICATA MQTT missing message ID"; app-layer-event:mqtt.missing… 15 alert mqtt any any -> any any (msg:"SURICATA MQTT unassigned message type (0 or >15)"; app-layer-ev…
|
/dports/benchmarks/tsung/tsung-1.7.0/src/test/ |
H A D | ts_test_mqtt.erl | 47 Message = #mqtt{type = ?CONNECT, arg = Options}, 59 {#mqtt{type = Type}, Left} = mqtt_frame:decode(Data), 64 Message = #mqtt{type = ?DISCONNECT}, 70 {#mqtt{type = Type}, Left} = mqtt_frame:decode(Data), 82 {#mqtt{type = Type}, Left} = mqtt_frame:decode(Data), 94 {#mqtt{type = Type}, Left} = mqtt_frame:decode(Data), 106 {#mqtt{type = Type}, Left} = mqtt_frame:decode(Data), 111 Message = #mqtt{type = ?PUBACK, arg = 1}, 117 {#mqtt{type = Type}, Left} = mqtt_frame:decode(Data), 122 Message = #mqtt{type = ?PINGREQ}, [all …]
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/mqtt/source/ |
H A D | Makefile.am | 2 noinst_LTLIBRARIES += modules/mqtt/source/libmqtt_source.la 4 modules/mqtt/source/mqtt-source.h \ 5 modules/mqtt/source/mqtt-source.c 10 -I$(top_srcdir)/modules/mqtt/source/ \ 11 -I$(top_builddir)/modules/mqtt/source/ \ 12 -I$(top_srcdir)/modules/mqtt/ \ 13 -I$(top_builddir)/modules/mqtt/ 21 modules/mqtt/source/CMakeLists.txt
|
/dports/security/suricata/suricata-6.0.4/rust/src/mqtt/ |
H A D | mqtt_property.rs | 21 use crate::mqtt::parser::*; 61 impl crate::mqtt::mqtt_property::MQTTProperty { 70 crate::mqtt::mqtt_property::MQTTProperty::CONTENT_TYPE(v) => { in set_json() 73 crate::mqtt::mqtt_property::MQTTProperty::RESPONSE_TOPIC(v) => { in set_json() 76 crate::mqtt::mqtt_property::MQTTProperty::CORRELATION_DATA(v) => { in set_json() 109 crate::mqtt::mqtt_property::MQTTProperty::SERVER_REFERENCE(v) => { in set_json() 112 crate::mqtt::mqtt_property::MQTTProperty::REASON_STRING(v) => { in set_json() 115 crate::mqtt::mqtt_property::MQTTProperty::RECEIVE_MAXIMUM(v) => { in set_json() 121 crate::mqtt::mqtt_property::MQTTProperty::TOPIC_ALIAS(v) => { in set_json() 124 crate::mqtt::mqtt_property::MQTTProperty::MAXIMUM_QOS(v) => { in set_json() [all …]
|
/dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/mqtt/ |
H A D | mqtt.c | 463 __func__, mqtt); in lws_mqtt_client_remove_subs() 1160 w->mqtt = wsi->mqtt; in _lws_mqtt_rx_parser() 1161 wsi->mqtt = lws_zalloc(sizeof(*wsi->mqtt), "nwsi mqtt"); in _lws_mqtt_rx_parser() 1162 if (!wsi->mqtt) in _lws_mqtt_rx_parser() 1164 w->mqtt->wsi = w; in _lws_mqtt_rx_parser() 1726 if (mqtt->wsi->a.protocol->callback(mqtt->wsi, LWS_CALLBACK_MQTT_RESEND, in lws_mqtt_publish_resend() 1818 wsi->mqtt->ack_pkt_id = pub->packet_id = ++nwsi->mqtt->pkt_id; in lws_mqtt_client_send_publish() 1840 nwsi->mqtt->inside_payload = wsi->mqtt->inside_payload = 1; in lws_mqtt_client_send_publish() 1859 wsi->mqtt->inside_payload = nwsi->mqtt->inside_payload = 0; in lws_mqtt_client_send_publish() 2007 wsi->mqtt->ack_pkt_id = sub->packet_id = ++nwsi->mqtt->pkt_id; in lws_mqtt_client_send_subcribe() [all …]
|
/dports/net/p5-AnyEvent-MQTT/AnyEvent-MQTT-1.142640/t/ |
H A D | 04-multi-subs.t | 63 my $mqtt = AnyEvent::MQTT->new(host => $host, port => $port, 66 ok($mqtt, 'instantiate AnyEvent::MQTT object'); 70 my $t1_sub = $mqtt->subscribe(topic => '/t1', callback => $cb1); 74 my $t2_sub = $mqtt->subscribe(topic => '/t1', callback => $cb2); 85 my $t3_sub = $mqtt->subscribe(topic => '/t1', callback => $cb3); 88 $mqtt->_send(message_type => MQTT_PINGREQ); # ping to trigger server to cont. 96 my $unsub_cv = $mqtt->unsubscribe(topic => '/t1', callback => $cb1); 99 $mqtt->_send(message_type => MQTT_PINGREQ); # ping to trigger server to cont. 106 $unsub_cv = $mqtt->unsubscribe(topic => '/t1', callback => $cb2); 109 $mqtt->_send(message_type => MQTT_PINGREQ); # ping to trigger server to cont. [all …]
|