Function TEST_F

3rdparty/libprocess/src/tests/io_tests.cpp:43–73

TEST_F(IOTest, PollRead)
{
  Try<std::array<int_fd, 2>> pipes = os::pipe();
  ASSERT_SOME(pipes);
  ASSERT_SOME(io::prepare_async((*pipes)[0]));
  ASSERT_SOME(io::prepare_async((*pipes)[1]));

  // Test discard when polling.
  Future<short> future = io::poll((*pipes)[0], io::READ);
  EXPECT_TRUE(future.isPending());
  future.discard();
  AWAIT_DISCARDED(future);

  // Test successful polling.
  future = io::poll((*pipes)[0], io::READ);

  // This is not sufficient for ensuring the event loop does
  // not detect readiness, since it's happening asynchronously
  // in the kernel.
  Clock::pause();
  Clock::settle();
  Clock::resume();

  EXPECT_TRUE(future.isPending());

  ASSERT_EQ(2, write((*pipes)[1], "hi", 2));
  AWAIT_EXPECT_EQ(io::READ, future);

  ASSERT_SOME(os::close((*pipes)[0]));
  ASSERT_SOME(os::close((*pipes)[1]));
}


// We do not support write readiness polling on Windows