Mirrors_Framework/nuttx
1
0
Fork 0
mirror of https://github.com/apache/nuttx.git synced 2026-06-06 00:14:22 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

pipe: pipe close should notify block writting, and write will return -EPIPE

Browse Source 
Change-Id: I1d1d1be618b6cc423e14f94c7028c3406e7de5a6
Signed-off-by: ligd <liguiding1@xiaomi.com>
This commit is contained in:
ligd
2021-10-20 12:25:30 +08:00
committed by liguiding1
parent 89289e6014
commit 1952a1cf95
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
drivers/pipes/pipe_common.c
+9
View File
@@ -346,6 +346,10 @@ int pipecommon_close(FAR struct file *filep)
/* Inform poll writers that other end closed. */ /* Inform poll writers that other end closed. */
pipecommon_pollnotify(dev, POLLERR); pipecommon_pollnotify(dev, POLLERR);
while (nxsem_get_value(&dev->d_wrsem, &sval) == 0 && sval < 0)
{
nxsem_post(&dev->d_wrsem);
}
} }
} }
} }
@@ -654,6 +658,11 @@ ssize_t pipecommon_write(FAR struct file *filep, FAR const char *buffer,
ret = nxsem_wait(&dev->d_wrsem); ret = nxsem_wait(&dev->d_wrsem);
sched_unlock(); sched_unlock();
if (dev->d_nreaders <= 0)
{
ret = -EPIPE;
}
if (ret < 0 || (ret = nxsem_wait(&dev->d_bfsem)) < 0) if (ret < 0 || (ret = nxsem_wait(&dev->d_bfsem)) < 0)
{ {
/* Either call nxsem_wait may fail because a signal was /* Either call nxsem_wait may fail because a signal was