Searched refs:qos (Results 1 - 2 of 2) sorted by relevance

/seL4-camkes-master/projects/lwip/src/include/lwip/apps/
H A Dmqtt.h189 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 Dmqtt.c109 /** 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