1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "tools/android/forwarder2/pipe_notifier.h"
9 #include <sys/socket.h>
10 #include <sys/types.h>
12 #include "base/logging.h"
13 #include "base/posix/eintr_wrapper.h"
14 #include "base/safe_strerror_posix.h"
16 namespace forwarder2
{
18 PipeNotifier::PipeNotifier() {
20 int ret
= pipe(pipe_fd
);
22 receiver_fd_
= pipe_fd
[0];
23 sender_fd_
= pipe_fd
[1];
24 fcntl(sender_fd_
, F_SETFL
, O_NONBLOCK
);
27 PipeNotifier::~PipeNotifier() {
28 (void) HANDLE_EINTR(close(receiver_fd_
));
29 (void) HANDLE_EINTR(close(sender_fd_
));
32 bool PipeNotifier::Notify() {
33 CHECK_NE(-1, sender_fd_
);
35 int ret
= HANDLE_EINTR(write(sender_fd_
, "1", 1));
37 LOG(WARNING
) << "Error while notifying pipe. " << safe_strerror(errno
);
43 } // namespace forwarder