libs/rt-thread-official
libs
/
rt-thread-official
mirror of https://github.com/RT-Thread/rt-thread.git
4
0
Fork 0
Code Issues Releases Wiki Activity

Typo: rt_data_queue_peak() in dataqueue

This commit is contained in:
Meco Man 2020-12-31 16:02:42 +08:00
parent 4a4f00de6b
commit a233495718
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
components/drivers/audio/audio.c
View File

@ -45,7 +45,7 @@ static rt_err_t _audio_send_replay_frame(struct rt_audio_device *audio)
dst_size = buf_info->block_size; dst_size = buf_info->block_size;
/* check replay queue is empty */ /* check replay queue is empty */
if (rt_data_queue_peak(&audio->replay->queue, (const void **)&data, &src_size) != RT_EOK) if (rt_data_queue_peek(&audio->replay->queue, (const void **)&data, &src_size) != RT_EOK)
{ {
/* ack stop event */ /* ack stop event */
if (audio->replay->event & REPLAY_EVT_STOP) if (audio->replay->event & REPLAY_EVT_STOP)
@ -64,7 +64,7 @@ static rt_err_t _audio_send_replay_frame(struct rt_audio_device *audio)
/* copy data from memory pool to hardware device fifo */ /* copy data from memory pool to hardware device fifo */
while (index < dst_size) while (index < dst_size)
{ {
result = rt_data_queue_peak(&audio->replay->queue, (const void **)&data, &src_size); result = rt_data_queue_peek(&audio->replay->queue, (const void **)&data, &src_size);
if (result != RT_EOK) if (result != RT_EOK)
{ {
LOG_D("under run %d, remain %d", audio->replay->pos, remain_bytes); LOG_D("under run %d, remain %d", audio->replay->pos, remain_bytes);

2
components/drivers/include/ipc/dataqueue.h
View File

@ -55,7 +55,7 @@ rt_err_t rt_data_queue_pop(struct rt_data_queue *queue,
const void **data_ptr, const void **data_ptr,
rt_size_t *size, rt_size_t *size,
rt_int32_t timeout); rt_int32_t timeout);
rt_err_t rt_data_queue_peak(struct rt_data_queue *queue, rt_err_t rt_data_queue_peek(struct rt_data_queue *queue,
const void **data_ptr, const void **data_ptr,
rt_size_t *size); rt_size_t *size);
void rt_data_queue_reset(struct rt_data_queue *queue); void rt_data_queue_reset(struct rt_data_queue *queue);

2
components/drivers/serial/serial.c
View File

@ -1268,7 +1268,7 @@ void rt_hw_serial_isr(struct rt_serial_device *serial, int event)
tx_dma = (struct rt_serial_tx_dma*) serial->serial_tx; tx_dma = (struct rt_serial_tx_dma*) serial->serial_tx;
rt_data_queue_pop(&(tx_dma->data_queue), &last_data_ptr, &data_size, 0); rt_data_queue_pop(&(tx_dma->data_queue), &last_data_ptr, &data_size, 0);
if (rt_data_queue_peak(&(tx_dma->data_queue), &data_ptr, &data_size) == RT_EOK) if (rt_data_queue_peek(&(tx_dma->data_queue), &data_ptr, &data_size) == RT_EOK)
{ {
/* transmit next data node */ /* transmit next data node */
tx_dma->activated = RT_TRUE; tx_dma->activated = RT_TRUE;

4
components/drivers/src/dataqueue.c
View File

@ -264,7 +264,7 @@ __exit:
} }
RTM_EXPORT(rt_data_queue_pop); RTM_EXPORT(rt_data_queue_pop);
rt_err_t rt_data_queue_peak(struct rt_data_queue *queue, rt_err_t rt_data_queue_peek(struct rt_data_queue *queue,
const void** data_ptr, const void** data_ptr,
rt_size_t *size) rt_size_t *size)
{ {
@ -287,7 +287,7 @@ rt_err_t rt_data_queue_peak(struct rt_data_queue *queue,
return RT_EOK; return RT_EOK;
} }
RTM_EXPORT(rt_data_queue_peak); RTM_EXPORT(rt_data_queue_peek);
void rt_data_queue_reset(struct rt_data_queue *queue) void rt_data_queue_reset(struct rt_data_queue *queue)
{ {