Send SIGPIPE to the thread that issued the offending system call

rather than to the entire process.

Reported by:	Anit Chakraborty
Reviewed by:	kib, deischen (concept)
MFC after:	1 week
This commit is contained in:
jhb 2010-06-29 20:44:19 +00:00
parent df7979cf76
commit 44b49a3eaa
3 changed files with 5 additions and 5 deletions

View File

@ -532,7 +532,7 @@ dofilewrite(td, fd, fp, auio, offset, flags)
/* Socket layer is responsible for issuing SIGPIPE. */
if (fp->f_type != DTYPE_SOCKET && error == EPIPE) {
PROC_LOCK(td->td_proc);
psignal(td->td_proc, SIGPIPE);
tdsignal(td, SIGPIPE);
PROC_UNLOCK(td->td_proc);
}
}

View File

@ -102,7 +102,7 @@ soo_write(struct file *fp, struct uio *uio, struct ucred *active_cred,
error = sosend(so, 0, uio, 0, 0, 0, uio->uio_td);
if (error == EPIPE && (so->so_options & SO_NOSIGPIPE) == 0) {
PROC_LOCK(uio->uio_td->td_proc);
psignal(uio->uio_td->td_proc, SIGPIPE);
tdsignal(uio->uio_td, SIGPIPE);
PROC_UNLOCK(uio->uio_td->td_proc);
}
return (error);

View File

@ -794,7 +794,7 @@ kern_sendit(td, s, mp, flags, control, segflg)
if (error == EPIPE && !(so->so_options & SO_NOSIGPIPE) &&
!(flags & MSG_NOSIGNAL)) {
PROC_LOCK(td->td_proc);
psignal(td->td_proc, SIGPIPE);
tdsignal(td, SIGPIPE);
PROC_UNLOCK(td->td_proc);
}
}
@ -2444,7 +2444,7 @@ sctp_generic_sendmsg (td, uap)
if (error == EPIPE && !(so->so_options & SO_NOSIGPIPE) &&
!(uap->flags & MSG_NOSIGNAL)) {
PROC_LOCK(td->td_proc);
psignal(td->td_proc, SIGPIPE);
tdsignal(td, SIGPIPE);
PROC_UNLOCK(td->td_proc);
}
}
@ -2562,7 +2562,7 @@ sctp_generic_sendmsg_iov(td, uap)
if (error == EPIPE && !(so->so_options & SO_NOSIGPIPE) &&
!(uap->flags & MSG_NOSIGNAL)) {
PROC_LOCK(td->td_proc);
psignal(td->td_proc, SIGPIPE);
tdsignal(td, SIGPIPE);
PROC_UNLOCK(td->td_proc);
}
}