Searched refs:rb (Results 1 – 8 of 8) sorted by relevance
| /components/drivers/ipc/ |
| A D | ringbuffer.c | 20 if (rb->read_index == rb->write_index) in rt_ringbuffer_status()
22 if (rb->read_mirror == rb->write_mirror) in rt_ringbuffer_status()
45 rb->read_mirror = rb->read_index = 0; in rt_ringbuffer_init()
46 rb->write_mirror = rb->write_index = 0; in rt_ringbuffer_init()
100 rb->write_mirror = ~rb->write_mirror; in rt_ringbuffer_put()
101 rb->write_index = length - (rb->buffer_size - rb->write_index); in rt_ringbuffer_put()
154 rb->write_mirror = ~rb->write_mirror; in rt_ringbuffer_put_force()
155 rb->write_index = length - (rb->buffer_size - rb->write_index); in rt_ringbuffer_put_force()
214 rb->read_mirror = ~rb->read_mirror; in rt_ringbuffer_get()
215 rb->read_index = length - (rb->buffer_size - rb->read_index); in rt_ringbuffer_get()
[all …]
|
| /components/drivers/include/ipc/ |
| A D | ringbuffer.h | 67 void rt_ringbuffer_init(struct rt_ringbuffer *rb, rt_uint8_t *pool, rt_int32_t size);
68 void rt_ringbuffer_reset(struct rt_ringbuffer *rb);
71 rt_size_t rt_ringbuffer_putchar(struct rt_ringbuffer *rb, const rt_uint8_t ch);
74 rt_size_t rt_ringbuffer_peek(struct rt_ringbuffer *rb, rt_uint8_t **ptr);
75 rt_size_t rt_ringbuffer_getchar(struct rt_ringbuffer *rb, rt_uint8_t *ch);
76 rt_size_t rt_ringbuffer_data_len(struct rt_ringbuffer *rb);
80 void rt_ringbuffer_destroy(struct rt_ringbuffer *rb);
90 rt_inline rt_uint32_t rt_ringbuffer_get_size(struct rt_ringbuffer *rb) in rt_ringbuffer_get_size() argument
92 RT_ASSERT(rb != RT_NULL); in rt_ringbuffer_get_size()
93 return rb->buffer_size; in rt_ringbuffer_get_size()
[all …]
|
| /components/drivers/serial/ |
| A D | dev_serial_v2.c | 284 *ptr = &rb->buffer_ptr[rb->read_index]; in rt_serial_get_linear_buffer()
286 if (rb->buffer_size - rb->read_index > size) in rt_serial_get_linear_buffer()
291 return rb->buffer_size - rb->read_index; in rt_serial_get_linear_buffer()
320 rb->read_mirror = ~rb->read_mirror; in rt_serial_update_read_index()
321 rb->read_index = length - (rb->buffer_size - rb->read_index); in rt_serial_update_read_index()
350 rb->read_index = rb->write_index; in rt_serial_update_write_index()
356 rb->write_mirror = ~rb->write_mirror; in rt_serial_update_write_index()
357 rb->write_index = length - (rb->buffer_size - rb->write_index); in rt_serial_update_write_index()
361 if (rb->write_index <= rb->read_index) in rt_serial_update_write_index()
362 rb->read_mirror = ~rb->read_mirror; in rt_serial_update_write_index()
[all …]
|
| A D | bypass.c | 149 ringbuf_date_stat = rt_ringbuffer_data_len(&rx_fifo->rb); in _bypass_getchar_form_serial_fifo()
156 if(!rt_ringbuffer_getchar(&rx_fifo->rb, (rt_uint8_t *)ch)) in _bypass_getchar_form_serial_fifo()
|
| /components/net/lwip/lwip-2.1.2/src/apps/mqtt/ |
| A D | mqtt.c | 186 rb->buf[rb->put] = item; in mqtt_ringbuf_put()
187 rb->put++; in mqtt_ringbuf_put()
189 rb->put = 0; in mqtt_ringbuf_put()
197 return &rb->buf[rb->get]; in mqtt_ringbuf_get_ptr()
205 rb->get += len; in mqtt_ringbuf_advance_get_idx()
207 rb->get = rb->get - MQTT_OUTPUT_RINGBUF_SIZE; in mqtt_ringbuf_advance_get_idx()
215 u32_t len = rb->put - rb->get; in mqtt_ringbuf_len()
223 #define mqtt_ringbuf_free(rb) (MQTT_OUTPUT_RINGBUF_SIZE - mqtt_ringbuf_len(rb)) argument
226 #define mqtt_ringbuf_linear_read_length(rb) LWIP_MIN(mqtt_ringbuf_len(rb), (MQTT_OUTPUT_RINGBUF_SIZ… argument
247 send_len, ringbuf_lin_len, rb->get, rb->put)); in mqtt_output_send()
[all …]
|
| /components/net/lwip/lwip-2.0.3/src/apps/mqtt/ |
| A D | mqtt.c | 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
422 mqtt_ringbuf_put(rb, value); in mqtt_output_append_u8()
428 mqtt_ringbuf_put(rb, value >> 8); in mqtt_output_append_u16()
429 mqtt_ringbuf_put(rb, value & 0xff); in mqtt_output_append_u16()
445 mqtt_ringbuf_put(rb, length >> 8); in mqtt_output_append_string()
[all …]
|
| /components/drivers/include/drivers/ |
| A D | dev_serial_v2.h | 291 struct rt_ringbuffer rb; member
310 struct rt_ringbuffer rb; member
|
| /components/drivers/usb/cherryusb/ |
| A D | .gitattributes | 23 *.rb text
|
Completed in 21 milliseconds