Searched refs:qos (Results 1 - 2 of 2) sorted by relevance
/seL4-camkes-master/projects/lwip/src/include/lwip/apps/ |
H 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 *arg, u8_t sub); 193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) 198 err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
|
/seL4-camkes-master/projects/lwip/src/apps/mqtt/ |
H A D | mqtt.c | 109 /** Helpers to extract control packet type and qos from first byte in fixed header */ 631 * @param qos QoS value 635 pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos) argument 639 mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2); 715 u8_t qos = MQTT_CTL_PACKET_QOS(client->rx_buffer[0]); local 723 u16_t qos_len = (qos ? 2U : 0U); 739 if ((after_topic + (qos ? 2U : 1U)) > var_hdr_payload_bufsize) { 745 if (qos > 0) { 764 qos, topic, remaining_length + payload_length)); 778 if (remaining_length == 0 && qos > 1097 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, mqtt_request_cb_t cb, void *arg) argument 1173 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub) argument [all...] |
Completed in 68 milliseconds