39     if (rt_data_queue_peak(&audio->replay->queue, &frame.data_ptr, &frame.data_size) != RT_EOK)  in _audio_send_replay_frame()
45         audio->replay->activated = RT_FALSE;  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()
72     if (audio->replay == RT_NULL)  in _audio_flush_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()
95     /* initialize replay & record */  in _audio_dev_init()
96     audio->replay = RT_NULL;  in _audio_dev_init()
126         if (audio->replay == RT_NULL)  in _audio_dev_open()
128 …struct rt_audio_replay *replay = (struct rt_audio_replay *) rt_malloc(sizeof(struct rt_audio_repla…  in _audio_dev_open()  local
130             if (replay == RT_NULL)  in _audio_dev_open()
132                 AUDIO_DBG("request memory for replay error\n");  in _audio_dev_open()
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()
139             replay->activated = RT_FALSE;  in _audio_dev_open()
140             audio->replay = replay;  in _audio_dev_open()
203         //stop replay stream  in _audio_dev_close()
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()
255     if (!(dev->open_flag & RT_DEVICE_OFLAG_WRONLY) || (audio->replay == RT_NULL))  in _audio_dev_write()
261         result = rt_data_queue_push(&audio->replay->queue, buffer, size,  in _audio_dev_write()
273     if (audio->replay->activated != RT_TRUE)  in _audio_dev_write()
275         audio->replay->activated = RT_TRUE;  in _audio_dev_write()
328             //flush replay frame...  in _audio_dev_control()
441     //init memory pool for replay  in rt_audio_register()