Lines Matching refs:in_queue
40 struct k_msgq in_queue; member
323 while (k_msgq_get(&stream->in_queue, &queue_entry, K_NO_WAIT) == 0) { in i2s_purge_stream_buffers()
327 while (k_msgq_get(&stream->in_queue, &buffer, K_NO_WAIT) == 0) { in i2s_purge_stream_buffers()
498 ret = k_msgq_get(&stream->in_queue, &queue_entry, K_NO_WAIT); in i2s_mcux_dma_tx_callback()
551 ret = k_msgq_get(&stream->in_queue, &buffer, K_NO_WAIT); in i2s_mcux_dma_rx_callback()
578 ret = k_msgq_put(&stream->in_queue, &buffer, K_NO_WAIT); in i2s_mcux_dma_rx_callback()
581 buffer, &stream->in_queue, ret); in i2s_mcux_dma_rx_callback()
607 ret = k_msgq_get(&stream->in_queue, &queue_entry, K_NO_WAIT); in i2s_mcux_tx_stream_start()
673 ret = k_msgq_put(&stream->in_queue, &buffer[i], K_NO_WAIT); in i2s_mcux_rx_stream_start()
843 ret = k_msgq_put(&stream->in_queue, &queue_entry, in i2s_mcux_write()
899 k_msgq_init(&data->tx.in_queue, (char *)data->tx_in_msgs, in i2s_mcux_init()
901 k_msgq_init(&data->rx.in_queue, (char *)data->rx_in_msgs, in i2s_mcux_init()