Function TCPTest

UnitTests/sources/SocketTest.cpp:259–311

};

void TCPTest(SocketManager& sockets) {

	TCPServer server(sockets);
	list<TCPConnection> connections;

	TCPServer::OnError::Type onError = [](const Exception& ex) {
		FATAL_ERROR("TCPServer, ",ex.error());
	};
	TCPServer::OnConnection::Type onConnection = [&](Exception& ex, const SocketAddress& address, SocketFile& file) {
		CHECK(address && file);
		connections.emplace_back(address, file, sockets);
	};
	server.OnError::subscribe(onError);
	server.OnConnection::subscribe(onConnection);

	Exception ex;
	SocketAddress host(IPAddress::Wildcard(),62435);

	CHECK(server.start(ex, host) && !ex);
	server.stop();
	CHECK(server.start(ex, host) && !ex);

	TCPEchoClient client(sockets, &sockets == &ParallelSockets);
	SocketAddress target(IPAddress::Loopback(),host.port());
	CHECK(client.connect(ex, target) && !ex && client.connected());
	CHECK(client.echo(ex,BIN EXPAND("hi mathieu and thomas")) && !ex);
	CHECK(client.echo(ex,BIN Long0Data.c_str(),Long0Data.size()) && !ex);
	CHECK(TaskSockets.join(client));

	client.testDisconnection = true;

	client.disconnect();

	CHECK(TaskSockets.join(client));

	// Test an unknown connection
	SocketAddress unknown(IPAddress::Loopback(),62434);
	if (client.connect(ex, unknown)) {
		CHECK(!ex)
		if (!client.parallel) {
			CHECK(client.connected());
			CHECK(client.address());
			CHECK(client.peerAddress()==unknown);
			CHECK(client.send(ex, BIN EXPAND("salut")) && !ex)
			CHECK(client.connected());
		}
		CHECK(TaskSockets.join(client));
	}
	CHECK(!client.connected());

	server.OnError::unsubscribe(onError);
	server.OnConnection::unsubscribe(onConnection);
}

void UDPTest(SocketManager& sockets) {
	UDPSocket    server(sockets);