AsyncPipeTest.cpp File Reference

#include <folly/io/async/AsyncPipe.h>
#include <folly/Memory.h>
#include <folly/io/async/EventBase.h>
#include <folly/portability/GTest.h>
#include <fcntl.h>

Go to the source code of this file.

Functions
	TEST_F (AsyncPipeTest, simple)
	TEST_F (AsyncPipeTest, blocked_writes)
	TEST_F (AsyncPipeTest, writeOnClose)

Function Documentation

TEST_F	(	AsyncPipeTest	,
		simple
	)

Definition at line 129 of file AsyncPipeTest.cpp.

References EXPECT_EQ, and EXPECT_FALSE.

                              {
  for (int pass = 0; pass < 2; ++pass) {
    reset(pass % 2 != 0);
    reader_->setReadCB(&readCallback_);
    writer_->write(getBuf("hello"), &writeCallback_);
    writer_->closeOnEmpty();
    eventBase_.loop();
    EXPECT_EQ(readCallback_.getData(), "hello");
    EXPECT_FALSE(readCallback_.error_);
    EXPECT_EQ(writeCallback_.writes_, 1);
    EXPECT_FALSE(writeCallback_.error_);
  }
}

TEST_F	(	AsyncPipeTest	,
		blocked_writes
	)

Definition at line 143 of file AsyncPipeTest.cpp.

References EXPECT_EQ, EXPECT_FALSE, i, string, and uint32_t.

                                      {
  for (int pass = 0; pass < 2; ++pass) {
    reset(pass % 2 != 0);
    uint32_t writeAttempts = 0;
    do {
      ++writeAttempts;
      writer_->write(getBuf("hello"), &writeCallback_);
    } while (writeCallback_.writes_ == writeAttempts);
    // there is one blocked write
    writer_->closeOnEmpty();

    reader_->setReadCB(&readCallback_);

    eventBase_.loop();
    std::string expected;
    for (uint32_t i = 0; i < writeAttempts; i++) {
      expected += "hello";
    }
    EXPECT_EQ(readCallback_.getData(), expected);
    EXPECT_FALSE(readCallback_.error_);
    EXPECT_EQ(writeCallback_.writes_, writeAttempts);
    EXPECT_FALSE(writeCallback_.error_);
  }
}

TEST_F	(	AsyncPipeTest	,
		writeOnClose
	)

Definition at line 168 of file AsyncPipeTest.cpp.

References EXPECT_EQ, EXPECT_FALSE, and EXPECT_TRUE.

                                    {
  for (int pass = 0; pass < 2; ++pass) {
    reset(pass % 2 != 0);
    reader_->setReadCB(&readCallback_);
    writer_->write(getBuf("hello"), &writeCallback_);
    writer_->closeOnEmpty();
    writer_->write(getBuf("hello"), &writeCallback_);
    eventBase_.loop();
    EXPECT_EQ(readCallback_.getData(), "hello");
    EXPECT_FALSE(readCallback_.error_);
    EXPECT_EQ(writeCallback_.writes_, 1);
    EXPECT_TRUE(writeCallback_.error_);
  }
}