| /components/net/lwip/lwip-2.1.2/src/include/lwip/apps/ |
| A D | mqtt.h | 189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void…
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument
198 …ent_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
|
| /components/net/lwip/lwip-2.0.3/src/include/lwip/apps/ |
| A D | mqtt.h | 226 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void…
230 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument
237 …ent_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
|
| /components/net/lwip/lwip-2.0.3/src/apps/mqtt/ |
| A D | mqtt.c | 464 u8_t qos, u8_t retain, u16_t r_length) in mqtt_output_append_fixed_header() argument
604 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() argument
608 mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2); in pub_ack_rec_rel_response()
674 u8_t qos = MQTT_CTL_PACKET_QOS(client->rx_buffer[0]); in mqtt_message_received() local
687 if ((after_topic + (qos? 2 : 1)) > length) { in mqtt_message_received()
693 if (qos > 0) { in mqtt_message_received()
718 if (remaining_length == 0 && qos > 0) { in mqtt_message_received()
1048 if (qos > 0) { in mqtt_publish()
1073 if (qos > 0) { in mqtt_publish()
1120 LWIP_ASSERT("mqtt_sub_unsub: qos < 3", qos < 3); in mqtt_sub_unsub()
[all …]
|
| /components/net/lwip/lwip-2.1.2/src/apps/mqtt/ |
| A D | mqtt.c | 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() argument
639 mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2); in pub_ack_rec_rel_response()
715 u8_t qos = MQTT_CTL_PACKET_QOS(client->rx_buffer[0]); in mqtt_message_received() local
723 u16_t qos_len = (qos ? 2U : 0U); in mqtt_message_received()
739 if ((after_topic + (qos ? 2U : 1U)) > var_hdr_payload_bufsize) { in mqtt_message_received()
745 if (qos > 0) { in mqtt_message_received()
778 if (remaining_length == 0 && qos > 0) { in mqtt_message_received()
1117 if (qos > 0) { in mqtt_publish()
1146 if (qos > 0) { in mqtt_publish()
1194 LWIP_ASSERT("mqtt_sub_unsub: qos < 3", qos < 3); in mqtt_sub_unsub()
[all …]
|
| /components/vbus/share_hdr/ |
| A D | vbus_api.h | 27 unsigned char qos; member
|
| /components/net/lwip/lwip-2.0.3/doc/ |
| A D | mqtt_client.txt | 143 u8_t qos = 2; /* 0 1 or 2, see MQTT specification */
145 …err = mqtt_publish(client, "pub_topic", pub_payload, strlen(pub_payload), qos, retain, mqtt_pub_re…
|
| /components/net/lwip/lwip-2.1.2/doc/ |
| A D | mqtt_client.txt | 143 u8_t qos = 2; /* 0 1 or 2, see MQTT specification */
145 …err = mqtt_publish(client, "pub_topic", pub_payload, strlen(pub_payload), qos, retain, mqtt_pub_re…
|
| /components/vbus/ |
| A D | vbus.c | 246 RT_VBUS_OUT_RING->blks[RT_VBUS_OUT_RING->put_idx].qos = dpkg.prio; in _bus_out_entry()
|