AsyncSocketIntegrationTest Class Reference

Inheritance diagram for AsyncSocketIntegrationTest:

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

Public Attributes
folly::EventBase	sevb
folly::EventBase	cevb
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 325 of file AsyncUDPSocketTest.cpp.

Member Function Documentation

std::unique_ptr< UDPClient > AsyncSocketIntegrationTest::performPingPongTest	(	folly::Optional< folly::SocketAddress >	connectedAddress,
		bool	useConnectedWrite
	)

Definition at line 367 of file AsyncUDPSocketTest.cpp.

References folly::Optional< Value >::hasValue(), and folly::gen::move.

                            {
  if (useConnectedWrite) {
    CHECK(connectedAddress.hasValue());
    client = std::make_unique<ConnectedWriteUDPClient>(&cevb);
    client->setShouldConnect(*connectedAddress);
  } else {
    client = std::make_unique<UDPClient>(&cevb);
    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(), 100); });

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

void AsyncSocketIntegrationTest::SetUp ( )

inlineoverridevirtual

Reimplemented from testing::Test.

Definition at line 327 of file AsyncUDPSocketTest.cpp.

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

    // 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 AsyncSocketIntegrationTest::startServer ( )

inline

Definition at line 339 of file AsyncUDPSocketTest.cpp.

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

void AsyncSocketIntegrationTest::TearDown ( )

inlineoverridevirtual

Reimplemented from testing::Test.

Definition at line 345 of file AsyncUDPSocketTest.cpp.

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

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

Member Data Documentation

folly::EventBase AsyncSocketIntegrationTest::cevb

Definition at line 361 of file AsyncUDPSocketTest.cpp.

std::unique_ptr<UDPClient> AsyncSocketIntegrationTest::client

Definition at line 364 of file AsyncUDPSocketTest.cpp.

std::unique_ptr<UDPServer> AsyncSocketIntegrationTest::server

Definition at line 363 of file AsyncUDPSocketTest.cpp.

std::unique_ptr<std::thread> AsyncSocketIntegrationTest::serverThread

Definition at line 362 of file AsyncUDPSocketTest.cpp.

folly::EventBase AsyncSocketIntegrationTest::sevb

Definition at line 360 of file AsyncUDPSocketTest.cpp.

---

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

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