diff options
author | hubbe@chromium.org <hubbe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-02-21 00:18:29 +0000 |
---|---|---|
committer | hubbe@chromium.org <hubbe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-02-21 00:18:29 +0000 |
commit | 0e8a7916cb24dc7617d254b3d4bd48441fb7723a (patch) | |
tree | 53d0201fce5e7a54a0161ffbf84f2c83e29c7a28 /ipc/ipc_channel_posix.cc | |
parent | 40e0d75498a18c96285416302b0fb6318dbc0997 (diff) | |
download | chromium_src-0e8a7916cb24dc7617d254b3d4bd48441fb7723a.zip chromium_src-0e8a7916cb24dc7617d254b3d4bd48441fb7723a.tar.gz chromium_src-0e8a7916cb24dc7617d254b3d4bd48441fb7723a.tar.bz2 |
Fix posix IPC channel hanging problem.
If a channel closes right before a send call, listeners might not be notified of
the problem, which can cause hangs. This CL fixes that and adds a test that makes
sure that this does not happen in the future.
This is similar to cl/150893002, but takes a slightly different approach to how to
make sure everything happens in the right order. In particular, it avoids closing
the socket (and calling OnChannelError()) from Send().
BUG=338709
Review URL: https://codereview.chromium.org/172773002
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@252430 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'ipc/ipc_channel_posix.cc')
-rw-r--r-- | ipc/ipc_channel_posix.cc | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/ipc/ipc_channel_posix.cc b/ipc/ipc_channel_posix.cc index 8788532..2bd0989 100644 --- a/ipc/ipc_channel_posix.cc +++ b/ipc/ipc_channel_posix.cc @@ -327,7 +327,7 @@ bool Channel::ChannelImpl::CreatePipe( bool Channel::ChannelImpl::Connect() { if (server_listen_pipe_ == -1 && pipe_ == -1) { - DLOG(INFO) << "Channel creation failed: " << pipe_name_; + DLOG(WARNING) << "Channel creation failed: " << pipe_name_; return false; } @@ -464,15 +464,19 @@ bool Channel::ChannelImpl::ProcessOutgoingMessages() { CloseFileDescriptors(msg); if (bytes_written < 0 && !SocketWriteErrorIsRecoverable()) { + // We can't close the pipe here, because calling OnChannelError + // may destroy this object, and that would be bad if we are + // called from Send(). Instead, we return false and hope the + // caller will close the pipe. If they do not, the pipe will + // still be closed next time OnFileCanReadWithoutBlocking is + // called. #if defined(OS_MACOSX) // On OSX writing to a pipe with no listener returns EPERM. if (errno == EPERM) { - Close(); return false; } #endif // OS_MACOSX if (errno == EPIPE) { - Close(); return false; } PLOG(ERROR) << "pipe error on " @@ -680,7 +684,7 @@ void Channel::ChannelImpl::OnFileCanReadWithoutBlocking(int fd) { // If we're a server and handshaking, then we want to make sure that we // only send our handshake message after we've processed the client's. // This gives us a chance to kill the client if the incoming handshake - // is invalid. This also flushes any closefd messagse. + // is invalid. This also flushes any closefd messages. if (!is_blocked_on_write_) { if (!ProcessOutgoingMessages()) { ClosePipeOnError(); |