AsyncSocketGSOIntegrationTest Class Reference

Inheritance diagram for AsyncSocketGSOIntegrationTest:

Public Member Functions
void	SetUp () override
void	startServer ()
void	TearDown () override
std::unique_ptr< UDPClient >	performPingPongTest (TestData &testData, folly::Optional< folly::SocketAddress > connectedAddress)
Public Member Functions inherited from testing::Test
virtual	~Test ()
virtual	~Test ()
virtual	~Test ()

Public Attributes
folly::EventBase	sevb
folly::EventBase	cevb
TestData *	testData_ {nullptr}
std::unique_ptr< std::thread >	serverThread
std::unique_ptr< UDPServer >	server
std::unique_ptr< UDPClient >	client

Additional Inherited Members
Public Types inherited from testing::Test
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc
typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc
typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc
typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc
Static Public Member Functions inherited from testing::Test
static void	SetUpTestCase ()
static void	TearDownTestCase ()
static bool	HasFatalFailure ()
static bool	HasNonfatalFailure ()
static bool	HasFailure ()
static void	RecordProperty (const std::string &key, const std::string &value)
static void	RecordProperty (const std::string &key, int value)
static void	SetUpTestCase ()
static void	TearDownTestCase ()
static bool	HasFatalFailure ()
static bool	HasNonfatalFailure ()
static bool	HasFailure ()
static void	RecordProperty (const std::string &key, const std::string &value)
static void	RecordProperty (const std::string &key, int value)
static void	SetUpTestCase ()
static void	TearDownTestCase ()
static bool	HasFatalFailure ()
static bool	HasNonfatalFailure ()
static bool	HasFailure ()
static void	RecordProperty (const std::string &key, const std::string &value)
static void	RecordProperty (const std::string &key, int value)
Protected Member Functions inherited from testing::Test
	Test ()
	Test ()
	Test ()

Detailed Description

Definition at line 306 of file AsyncUDPSocketGSOTest.cpp.

Member Function Documentation

std::unique_ptr< UDPClient > AsyncSocketGSOIntegrationTest::performPingPongTest	(	TestData &	testData,
		folly::Optional< folly::SocketAddress >	connectedAddress
	)

Definition at line 349 of file AsyncUDPSocketGSOTest.cpp.

References folly::gen::move.

                                                        {
  testData_ = &testData;

  client = std::make_unique<UDPClient>(&cevb, testData);
  if (connectedAddress) {
    client->setShouldConnect(*connectedAddress);
  }

  // Start event loop in a separate thread
  auto clientThread = std::thread([this]() { cevb.loopForever(); });

  // Wait for event loop to start
  cevb.waitUntilRunning();

  // Send ping
  cevb.runInEventBaseThread([&]() { client->start(server->address()); });

  // Wait for client to finish
  clientThread.join();
  return std::move(client);
}

void AsyncSocketGSOIntegrationTest::SetUp ( )

inlineoverridevirtual

Reimplemented from testing::Test.

Definition at line 308 of file AsyncUDPSocketGSOTest.cpp.

                        {
    server = std::make_unique<UDPServer>(
        &sevb, folly::SocketAddress("127.0.0.1", 0), 1);

    // Start event loop in a separate thread
    serverThread =
        std::make_unique<std::thread>([this]() { sevb.loopForever(); });

    // Wait for event loop to start
    sevb.waitUntilRunning();
  }

void AsyncSocketGSOIntegrationTest::startServer ( )

inline

Definition at line 320 of file AsyncUDPSocketGSOTest.cpp.

                     {
    // Start the server
    sevb.runInEventBaseThreadAndWait([&]() { server->start(); });
    LOG(INFO) << "Server listening=" << server->address();
  }

void AsyncSocketGSOIntegrationTest::TearDown ( )

inlineoverridevirtual

Reimplemented from testing::Test.

Definition at line 326 of file AsyncUDPSocketGSOTest.cpp.

                           {
    // Shutdown server
    sevb.runInEventBaseThread([&]() {
      server->shutdown();
      sevb.terminateLoopSoon();
    });

    // Wait for server thread to join
    serverThread->join();
  }

Member Data Documentation

folly::EventBase AsyncSocketGSOIntegrationTest::cevb

Definition at line 342 of file AsyncUDPSocketGSOTest.cpp.

std::unique_ptr<UDPClient> AsyncSocketGSOIntegrationTest::client

Definition at line 346 of file AsyncUDPSocketGSOTest.cpp.

std::unique_ptr<UDPServer> AsyncSocketGSOIntegrationTest::server

Definition at line 345 of file AsyncUDPSocketGSOTest.cpp.

std::unique_ptr<std::thread> AsyncSocketGSOIntegrationTest::serverThread

Definition at line 344 of file AsyncUDPSocketGSOTest.cpp.

folly::EventBase AsyncSocketGSOIntegrationTest::sevb

Definition at line 341 of file AsyncUDPSocketGSOTest.cpp.

TestData* AsyncSocketGSOIntegrationTest::testData_ {nullptr}

Definition at line 343 of file AsyncUDPSocketGSOTest.cpp.

---

The documentation for this class was generated from the following file:

• proxygen/folly/folly/io/async/test/AsyncUDPSocketGSOTest.cpp