Function rt_audio_pipe_write

components/drivers/audio/dev_audio_pipe.c:150–212

* @brief Write data into audio pipe * * @param[in] dev pointer to audio pipe that has been configured * * @param[in] pos useless param * * @param[in] buffer pointer to buffer of ringbuffer * * @param[in] size size of data will be written * * @return number of written bytes * * @note The function will disable interrupt and may suspend current thread */

 * @note The function will disable interrupt and may suspend current thread
 */
static rt_ssize_t rt_audio_pipe_write(rt_device_t dev,
                               rt_off_t    pos,
                               const void *buffer,
                               rt_size_t   size)
{
    rt_base_t level;
    rt_thread_t thread;
    struct rt_audio_pipe *pipe;
    rt_size_t write_nbytes;

    pipe = (struct rt_audio_pipe *)dev;
    RT_ASSERT(pipe != RT_NULL);

    if ((pipe->flag & RT_PIPE_FLAG_FORCE_WR) ||
            !(pipe->flag & RT_PIPE_FLAG_BLOCK_WR))
    {
        level = rt_hw_interrupt_disable();

        if (pipe->flag & RT_PIPE_FLAG_FORCE_WR)
            write_nbytes = rt_ringbuffer_put_force(&(pipe->ringbuffer),
                                                   (const rt_uint8_t *)buffer, size);
        else
            write_nbytes = rt_ringbuffer_put(&(pipe->ringbuffer),
                                             (const rt_uint8_t *)buffer, size);

        _rt_audio_pipe_resume_reader(pipe);

        rt_hw_interrupt_enable(level);

        return write_nbytes;
    }

    thread = rt_thread_self();

    /* current context checking */
    RT_DEBUG_NOT_IN_INTERRUPT;

    do
    {
        level = rt_hw_interrupt_disable();
        write_nbytes = rt_ringbuffer_put(&(pipe->ringbuffer), (const rt_uint8_t *)buffer, size);
        if (write_nbytes == 0)
        {
            /* pipe full, waiting on suspended write list */
            rt_thread_suspend(thread);
            /* waiting on suspended read list */
            rt_list_insert_before(&(pipe->suspended_write_list),
                                  &RT_THREAD_LIST_NODE(thread));
            rt_hw_interrupt_enable(level);

            rt_schedule();
        }
        else
        {
            _rt_audio_pipe_resume_reader(pipe);
            rt_hw_interrupt_enable(level);
            break;
        }