UnitTests: Rename .cpp (it was confusing the debugger)
This commit is contained in:
84
tests/Engine/Network/SocketPollerTest.cpp
Normal file
84
tests/Engine/Network/SocketPollerTest.cpp
Normal file
@@ -0,0 +1,84 @@
|
||||
#include <Nazara/Math/Vector3.hpp>
|
||||
#include <Nazara/Network/NetPacket.hpp>
|
||||
#include <Nazara/Network/SocketPoller.hpp>
|
||||
#include <Nazara/Network/TcpClient.hpp>
|
||||
#include <Nazara/Network/TcpServer.hpp>
|
||||
#include <Catch/catch.hpp>
|
||||
#include <random>
|
||||
|
||||
SCENARIO("SocketPoller", "[NETWORK][SOCKETPOLLER]")
|
||||
{
|
||||
GIVEN("A TcpServer and a TcpClient in a selector")
|
||||
{
|
||||
std::random_device rd;
|
||||
std::uniform_int_distribution<Nz::UInt16> dis(1025, 65535);
|
||||
|
||||
Nz::UInt16 port = dis(rd);
|
||||
Nz::TcpServer server;
|
||||
server.EnableBlocking(false);
|
||||
|
||||
REQUIRE(server.Listen(Nz::NetProtocol::IPv4, port) == Nz::SocketState::Bound);
|
||||
|
||||
Nz::IpAddress serverIP(Nz::IpAddress::LoopbackIpV4.ToIPv4(), port);
|
||||
REQUIRE(serverIP.IsValid());
|
||||
|
||||
Nz::SocketPoller serverPoller;
|
||||
Nz::TcpClient clientToServer;
|
||||
|
||||
WHEN("We register the server socket to the poller")
|
||||
{
|
||||
REQUIRE(serverPoller.RegisterSocket(server, Nz::SocketPollEvent::Read));
|
||||
|
||||
THEN("The poller should have registered our socket")
|
||||
{
|
||||
REQUIRE(serverPoller.IsRegistered(server));
|
||||
}
|
||||
AND_THEN("We connect using a TcpClient")
|
||||
{
|
||||
Nz::SocketState state = clientToServer.Connect(serverIP);
|
||||
|
||||
CHECK(state != Nz::SocketState::NotConnected);
|
||||
|
||||
AND_THEN("We wait on our selector, it should return true")
|
||||
{
|
||||
REQUIRE(serverPoller.Wait(1000));
|
||||
|
||||
Nz::TcpClient serverToClient;
|
||||
REQUIRE(server.AcceptClient(&serverToClient));
|
||||
|
||||
WHEN("We register the client socket to the poller")
|
||||
{
|
||||
REQUIRE(serverPoller.RegisterSocket(serverToClient, Nz::SocketPollEvent::Read));
|
||||
|
||||
THEN("The poller should have registered our socket")
|
||||
{
|
||||
REQUIRE(serverPoller.IsRegistered(serverToClient));
|
||||
}
|
||||
|
||||
AND_WHEN("We test sending data from the client to the server and checking the poller")
|
||||
{
|
||||
std::array<char, 5> buffer = {"Data"};
|
||||
|
||||
std::size_t sent;
|
||||
REQUIRE(clientToServer.Send(buffer.data(), buffer.size(), &sent));
|
||||
REQUIRE(sent == buffer.size());
|
||||
|
||||
REQUIRE(serverPoller.Wait(1000));
|
||||
|
||||
CHECK(serverPoller.IsReadyToRead(serverToClient));
|
||||
|
||||
CHECK(serverToClient.Read(buffer.data(), buffer.size()) == sent);
|
||||
|
||||
AND_THEN("Our selector should report no socket ready")
|
||||
{
|
||||
REQUIRE_FALSE(serverPoller.Wait(100));
|
||||
|
||||
REQUIRE_FALSE(serverPoller.IsReadyToRead(serverToClient));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user