Lines Matching refs:msg
76 struct rx_msg msg; in uart_input_dma() local
79 msg.dev = dev; in uart_input_dma()
80 msg.size = size; in uart_input_dma()
82 result = rt_mq_send(&rx_mq, &msg, sizeof(msg)); in uart_input_dma()
108 struct rx_msg msg; in serial_thread_entry_dma() local
117 rt_memset(&msg, 0, sizeof(msg)); in serial_thread_entry_dma()
119 result = rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER); in serial_thread_entry_dma()
123 while (msg.size) in serial_thread_entry_dma()
125 if (msg.size > (buf_size - put_index)) in serial_thread_entry_dma()
127 … rx_length = rt_device_read(msg.dev, 0, rx_buffer + put_index, buf_size - put_index); in serial_thread_entry_dma()
128 msg.size -= rx_length; in serial_thread_entry_dma()
132 rx_length = rt_device_read(msg.dev, 0, rx_buffer + put_index, msg.size); in serial_thread_entry_dma()
133 msg.size = 0UL; in serial_thread_entry_dma()