diff options
Diffstat (limited to '')
-rw-r--r-- | cpukit/libfs/src/pipe/fifo.c | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/cpukit/libfs/src/pipe/fifo.c b/cpukit/libfs/src/pipe/fifo.c index d306c00395..38b90ed36e 100644 --- a/cpukit/libfs/src/pipe/fifo.c +++ b/cpukit/libfs/src/pipe/fifo.c @@ -104,6 +104,8 @@ static int pipe_alloc( if (! pipe->Buffer) goto err_buf; + err = -ENOMEM; + if (rtems_barrier_create( rtems_build_name ('P', 'I', 'r', c), RTEMS_BARRIER_MANUAL_RELEASE, 0, @@ -342,15 +344,17 @@ int fifo_open( break; case LIBIO_FLAGS_WRITE: + pipe->writerCounter ++; + + if (pipe->Writers ++ == 0) + PIPE_WAKEUPREADERS(pipe); + if (pipe->Readers == 0 && LIBIO_NODELAY(iop)) { + PIPE_UNLOCK(pipe); err = -ENXIO; goto out_error; } - pipe->writerCounter ++; - if (pipe->Writers ++ == 0) - PIPE_WAKEUPREADERS(pipe); - if (pipe->Readers == 0) { prevCounter = pipe->readerCounter; err = -EINTR; |