Lines Matching defs:rb
182 #define mqtt_ringbuf_put(rb, item) ((rb)->buf)[(rb)->put++ & MQTT_RINGBUF_IDX_MASK] = (item) argument
185 #define mqtt_ringbuf_len(rb) ((u16_t)((rb)->put - (rb)->get)) argument
188 #define mqtt_ringbuf_free(rb) (MQTT_OUTPUT_RINGBUF_SIZE - mqtt_ringbuf_len(rb)) argument
191 #define mqtt_ringbuf_linear_read_length(rb) LWIP_MIN(mqtt_ringbuf_len(rb), (MQTT_OUTPUT_RINGBUF_SIZ… argument
194 #define mqtt_ringbuf_get_ptr(rb) (&(rb)->buf[(rb)->get & MQTT_RINGBUF_IDX_MASK]) argument
196 #define mqtt_ringbuf_advance_get_idx(rb, len) ((rb)->get += (len)) argument
205 mqtt_output_send(struct mqtt_ringbuf_t *rb, struct tcp_pcb *tpcb) in mqtt_output_send()
419 mqtt_output_append_u8(struct mqtt_ringbuf_t *rb, u8_t value) in mqtt_output_append_u8()
425 void mqtt_output_append_u16(struct mqtt_ringbuf_t *rb, u16_t value) in mqtt_output_append_u16()
432 mqtt_output_append_buf(struct mqtt_ringbuf_t *rb, const void *data, u16_t length) in mqtt_output_append_buf()
441 mqtt_output_append_string(struct mqtt_ringbuf_t *rb, const char *str, u16_t length) in mqtt_output_append_string()
462 mqtt_output_append_fixed_header(struct mqtt_ringbuf_t *rb, u8_t msg_type, u8_t dup, in mqtt_output_append_fixed_header()
482 mqtt_output_check_space(struct mqtt_ringbuf_t *rb, u16_t r_length) in mqtt_output_check_space()