Home
last modified time | relevance | path

Searched refs:mqtt (Results 1 – 25 of 750) sorted by relevance

12345678910>>...30

/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/mqtt/
H A DMakefile.am23 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 Dmqtt-keywords.rst22 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 Dmqtt.c74 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 Dfacebook-mqtt.c63 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 Drabbitmq_mqtt.schema4 %% 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 Doutput_mqtt.c355 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 D04-revert-gio.patch26 #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 DMakefile.am2 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 Dss-mqtt.c54 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 Dmqtt.scrbl3 @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 Dmqtt.c246 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 Dmqtt_frame.erl39 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 DREADME118 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 Dmqtt.c16 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 Dmqtt.h3 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 Dsubscribe.c24 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 Dpublish.c27 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 D01-message.t13 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 DSavvyCAN.pro24 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 Dmqtt-events.rules7 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 Dts_test_mqtt.erl47 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 DMakefile.am2 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 Dmqtt_property.rs21 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 Dmqtt.c463 __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 D04-multi-subs.t63 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 …]

12345678910>>...30