mirror of
https://github.com/vcmi/vcmi.git
synced 2025-03-21 21:17:49 +02:00
d9244cf061
This removes need for TCP network connection in single-player games. Instead, game will now create internal pseudo-connection that performs client<->server communication by posting sent messages to client/server asio::io_service'a. This should fix gameplay aborting on switching to another app on iOS (and apparently, on Android in some cases)
78 lines
2.3 KiB
C++
78 lines
2.3 KiB
C++
/*
|
|
* NetworkServer.cpp, part of VCMI engine
|
|
*
|
|
* Authors: listed in file AUTHORS in main folder
|
|
*
|
|
* License: GNU General Public License v2.0 or later
|
|
* Full text of license available in license.txt file, in main folder
|
|
*
|
|
*/
|
|
#include "StdInc.h"
|
|
#include "NetworkServer.h"
|
|
#include "NetworkConnection.h"
|
|
|
|
VCMI_LIB_NAMESPACE_BEGIN
|
|
|
|
NetworkServer::NetworkServer(INetworkServerListener & listener, const std::shared_ptr<NetworkContext> & context)
|
|
: io(context)
|
|
, listener(listener)
|
|
{
|
|
}
|
|
|
|
uint16_t NetworkServer::start(uint16_t port)
|
|
{
|
|
acceptor = std::make_shared<NetworkAcceptor>(*io, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), port));
|
|
return startAsyncAccept();
|
|
}
|
|
|
|
uint16_t NetworkServer::startAsyncAccept()
|
|
{
|
|
auto upcomingConnection = std::make_shared<NetworkSocket>(*io);
|
|
acceptor->async_accept(*upcomingConnection, [this, upcomingConnection](const auto & ec) { connectionAccepted(upcomingConnection, ec); });
|
|
return acceptor->local_endpoint().port();
|
|
}
|
|
|
|
void NetworkServer::connectionAccepted(std::shared_ptr<NetworkSocket> upcomingConnection, const boost::system::error_code & ec)
|
|
{
|
|
if(ec)
|
|
{
|
|
throw std::runtime_error("Something wrong during accepting: " + ec.message());
|
|
}
|
|
|
|
logNetwork->info("We got a new connection! :)");
|
|
auto connection = std::make_shared<NetworkConnection>(*this, upcomingConnection, io);
|
|
connections.insert(connection);
|
|
connection->start();
|
|
listener.onNewConnection(connection);
|
|
startAsyncAccept();
|
|
}
|
|
|
|
void NetworkServer::onDisconnected(const std::shared_ptr<INetworkConnection> & connection, const std::string & errorMessage)
|
|
{
|
|
logNetwork->info("Connection lost! Reason: %s", errorMessage);
|
|
if (connections.count(connection))
|
|
{
|
|
connections.erase(connection);
|
|
listener.onDisconnected(connection, errorMessage);
|
|
}
|
|
}
|
|
|
|
void NetworkServer::receiveInternalConnection(std::shared_ptr<IInternalConnection> remoteConnection)
|
|
{
|
|
auto localConnection = std::make_shared<InternalConnection>(*this, io);
|
|
|
|
connections.insert(localConnection);
|
|
|
|
localConnection->connectTo(remoteConnection);
|
|
remoteConnection->connectTo(localConnection);
|
|
|
|
listener.onNewConnection(localConnection);
|
|
}
|
|
|
|
void NetworkServer::onPacketReceived(const std::shared_ptr<INetworkConnection> & connection, const std::vector<std::byte> & message)
|
|
{
|
|
listener.onPacketReceived(connection, message);
|
|
}
|
|
|
|
VCMI_LIB_NAMESPACE_END
|