Lines Matching refs:rb
250 if (rt_ringbuffer_data_len(&rx_fifo->rb)) in serial_fops_poll()
270 static rt_ssize_t rt_serial_get_linear_buffer(struct rt_ringbuffer *rb, in rt_serial_get_linear_buffer() argument
275 RT_ASSERT(rb != RT_NULL); in rt_serial_get_linear_buffer()
278 size = rt_ringbuffer_data_len(rb); in rt_serial_get_linear_buffer()
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()
295 static void rt_serial_update_read_index(struct rt_ringbuffer *rb, in rt_serial_update_read_index() argument
300 RT_ASSERT(rb != RT_NULL); in rt_serial_update_read_index()
303 size = rt_ringbuffer_data_len(rb); in rt_serial_update_read_index()
313 if (rb->buffer_size - rb->read_index > length) in rt_serial_update_read_index()
315 rb->read_index += length; in rt_serial_update_read_index()
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()
326 static void rt_serial_update_write_index(struct rt_ringbuffer *rb, in rt_serial_update_write_index() argument
330 RT_ASSERT(rb != RT_NULL); in rt_serial_update_write_index()
333 space_length = rt_ringbuffer_space_len(rb); in rt_serial_update_write_index()
335 if (length > rb->buffer_size) in rt_serial_update_write_index()
337 length = rb->buffer_size; in rt_serial_update_write_index()
339 LOG_W("The serial buffer (len %d) is overflow.", rb->buffer_size); in rt_serial_update_write_index()
343 if (rb->buffer_size - rb->write_index > length) in rt_serial_update_write_index()
347 rb->write_index += length; in rt_serial_update_write_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()
363 rb->read_index = rb->write_index; in rt_serial_update_write_index()
504 data_len = rt_ringbuffer_data_len(&rx_fifo->rb); in _serial_fifo_rx()
521 … recv_size += rt_ringbuffer_get(&rx_fifo->rb, (rt_uint8_t *)buffer + recv_size, size - recv_size); in _serial_fifo_rx()
535 … recv_size += rt_ringbuffer_get(&rx_fifo->rb, (rt_uint8_t *)buffer + recv_size, size - recv_size); in _serial_fifo_rx()
549 recv_size = rt_ringbuffer_get(&rx_fifo->rb, buffer, size); in _serial_fifo_rx()
680 tx_fifo->put_size = rt_ringbuffer_put(&tx_fifo->rb, in _serial_fifo_tx_blocking_buf()
683 rb_size = rt_ringbuffer_data_len(&tx_fifo->rb); in _serial_fifo_tx_blocking_buf()
719 send_size += rb_size - rt_ringbuffer_data_len(&tx_fifo->rb); in _serial_fifo_tx_blocking_buf()
768 send_size = rt_ringbuffer_put(&tx_fifo->rb, buffer, size); in _serial_fifo_tx_nonblocking()
771 tx_fifo->put_size = rt_serial_get_linear_buffer(&tx_fifo->rb, &put_ptr); in _serial_fifo_tx_nonblocking()
800 send_size = rt_ringbuffer_put(&tx_fifo->rb, buffer, size); in _serial_fifo_tx_nonblocking()
864 rt_ringbuffer_init(&tx_fifo->rb, in rt_serial_tx_enable()
918 rt_ringbuffer_init(&tx_fifo->rb, in rt_serial_tx_enable()
992 rt_ringbuffer_init(&rx_fifo->rb, in rt_serial_rx_enable()
1256 rt_ringbuffer_reset(&rx_fifo->rb); in _serial_rx_flush()
1299 *unread_bytes = rt_ringbuffer_data_len(&rx_fifo->rb); in _serial_get_unread_bytes_count()
1826 if ((tx_fifo->rb.buffer_ptr) == RT_NULL) in rt_serial_write()
1918 rt_ringbuffer_putchar(&rx_fifo->rb, *(rt_uint8_t *)args); in rt_hw_serial_control_isr()
1920 rt_ringbuffer_putchar_force(&rx_fifo->rb, *(rt_uint8_t *)args); in rt_hw_serial_control_isr()
1935 if (rt_ringbuffer_getchar(&tx_fifo->rb, (rt_uint8_t *)args) == 0) in rt_hw_serial_control_isr()
2005 put_len = rt_ringbuffer_put(&rx_fifo->rb, ptr, size); in rt_hw_serial_isr()
2013 rt_ringbuffer_put(&rx_fifo->rb, ptr, size); in rt_hw_serial_isr()
2027 rt_ringbuffer_put_force(&rx_fifo->rb, ptr, size); in rt_hw_serial_isr()
2033 rt_ringbuffer_put_force(&rx_fifo->rb, ptr, size); in rt_hw_serial_isr()
2040 rx_length = rt_ringbuffer_data_len(&rx_fifo->rb); in rt_hw_serial_isr()
2077 tx_length = rt_ringbuffer_data_len(&tx_fifo->rb); in rt_hw_serial_isr()
2100 tx_fifo->rb.buffer_ptr, in rt_hw_serial_isr()
2121 rt_serial_update_read_index(&tx_fifo->rb, tx_fifo->put_size); in rt_hw_serial_isr()
2124 tx_length = rt_ringbuffer_data_len(&tx_fifo->rb); in rt_hw_serial_isr()
2134 tx_fifo->put_size = rt_serial_get_linear_buffer(&tx_fifo->rb, &put_ptr); in rt_hw_serial_isr()