tools/android/forwarder2/pipe_notifier.cc

   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.
   4
   5 #include "tools/android/forwarder2/pipe_notifier.h"
   6
   7 #include <fcntl.h>
   8 #include <unistd.h>
   9 #include <sys/socket.h>
  10 #include <sys/types.h>
  11
  12 #include "base/logging.h"
  13 #include "base/posix/eintr_wrapper.h"
  14 #include "base/safe_strerror_posix.h"
  15
  16 namespace forwarder2 {
  17
  18 PipeNotifier::PipeNotifier() {
  19   int pipe_fd[2];
  20   int ret = pipe(pipe_fd);
  21   CHECK_EQ(0, ret);
  22   receiver_fd_ = pipe_fd[0];
  23   sender_fd_ = pipe_fd[1];
  24   fcntl(sender_fd_, F_SETFL, O_NONBLOCK);
  25 }
  26
  27 PipeNotifier::~PipeNotifier() {
  28   close(receiver_fd_);
  29   close(sender_fd_);
  30 }
  31
  32 bool PipeNotifier::Notify() {
  33   CHECK_NE(-1, sender_fd_);
  34   errno = 0;
  35   int ret = HANDLE_EINTR(write(sender_fd_, "1", 1));
  36   if (ret < 0) {
  37     PLOG(ERROR) << "write";
  38     return false;
  39   }
  40   return true;
  41 }
  42
  43 void PipeNotifier::Reset() {
  44   char c;
  45   int ret = HANDLE_EINTR(read(receiver_fd_, &c, 1));
  46   if (ret < 0) {
  47     PLOG(ERROR) << "read";
  48     return;
  49   }
  50   DCHECK_EQ(1, ret);
  51   DCHECK_EQ('1', c);
  52 }
  53
  54 }  // namespace forwarder