Lines Matching refs:u8_t
153 mqtt_msg_type_to_str(u8_t msg_type)
184 mqtt_ringbuf_put(struct mqtt_ringbuf_t *rb, u8_t item)
194 static u8_t *
237 u8_t wrap = 0;
290 u8_t n;
391 mqtt_request_time_elapsed(struct mqtt_request_t **tail, u8_t t)
398 t -= (u8_t)r->timeout_diff;
438 u8_t n;
451 mqtt_output_append_u8(struct mqtt_ringbuf_t *rb, u8_t value)
468 mqtt_ringbuf_put(rb, ((const u8_t *)data)[n]);
494 mqtt_output_append_fixed_header(struct mqtt_ringbuf_t *rb, u8_t msg_type, u8_t fdup,
495 u8_t fqos, u8_t fretain, u16_t r_length)
513 static u8_t
578 u8_t restart_timer = 1;
635 pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos)
656 mqtt_incomming_suback(struct mqtt_request_t *r, u8_t result)
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u32_t remaining_length)
676 u8_t *var_hdr_payload = client->rx_buffer + fixed_hdr_len;
680 u8_t pkt_type = MQTT_CTL_PACKET_TYPE(client->rx_buffer[0]);
714 u8_t qos = MQTT_CTL_PACKET_QOS(client->rx_buffer[0]);
718 u8_t *topic;
720 u8_t bkp;
781 u8_t resp_msg = (qos == 1) ? MQTT_MSG_TYPE_PUBACK : MQTT_MSG_TYPE_PUBREC;
844 u8_t fixed_hdr_len = 0;
845 u8_t b = 0;
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub)
1290 u8_t flags = 0, will_topic_len = 0, will_msg_len = 0;
1321 will_topic_len = (u8_t)len;
1324 will_msg_len = (u8_t)len;
1454 u8_t