Searched refs:mqtt_client_t (Results 1 – 2 of 2) sorted by relevance
| /btstack/3rd-party/lwip/core/src/include/lwip/apps/ |
| H A D | mqtt.h | 49 typedef struct mqtt_client_s mqtt_client_t; typedef
126 typedef void (*mqtt_connection_cb_t)(mqtt_client_t *client, void *arg, mqtt_connection_status_t sta…
176 err_t mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ipaddr, u16_t port, mqtt_connecti…
179 void mqtt_disconnect(mqtt_client_t *client);
181 mqtt_client_t *mqtt_client_new(void);
182 void mqtt_client_free(mqtt_client_t* client);
184 u8_t mqtt_client_is_connected(mqtt_client_t *client);
186 void mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t,
189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void…
198 err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_len…
|
| /btstack/3rd-party/lwip/core/src/apps/mqtt/ |
| H A D | mqtt.c | 170 msg_generate_packet_id(mqtt_client_t *client) in msg_generate_packet_id()
537 mqtt_close(mqtt_client_t *client, mqtt_connection_status_t reason) in mqtt_close()
579 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_cyclic_timer()
635 pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos) in pub_ack_rec_rel_response()
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u32_t remaining_leng… in mqtt_message_received()
841 mqtt_parse_incoming(mqtt_client_t *client, struct pbuf *p) in mqtt_parse_incoming()
940 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_recv_cb()
984 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_sent_cb()
1017 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_err_cb()
1035 mqtt_client_t *client = (mqtt_client_t *)arg; in mqtt_tcp_poll_cb()
[all …]
|