summary |
tags |
clone url |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
bb2bb66)
SCCS-vsn: sys/miscfs/fifofs/fifo_vnops.c 7.2
* IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
*
* IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
*
- * @(#)fifo_vnops.c 7.1 (Berkeley) %G%
+ * @(#)fifo_vnops.c 7.2 (Berkeley) %G%
register struct fifoinfo *fip;
struct socket *rso, *wso;
int error;
register struct fifoinfo *fip;
struct socket *rso, *wso;
int error;
+ static char openstr[] = "fifo";
if ((mode & (FREAD|FWRITE)) == (FREAD|FWRITE))
return (EINVAL);
if ((mode & (FREAD|FWRITE)) == (FREAD|FWRITE))
return (EINVAL);
if (mode & O_NONBLOCK)
return (0);
while (fip->fi_writers == 0)
if (mode & O_NONBLOCK)
return (0);
while (fip->fi_writers == 0)
- if (error = isleep((caddr_t)&fip->fi_readers, PZERO + 1,
- SLP_FIFO_OPEN, 0))
+ if (error = tsleep((caddr_t)&fip->fi_readers, PSOCK,
+ openstr, 0))
break;
} else {
fip->fi_writers++;
break;
} else {
fip->fi_writers++;
wakeup((caddr_t)&fip->fi_readers);
}
while (fip->fi_readers == 0)
wakeup((caddr_t)&fip->fi_readers);
}
while (fip->fi_readers == 0)
- if (error = isleep((caddr_t)&fip->fi_writers,
- PZERO + 1, SLP_FIFO_OPEN, 0))
+ if (error = tsleep((caddr_t)&fip->fi_writers,
+ PSOCK, openstr, 0))