Searched defs:rb (Results 1 – 6 of 6) sorted by relevance
| /components/drivers/ipc/ |
| A D | ringbuffer.c | 18 rt_inline enum rt_ringbuffer_state rt_ringbuffer_status(struct rt_ringbuffer *rb) in rt_ringbuffer_status()
37 void rt_ringbuffer_init(struct rt_ringbuffer *rb, in rt_ringbuffer_init()
63 rt_size_t rt_ringbuffer_put(struct rt_ringbuffer *rb, in rt_ringbuffer_put()
116 rt_size_t rt_ringbuffer_put_force(struct rt_ringbuffer *rb, in rt_ringbuffer_put_force()
177 rt_size_t rt_ringbuffer_get(struct rt_ringbuffer *rb, in rt_ringbuffer_get()
231 rt_size_t rt_ringbuffer_peek(struct rt_ringbuffer *rb, rt_uint8_t **ptr) in rt_ringbuffer_peek()
346 rt_size_t rt_ringbuffer_getchar(struct rt_ringbuffer *rb, rt_uint8_t *ch) in rt_ringbuffer_getchar()
378 rt_size_t rt_ringbuffer_data_len(struct rt_ringbuffer *rb) in rt_ringbuffer_data_len()
405 void rt_ringbuffer_reset(struct rt_ringbuffer *rb) in rt_ringbuffer_reset()
427 struct rt_ringbuffer *rb; in rt_ringbuffer_create() local
[all …]
|
| /components/net/lwip/lwip-2.0.3/src/apps/mqtt/ |
| A D | mqtt.c | 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
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()
420 mqtt_output_append_u8(struct mqtt_ringbuf_t *rb, u8_t value) in mqtt_output_append_u8()
426 void mqtt_output_append_u16(struct mqtt_ringbuf_t *rb, u16_t value) in mqtt_output_append_u16()
433 mqtt_output_append_buf(struct mqtt_ringbuf_t *rb, const void *data, u16_t length) in mqtt_output_append_buf()
442 mqtt_output_append_string(struct mqtt_ringbuf_t *rb, const char *str, u16_t length) in mqtt_output_append_string()
463 mqtt_output_append_fixed_header(struct mqtt_ringbuf_t *rb, u8_t msg_type, u8_t dup, in mqtt_output_append_fixed_header()
[all …]
|
| /components/net/lwip/lwip-2.1.2/src/apps/mqtt/ |
| A D | mqtt.c | 184 mqtt_ringbuf_put(struct mqtt_ringbuf_t *rb, u8_t item) in mqtt_ringbuf_put()
195 mqtt_ringbuf_get_ptr(struct mqtt_ringbuf_t *rb) in mqtt_ringbuf_get_ptr()
201 mqtt_ringbuf_advance_get_idx(struct mqtt_ringbuf_t *rb, u16_t len) in mqtt_ringbuf_advance_get_idx()
213 mqtt_ringbuf_len(struct mqtt_ringbuf_t *rb) in mqtt_ringbuf_len()
223 #define mqtt_ringbuf_free(rb) (MQTT_OUTPUT_RINGBUF_SIZE - mqtt_ringbuf_len(rb)) argument
234 mqtt_output_send(struct mqtt_ringbuf_t *rb, struct altcp_pcb *tpcb) in mqtt_output_send()
451 mqtt_output_append_u8(struct mqtt_ringbuf_t *rb, u8_t value) in mqtt_output_append_u8()
457 void mqtt_output_append_u16(struct mqtt_ringbuf_t *rb, u16_t value) in mqtt_output_append_u16()
464 mqtt_output_append_buf(struct mqtt_ringbuf_t *rb, const void *data, u16_t length) in mqtt_output_append_buf()
473 mqtt_output_append_string(struct mqtt_ringbuf_t *rb, const char *str, u16_t length) in mqtt_output_append_string()
[all …]
|
| /components/drivers/include/ipc/ |
| A D | ringbuffer.h | 90 rt_inline rt_uint32_t rt_ringbuffer_get_size(struct rt_ringbuffer *rb) in rt_ringbuffer_get_size()
97 #define rt_ringbuffer_space_len(rb) ((rb)->buffer_size - rt_ringbuffer_data_len(rb)) argument
|
| /components/drivers/include/drivers/ |
| A D | dev_serial_v2.h | 291 struct rt_ringbuffer rb; member
310 struct rt_ringbuffer rb; member
|
| /components/drivers/serial/ |
| A D | dev_serial_v2.c | 270 static rt_ssize_t rt_serial_get_linear_buffer(struct rt_ringbuffer *rb, in rt_serial_get_linear_buffer()
295 static void rt_serial_update_read_index(struct rt_ringbuffer *rb, in rt_serial_update_read_index()
326 static void rt_serial_update_write_index(struct rt_ringbuffer *rb, in rt_serial_update_write_index()
|
Completed in 16 milliseconds