Lines Matching refs:tx_fifo
571 struct rt_serial_tx_fifo *tx_fifo; in _serial_fifo_tx_blocking_nbuf() local
579 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in _serial_fifo_tx_blocking_nbuf()
580 RT_ASSERT(tx_fifo != RT_NULL); in _serial_fifo_tx_blocking_nbuf()
590 if (rt_atomic_flag_test_and_set(&tx_fifo->activated)) in _serial_fifo_tx_blocking_nbuf()
596 rt_completion_wait(&tx_fifo->tx_cpt, 0); in _serial_fifo_tx_blocking_nbuf()
608 if (rt_atomic_load(&tx_fifo->tx_timeout) == RT_WAITING_NO) in _serial_fifo_tx_blocking_nbuf()
619 ret = rt_completion_wait(&tx_fifo->tx_cpt, rt_atomic_load(&tx_fifo->tx_timeout)); in _serial_fifo_tx_blocking_nbuf()
644 struct rt_serial_tx_fifo *tx_fifo; in _serial_fifo_tx_blocking_buf() local
651 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in _serial_fifo_tx_blocking_buf()
652 RT_ASSERT(tx_fifo != RT_NULL); in _serial_fifo_tx_blocking_buf()
662 if (rt_atomic_flag_test_and_set(&tx_fifo->activated)) in _serial_fifo_tx_blocking_buf()
668 rt_int32_t base_tx_timeout = rt_atomic_load(&tx_fifo->tx_timeout); in _serial_fifo_tx_blocking_buf()
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()
687 rt_completion_wait(&tx_fifo->tx_cpt, 0); in _serial_fifo_tx_blocking_buf()
694 tx_fifo->put_size, in _serial_fifo_tx_blocking_buf()
706 send_size += tx_fifo->put_size; in _serial_fifo_tx_blocking_buf()
712 rt_completion_wait(&tx_fifo->tx_cpt, tx_timeout_left); in _serial_fifo_tx_blocking_buf()
719 send_size += rb_size - rt_ringbuffer_data_len(&tx_fifo->rb); in _serial_fifo_tx_blocking_buf()
727 send_size += tx_fifo->put_size; in _serial_fifo_tx_blocking_buf()
749 struct rt_serial_tx_fifo *tx_fifo; in _serial_fifo_tx_nonblocking() local
759 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in _serial_fifo_tx_nonblocking()
760 RT_ASSERT(tx_fifo != RT_NULL); in _serial_fifo_tx_nonblocking()
764 if (!rt_atomic_flag_test_and_set(&tx_fifo->activated)) in _serial_fifo_tx_nonblocking()
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()
775 rt_completion_wait(&tx_fifo->tx_cpt, 0); in _serial_fifo_tx_nonblocking()
782 tx_fifo->put_size, in _serial_fifo_tx_nonblocking()
800 send_size = rt_ringbuffer_put(&tx_fifo->rb, buffer, size); in _serial_fifo_tx_nonblocking()
817 struct rt_serial_tx_fifo *tx_fifo = RT_NULL; in rt_serial_tx_enable() local
861 …tx_fifo = (struct rt_serial_tx_fifo *)rt_malloc(sizeof(struct rt_serial_tx_fifo) + serial->config.… in rt_serial_tx_enable()
862 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_tx_enable()
863 rt_memset(tx_fifo, RT_NULL, sizeof(struct rt_serial_tx_fifo) + serial->config.tx_bufsz); in rt_serial_tx_enable()
864 rt_ringbuffer_init(&tx_fifo->rb, in rt_serial_tx_enable()
865 (rt_uint8_t *)tx_fifo + sizeof(struct rt_serial_tx_fifo), in rt_serial_tx_enable()
867 serial->serial_tx = tx_fifo; in rt_serial_tx_enable()
877 tx_fifo = (struct rt_serial_tx_fifo *)rt_malloc(sizeof(struct rt_serial_tx_fifo)); in rt_serial_tx_enable()
878 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_tx_enable()
879 rt_memset(tx_fifo, RT_NULL, sizeof(struct rt_serial_tx_fifo)); in rt_serial_tx_enable()
882 serial->serial_tx = tx_fifo; in rt_serial_tx_enable()
901 rt_atomic_flag_clear(&tx_fifo->activated); in rt_serial_tx_enable()
902 tx_fifo->put_size = 0; in rt_serial_tx_enable()
903 rt_atomic_store(&tx_fifo->tx_timeout, RT_WAITING_FOREVER); in rt_serial_tx_enable()
905 rt_completion_init(&tx_fifo->tx_cpt); in rt_serial_tx_enable()
914 …tx_fifo = (struct rt_serial_tx_fifo *)rt_malloc(sizeof(struct rt_serial_tx_fifo) + serial->config.… in rt_serial_tx_enable()
915 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_tx_enable()
916 rt_memset(tx_fifo, RT_NULL, sizeof(struct rt_serial_tx_fifo) + serial->config.tx_bufsz); in rt_serial_tx_enable()
918 rt_ringbuffer_init(&tx_fifo->rb, in rt_serial_tx_enable()
919 (rt_uint8_t *)tx_fifo + sizeof(struct rt_serial_tx_fifo), in rt_serial_tx_enable()
921 serial->serial_tx = tx_fifo; in rt_serial_tx_enable()
923 rt_atomic_flag_clear(&tx_fifo->activated); in rt_serial_tx_enable()
924 tx_fifo->put_size = 0; in rt_serial_tx_enable()
930 rt_completion_init(&tx_fifo->tx_cpt); in rt_serial_tx_enable()
1083 struct rt_serial_tx_fifo *tx_fifo; in rt_serial_tx_disable() local
1094 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_serial_tx_disable()
1095 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_tx_disable()
1107 rt_completion_done(&tx_fifo->tx_cpt); in rt_serial_tx_disable()
1116 rt_free(tx_fifo); in rt_serial_tx_disable()
1267 struct rt_serial_tx_fifo *tx_fifo; in _serial_tx_flush() local
1272 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in _serial_tx_flush()
1273 RT_ASSERT(tx_fifo != RT_NULL); in _serial_tx_flush()
1275 if (rt_atomic_load(&tx_fifo->activated)) in _serial_tx_flush()
1277 rt_completion_wait(&tx_fifo->tx_cpt, RT_WAITING_FOREVER); in _serial_tx_flush()
1492 struct rt_serial_tx_fifo *tx_fifo = RT_NULL; in rt_serial_control() local
1493 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_serial_control()
1494 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_control()
1496 rt_atomic_store(&tx_fifo->tx_timeout, *(rt_int32_t *)args); in rt_serial_control()
1532 struct rt_serial_tx_fifo *tx_fifo = RT_NULL; in rt_serial_control() local
1533 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_serial_control()
1534 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_control()
1536 *(rt_int32_t *)args = rt_atomic_load(&tx_fifo->tx_timeout); in rt_serial_control()
1809 struct rt_serial_tx_fifo *tx_fifo; in rt_serial_write() local
1816 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_serial_write()
1825 RT_ASSERT(tx_fifo != RT_NULL); in rt_serial_write()
1826 if ((tx_fifo->rb.buffer_ptr) == RT_NULL) in rt_serial_write()
1932 struct rt_serial_tx_fifo *tx_fifo = RT_NULL; in rt_hw_serial_control_isr() local
1933 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_hw_serial_control_isr()
1934 RT_ASSERT(tx_fifo != RT_NULL); 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()
2070 struct rt_serial_tx_fifo *tx_fifo; in rt_hw_serial_isr() local
2073 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_hw_serial_isr()
2074 RT_ASSERT(tx_fifo != RT_NULL); in rt_hw_serial_isr()
2077 tx_length = rt_ringbuffer_data_len(&tx_fifo->rb); in rt_hw_serial_isr()
2083 rt_completion_done(&tx_fifo->tx_cpt); in rt_hw_serial_isr()
2091 rt_atomic_flag_clear(&tx_fifo->activated); in rt_hw_serial_isr()
2095 rt_atomic_flag_test_and_set(&tx_fifo->activated); in rt_hw_serial_isr()
2100 tx_fifo->rb.buffer_ptr, in rt_hw_serial_isr()
2105 rt_atomic_flag_clear(&tx_fifo->activated); in rt_hw_serial_isr()
2112 struct rt_serial_tx_fifo *tx_fifo; in rt_hw_serial_isr() local
2115 tx_fifo = (struct rt_serial_tx_fifo *)serial->serial_tx; in rt_hw_serial_isr()
2116 RT_ASSERT(tx_fifo != RT_NULL); 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()
2130 rt_atomic_flag_test_and_set(&tx_fifo->activated); 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()
2139 tx_fifo->put_size, in rt_hw_serial_isr()
2143 rt_atomic_flag_clear(&tx_fifo->activated); in rt_hw_serial_isr()
2149 rt_completion_done(&tx_fifo->tx_cpt); in rt_hw_serial_isr()
2157 rt_atomic_flag_clear(&tx_fifo->activated); in rt_hw_serial_isr()