Lines Matching refs:qos
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)
639 mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2);
714 u8_t qos = MQTT_CTL_PACKET_QOS(client->rx_buffer[0]);
722 u16_t qos_len = (qos ? 2U : 0U);
738 if ((after_topic + (qos ? 2U : 1U)) > var_hdr_payload_bufsize) {
744 if (qos > 0) {
763 qos, topic, remaining_length + payload_length));
779 if (remaining_length == 0 && qos > 0) {
781 u8_t resp_msg = (qos == 1) ? MQTT_MSG_TYPE_PUBACK : MQTT_MSG_TYPE_PUBREC;
1087 * @param qos Quality of service, 0 1 or 2
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
1116 if (qos > 0) {
1139 mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain, remaining_length);
1145 if (qos > 0) {
1165 * @param qos Quality of service, 0 1 or 2 (only used for subscribe)
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub)
1188 /* Topic string, pkt_id, qos for subscribe */
1193 LWIP_ASSERT("mqtt_sub_unsub: qos < 3", qos < 3);
1219 mqtt_output_append_u8(&client->output, LWIP_MIN(qos, 2));