diff options
| -rw-r--r-- | chrome/common/ipc_channel.cc | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/chrome/common/ipc_channel.cc b/chrome/common/ipc_channel.cc index 8c0612e..a9d73e7 100644 --- a/chrome/common/ipc_channel.cc +++ b/chrome/common/ipc_channel.cc @@ -52,8 +52,15 @@ Channel::Channel(const wstring& channel_id, Mode mode, Listener* listener) void Channel::Close() { // make sure we are no longer watching the pipe events MessageLoopForIO* loop = MessageLoopForIO::current(); - loop->WatchObject(input_state_.overlapped.hEvent, NULL); - loop->WatchObject(output_state_.overlapped.hEvent, NULL); + if (input_state_.is_pending) { + input_state_.is_pending = false; + loop->RegisterIOContext(&input_state_.overlapped, NULL); + } + + if (output_state_.is_pending) { + output_state_.is_pending = false; + loop->RegisterIOContext(&output_state_.overlapped, NULL); + } if (pipe_ != INVALID_HANDLE_VALUE) { CloseHandle(pipe_); |