Home
last modified time | relevance | path

Searched refs:mqtt_client (Results 1 – 25 of 28) sorted by relevance

12

/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_transport.h22 typedef int (*transport_connect_handler_t)(struct mqtt_client *client);
25 typedef int (*transport_write_handler_t)(struct mqtt_client *client,
29 typedef int (*transport_write_msg_handler_t)(struct mqtt_client *client,
33 typedef int (*transport_read_handler_t)(struct mqtt_client *client, uint8_t *data,
37 typedef int (*transport_disconnect_handler_t)(struct mqtt_client *client);
73 int mqtt_transport_connect(struct mqtt_client *client);
83 int mqtt_transport_write(struct mqtt_client *client, const uint8_t *data,
94 int mqtt_transport_write_msg(struct mqtt_client *client,
107 int mqtt_transport_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen,
116 int mqtt_transport_disconnect(struct mqtt_client *client);
[all …]
Dmqtt_transport.c61 int mqtt_transport_connect(struct mqtt_client *client) in mqtt_transport_connect()
66 int mqtt_transport_write(struct mqtt_client *client, const uint8_t *data, in mqtt_transport_write()
73 int mqtt_transport_write_msg(struct mqtt_client *client, in mqtt_transport_write_msg()
79 int mqtt_transport_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_transport_read()
86 int mqtt_transport_disconnect(struct mqtt_client *client) in mqtt_transport_disconnect()
Dmqtt.c21 static void client_reset(struct mqtt_client *client) in client_reset()
31 static void tx_buf_init(struct mqtt_client *client, struct buf_ctx *buf) in tx_buf_init()
38 void event_notify(struct mqtt_client *client, const struct mqtt_evt *evt) in event_notify()
49 static void client_disconnect(struct mqtt_client *client, int result, in client_disconnect()
73 static int client_connect(struct mqtt_client *client) in client_connect()
112 static int client_read(struct mqtt_client *client) in client_read()
128 static int client_write(struct mqtt_client *client, const uint8_t *data, in client_write()
149 static int client_write_msg(struct mqtt_client *client, in client_write_msg()
170 void mqtt_client_init(struct mqtt_client *client) in mqtt_client_init()
185 int mqtt_client_set_proxy(struct mqtt_client *client, in mqtt_client_set_proxy()
[all …]
Dmqtt_os.h37 static inline void mqtt_mutex_init(struct mqtt_client *client) in mqtt_mutex_init()
47 static inline void mqtt_mutex_lock(struct mqtt_client *client) in mqtt_mutex_lock()
57 static inline void mqtt_mutex_unlock(struct mqtt_client *client) in mqtt_mutex_unlock()
Dmqtt_transport_socket_tcp.c21 int mqtt_client_tcp_connect(struct mqtt_client *client) in mqtt_client_tcp_connect()
66 int mqtt_client_tcp_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tcp_write()
85 int mqtt_client_tcp_write_msg(struct mqtt_client *client, in mqtt_client_tcp_write_msg()
125 int mqtt_client_tcp_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tcp_read()
143 int mqtt_client_tcp_disconnect(struct mqtt_client *client) in mqtt_client_tcp_disconnect()
Dmqtt_transport_websocket.c24 int mqtt_client_websocket_connect(struct mqtt_client *client) in mqtt_client_websocket_connect()
89 int mqtt_client_websocket_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_websocket_write()
110 int mqtt_client_websocket_write_msg(struct mqtt_client *client, in mqtt_client_websocket_write_msg()
140 int mqtt_client_websocket_read(struct mqtt_client *client, uint8_t *data, in mqtt_client_websocket_read()
169 int mqtt_client_websocket_disconnect(struct mqtt_client *client) in mqtt_client_websocket_disconnect()
Dmqtt_internal.h155 void event_notify(struct mqtt_client *client, const struct mqtt_evt *evt);
163 int mqtt_handle_rx(struct mqtt_client *client);
179 int connect_request_encode(const struct mqtt_client *client,
315 int connect_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf,
Dmqtt_transport_socket_tls.c21 int mqtt_client_tls_connect(struct mqtt_client *client) in mqtt_client_tls_connect()
123 int mqtt_client_tls_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tls_write()
142 int mqtt_client_tls_write_msg(struct mqtt_client *client, in mqtt_client_tls_write_msg()
181 int mqtt_client_tls_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tls_read()
199 int mqtt_client_tls_disconnect(struct mqtt_client *client) in mqtt_client_tls_disconnect()
Dmqtt_rx.c19 static int mqtt_handle_packet(struct mqtt_client *client, in mqtt_handle_packet()
148 static int mqtt_read_message_chunk(struct mqtt_client *client, in mqtt_read_message_chunk()
196 static int mqtt_read_publish_var_header(struct mqtt_client *client, in mqtt_read_publish_var_header()
231 static int mqtt_read_and_parse_fixed_header(struct mqtt_client *client, in mqtt_read_and_parse_fixed_header()
256 int mqtt_handle_rx(struct mqtt_client *client) in mqtt_handle_rx()
Dmqtt_decoder.c211 int connect_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf, in connect_ack_decode()
/Zephyr-latest/tests/net/lib/mqtt_sn_client/src/
Dmqtt_sn_client.c122 static ZTEST_BMEM struct mqtt_sn_client *mqtt_client; variable
131 mqtt_client = &mqtt_clients[i++]; in setup()
149 mqtt_sn_client_deinit(mqtt_client); in cleanup()
198 err = mqtt_sn_client_init(mqtt_client, &client_id, &transport, evt_cb, tx, sizeof(tx), rx, in ZTEST()
202 err = input(mqtt_client, advertise, sizeof(advertise), &gw_addr); in ZTEST()
204 zassert_false(sys_slist_is_empty(&mqtt_client->gateway), "GW not saved."); in ZTEST()
208 err = input(mqtt_client, advertise, sizeof(advertise), &gw_addr); in ZTEST()
210 zassert_false(sys_slist_is_empty(&mqtt_client->gateway), "GW not saved."); in ZTEST()
211 zassert_equal(sys_slist_len(&mqtt_client->gateway), 1, "Too many Gateways stored."); in ZTEST()
215 err = mqtt_sn_connect(mqtt_client, false, false); in ZTEST()
[all …]
/Zephyr-latest/include/zephyr/net/
Dmqtt.h330 struct mqtt_client;
340 typedef void (*mqtt_evt_cb_t)(struct mqtt_client *client,
494 struct mqtt_client { struct
577 void mqtt_client_init(struct mqtt_client *client); argument
592 int mqtt_client_set_proxy(struct mqtt_client *client,
615 int mqtt_connect(struct mqtt_client *client);
627 int mqtt_publish(struct mqtt_client *client,
641 int mqtt_publish_qos1_ack(struct mqtt_client *client,
655 int mqtt_publish_qos2_receive(struct mqtt_client *client,
668 int mqtt_publish_qos2_release(struct mqtt_client *client,
[all …]
/Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/
Dmqtt_client.h20 int app_mqtt_init(struct mqtt_client *client);
25 void app_mqtt_connect(struct mqtt_client *client);
31 void app_mqtt_run(struct mqtt_client *client);
36 int app_mqtt_subscribe(struct mqtt_client *client);
41 int app_mqtt_publish(struct mqtt_client *client);
Dmqtt_client.c72 static void prepare_fds(struct mqtt_client *client) in prepare_fds()
123 static void on_mqtt_publish(struct mqtt_client *const client, const struct mqtt_evt *evt) in on_mqtt_publish()
149 static void mqtt_event_handler(struct mqtt_client *const client, const struct mqtt_evt *evt) in mqtt_event_handler()
248 static int poll_mqtt_socket(struct mqtt_client *client, int timeout) in poll_mqtt_socket()
291 int app_mqtt_publish(struct mqtt_client *client) in app_mqtt_publish()
329 int app_mqtt_subscribe(struct mqtt_client *client) in app_mqtt_subscribe()
359 int app_mqtt_process(struct mqtt_client *client) in app_mqtt_process()
390 void app_mqtt_run(struct mqtt_client *client) in app_mqtt_run()
408 void app_mqtt_connect(struct mqtt_client *client) in app_mqtt_connect()
435 int app_mqtt_init(struct mqtt_client *client) in app_mqtt_init()
Dmain.c22 static struct mqtt_client client_ctx;
/Zephyr-latest/samples/net/mqtt_sn_publisher/src/
Dudp.c31 static APP_BMEM struct mqtt_sn_client mqtt_client; variable
90 err = mqtt_sn_input(&mqtt_client); in do_work()
97 err = mqtt_sn_subscribe(&mqtt_client, MQTT_SN_QOS_0, &topic_s); in do_work()
117 err = mqtt_sn_publish(&mqtt_client, MQTT_SN_QOS_0, &topic_p, false, &pubdata); in do_work()
143 err = mqtt_sn_client_init(&mqtt_client, &client_id, &tp.tp, evt_cb, tx_buf, sizeof(tx_buf), in process_thread()
160 err = mqtt_sn_add_gw(&mqtt_client, 0x1f, gwaddr_data); in process_thread()
164 err = mqtt_sn_search(&mqtt_client, 1); in process_thread()
166 err = mqtt_sn_input(&mqtt_client); in process_thread()
171 err = mqtt_sn_connect(&mqtt_client, false, true); in process_thread()
/Zephyr-latest/samples/net/cloud/mqtt_azure/src/
Dmain.c28 static struct mqtt_client client_ctx;
72 static void mqtt_event_handler(struct mqtt_client *const client,
89 static void prepare_fds(struct mqtt_client *client) in prepare_fds()
144 static void client_init(struct mqtt_client *client) in client_init()
198 static void mqtt_event_handler(struct mqtt_client *const client, in mqtt_event_handler()
273 static void subscribe(struct mqtt_client *client) in subscribe()
290 static int publish(struct mqtt_client *client, enum mqtt_qos qos) in publish()
350 static int try_to_connect(struct mqtt_client *client) in try_to_connect()
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/
Dmain.c29 static struct mqtt_client client_ctx;
84 static void prepare_client_fds(struct mqtt_client *client) in prepare_client_fds()
436 static void publish_handler(struct mqtt_client *const client, in publish_handler()
458 static void mqtt_evt_handler(struct mqtt_client *const client, in mqtt_evt_handler()
556 static void client_init(struct mqtt_client *client) in client_init()
705 ZTEST(mqtt_client, test_mqtt_connect) in ZTEST() argument
713 ZTEST(mqtt_client, test_mqtt_ping) in ZTEST() argument
721 ZTEST(mqtt_client, test_mqtt_publish_qos0) in ZTEST() argument
732 ZTEST(mqtt_client, test_mqtt_publish_qos1) in ZTEST() argument
743 ZTEST(mqtt_client, test_mqtt_publish_qos2) in ZTEST() argument
[all …]
/Zephyr-latest/samples/net/mqtt_publisher/src/
Dmain.c45 static APP_BMEM struct mqtt_client client_ctx;
109 static void prepare_fds(struct mqtt_client *client) in prepare_fds()
143 void mqtt_evt_handler(struct mqtt_client *const client, in mqtt_evt_handler()
243 static int publish(struct mqtt_client *client, enum mqtt_qos qos) in publish()
298 static void client_init(struct mqtt_client *client) in client_init()
365 static int try_to_connect(struct mqtt_client *client) in try_to_connect()
398 static int process_mqtt_and_sleep(struct mqtt_client *client, int timeout) in process_mqtt_and_sleep()
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/
DCMakeLists.txt6 project(mqtt_client) project
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_packet/src/
Dmqtt_packet.c23 static ZTEST_DMEM struct mqtt_client client;
235 static ZTEST_DMEM struct mqtt_client client_connect1 = {
259 static ZTEST_DMEM struct mqtt_client client_connect2 = {
281 static ZTEST_DMEM struct mqtt_client client_connect3 = {
303 static ZTEST_DMEM struct mqtt_client client_connect4 = {
325 static ZTEST_DMEM struct mqtt_client client_connect5 = {
349 static ZTEST_DMEM struct mqtt_client client_connect6 = {
712 struct mqtt_client *test_client; in eval_msg_connect()
716 test_client = (struct mqtt_client *)mqtt_test->ctx; in eval_msg_connect()
/Zephyr-latest/include/zephyr/shell/
Dshell_mqtt.h59 struct mqtt_client mqtt_cli;
/Zephyr-latest/samples/net/cloud/aws_iot_mqtt/src/
Dmain.c47 static struct mqtt_client client_ctx;
203 static void mqtt_event_cb(struct mqtt_client *client, const struct mqtt_evt *evt) in mqtt_event_cb()
/Zephyr-latest/doc/connectivity/networking/api/
Dmqtt.rst44 static struct mqtt_client client_ctx;
61 void mqtt_evt_handler(struct mqtt_client *client,
Dmqtt_sn.rst101 err = mqtt_sn_search(&mqtt_client, 1);
103 err = mqtt_sn_input(&mqtt_client);

12