diff options
| author | Bernard Xiong <[email protected]> | 2018-06-26 11:19:38 +0800 |
|---|---|---|
| committer | Bernard Xiong <[email protected]> | 2018-06-26 11:19:38 +0800 |
| commit | a1a56ce1d1161ad361d421077472f922fe8fb7a7 (patch) | |
| tree | e05cf7dc63115cd87e5b2b0486da07e24c077397 /components/drivers/src/pipe.c | |
| parent | 6ecdfca2cde50e2974bdb5cda2995a64407c8818 (diff) | |
[Kernel] Add flag in wait queue and fix wakeup issue.
Diffstat (limited to 'components/drivers/src/pipe.c')
| -rw-r--r-- | components/drivers/src/pipe.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/components/drivers/src/pipe.c b/components/drivers/src/pipe.c index 09264ffbe3..973898e2cc 100644 --- a/components/drivers/src/pipe.c +++ b/components/drivers/src/pipe.c @@ -438,8 +438,8 @@ rt_pipe_t *rt_pipe_create(const char *name, int bufsz) rt_memset(pipe, 0, sizeof(rt_pipe_t)); rt_mutex_init(&(pipe->lock), name, RT_IPC_FLAG_FIFO); - rt_list_init(&(pipe->reader_queue)); - rt_list_init(&(pipe->writer_queue)); + rt_wqueue_init(&(pipe->reader_queue)); + rt_wqueue_init(&(pipe->writer_queue)); RT_ASSERT(bufsz < 0xFFFF); pipe->bufsz = bufsz; |