| Index: ipc/ipc_channel_posix.cc
|
| diff --git a/ipc/ipc_channel_posix.cc b/ipc/ipc_channel_posix.cc
|
| index a74178a694b99dbaf4e759e30e195461a29d30ef..878853290016620a1276ce2707ed52b8a7fa7f9b 100644
|
| --- a/ipc/ipc_channel_posix.cc
|
| +++ b/ipc/ipc_channel_posix.cc
|
| @@ -206,9 +206,9 @@ bool SocketPair(int* fd1, int* fd2) {
|
| if (fcntl(pipe_fds[0], F_SETFL, O_NONBLOCK) == -1 ||
|
| fcntl(pipe_fds[1], F_SETFL, O_NONBLOCK) == -1) {
|
| PLOG(ERROR) << "fcntl(O_NONBLOCK)";
|
| - if (HANDLE_EINTR(close(pipe_fds[0])) < 0)
|
| + if (IGNORE_EINTR(close(pipe_fds[0])) < 0)
|
| PLOG(ERROR) << "close";
|
| - if (HANDLE_EINTR(close(pipe_fds[1])) < 0)
|
| + if (IGNORE_EINTR(close(pipe_fds[1])) < 0)
|
| PLOG(ERROR) << "close";
|
| return false;
|
| }
|
| @@ -547,7 +547,7 @@ void Channel::ChannelImpl::CloseClientFileDescriptor() {
|
| base::AutoLock lock(client_pipe_lock_);
|
| if (client_pipe_ != -1) {
|
| PipeMap::GetInstance()->Remove(pipe_name_);
|
| - if (HANDLE_EINTR(close(client_pipe_)) < 0)
|
| + if (IGNORE_EINTR(close(client_pipe_)) < 0)
|
| PLOG(ERROR) << "close " << pipe_name_;
|
| client_pipe_ = -1;
|
| }
|
| @@ -571,18 +571,18 @@ void Channel::ChannelImpl::ResetToAcceptingConnectionState() {
|
| read_watcher_.StopWatchingFileDescriptor();
|
| write_watcher_.StopWatchingFileDescriptor();
|
| if (pipe_ != -1) {
|
| - if (HANDLE_EINTR(close(pipe_)) < 0)
|
| + if (IGNORE_EINTR(close(pipe_)) < 0)
|
| PLOG(ERROR) << "close pipe_ " << pipe_name_;
|
| pipe_ = -1;
|
| }
|
| #if defined(IPC_USES_READWRITE)
|
| if (fd_pipe_ != -1) {
|
| - if (HANDLE_EINTR(close(fd_pipe_)) < 0)
|
| + if (IGNORE_EINTR(close(fd_pipe_)) < 0)
|
| PLOG(ERROR) << "close fd_pipe_ " << pipe_name_;
|
| fd_pipe_ = -1;
|
| }
|
| if (remote_fd_pipe_ != -1) {
|
| - if (HANDLE_EINTR(close(remote_fd_pipe_)) < 0)
|
| + if (IGNORE_EINTR(close(remote_fd_pipe_)) < 0)
|
| PLOG(ERROR) << "close remote_fd_pipe_ " << pipe_name_;
|
| remote_fd_pipe_ = -1;
|
| }
|
| @@ -602,7 +602,7 @@ void Channel::ChannelImpl::ResetToAcceptingConnectionState() {
|
| for (std::set<int>::iterator i = fds_to_close_.begin();
|
| i != fds_to_close_.end();
|
| ++i) {
|
| - if (HANDLE_EINTR(close(*i)) < 0)
|
| + if (IGNORE_EINTR(close(*i)) < 0)
|
| PLOG(ERROR) << "close";
|
| }
|
| fds_to_close_.clear();
|
| @@ -637,7 +637,7 @@ void Channel::ChannelImpl::OnFileCanReadWithoutBlocking(int fd) {
|
| // close our new descriptor.
|
| if (HANDLE_EINTR(shutdown(new_pipe, SHUT_RDWR)) < 0)
|
| DPLOG(ERROR) << "shutdown " << pipe_name_;
|
| - if (HANDLE_EINTR(close(new_pipe)) < 0)
|
| + if (IGNORE_EINTR(close(new_pipe)) < 0)
|
| DPLOG(ERROR) << "close " << pipe_name_;
|
| listener()->OnChannelDenied();
|
| return;
|
| @@ -927,7 +927,7 @@ bool Channel::ChannelImpl::ExtractFileDescriptorsFromMsghdr(msghdr* msg) {
|
|
|
| void Channel::ChannelImpl::ClearInputFDs() {
|
| for (size_t i = 0; i < input_fds_.size(); ++i) {
|
| - if (HANDLE_EINTR(close(input_fds_[i])) < 0)
|
| + if (IGNORE_EINTR(close(input_fds_[i])) < 0)
|
| PLOG(ERROR) << "close ";
|
| }
|
| input_fds_.clear();
|
| @@ -996,7 +996,7 @@ void Channel::ChannelImpl::HandleInternalMessage(const Message& msg) {
|
| NOTREACHED();
|
| if (hops == 0) {
|
| if (fds_to_close_.erase(fd) > 0) {
|
| - if (HANDLE_EINTR(close(fd)) < 0)
|
| + if (IGNORE_EINTR(close(fd)) < 0)
|
| PLOG(ERROR) << "close";
|
| } else {
|
| NOTREACHED();
|
| @@ -1020,7 +1020,7 @@ void Channel::ChannelImpl::Close() {
|
| must_unlink_ = false;
|
| }
|
| if (server_listen_pipe_ != -1) {
|
| - if (HANDLE_EINTR(close(server_listen_pipe_)) < 0)
|
| + if (IGNORE_EINTR(close(server_listen_pipe_)) < 0)
|
| DPLOG(ERROR) << "close " << server_listen_pipe_;
|
| server_listen_pipe_ = -1;
|
| // Unregister libevent for the listening socket and close it.
|
|
|