Lines Matching full:queue
38 //check repaly queue is empty in _audio_send_replay_frame()
39 if (rt_data_queue_peak(&audio->replay->queue, &frame.data_ptr, &frame.data_size) != RT_EOK) in _audio_send_replay_frame()
41 AUDIO_DBG("TX queue is empty\n"); in _audio_send_replay_frame()
63 rt_data_queue_pop(&audio->replay->queue, &frame.data_ptr, &frame.data_size, RT_WAITING_FOREVER); in _audio_send_replay_frame()
74 while (rt_data_queue_peak(&audio->replay->queue, &frame.data_ptr, &frame.data_size) == RT_EOK) in _audio_flush_replay_frame()
77 … rt_data_queue_pop(&audio->replay->queue, &frame.data_ptr, &frame.data_size, RT_WAITING_FOREVER); in _audio_flush_replay_frame()
136 //init queue for audio replay in _audio_dev_open()
137 …rt_data_queue_init(&replay->queue, CFG_AUDIO_REPLAY_QUEUE_COUNT, CFG_AUDIO_REPLAY_QUEUE_COUNT / 2,… in _audio_dev_open()
207 … while (rt_data_queue_peak(&audio->replay->queue, &frame.data_ptr, &frame.data_size) == RT_EOK) in _audio_dev_close()
210 … rt_data_queue_pop(&audio->replay->queue, &frame.data_ptr, &frame.data_size, RT_WAITING_FOREVER); in _audio_dev_close()
259 //push a new frame to tx queue in _audio_dev_write()
261 result = rt_data_queue_push(&audio->replay->queue, buffer, size, in _audio_dev_write()
265 AUDIO_DBG("TX frame queue push error\n"); in _audio_dev_write()