Skip to content

Commit

Permalink
netplay: move code for async opening of client connections to the bas…
Browse files Browse the repository at this point in the history
…e `WzConnectionProvider`

Provide the default implementation for `openClientConnectionAsync()`
in `WzConnectionProvider`, which just spawns a new thread and
piggibacks on the `resolveHost()` + `openClientConnectionAny()`
combination.

The `TCPConnectionProvider` is now simpler because it can use
the default implementation from the base class.

Signed-off-by: Pavel Solodovnikov <pavel.al.solodovnikov@gmail.com>
  • Loading branch information
ManManson committed Nov 17, 2024
1 parent b0c39f5 commit 1ae4f40
Show file tree
Hide file tree
Showing 5 changed files with 110 additions and 86 deletions.
74 changes: 0 additions & 74 deletions lib/netplay/tcp/tcp_connection_provider.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -78,80 +78,6 @@ net::result<IClientConnection*> TCPConnectionProvider::openClientConnectionAny(c
return new TCPClientConnection(res.value());
}

namespace
{

OpenConnectionResult socketOpenTCPConnectionSync(const char* host, uint32_t port)
{
const auto hostsResult = resolveHost(host, port);
SocketAddress* hosts = hostsResult.value_or(nullptr);
if (hosts == nullptr)
{
const auto hostsErr = hostsResult.error();
const auto hostsErrMsg = hostsErr.message();
return OpenConnectionResult(hostsErr, astringf("Cannot resolve host \"%s\": [%d]: %s", host, hostsErr.value(), hostsErrMsg.c_str()));
}

auto sockResult = socketOpenAny(hosts, 15000);
Socket* client_transient_socket = sockResult.value_or(nullptr);
deleteSocketAddress(hosts);
hosts = nullptr;

if (client_transient_socket == nullptr)
{
const auto errValue = sockResult.error();
const auto errMsg = errValue.message();
return OpenConnectionResult(errValue, astringf("Cannot connect to [%s]:%d, [%d]:%s", host, port, errValue.value(), errMsg.c_str()));
}

return OpenConnectionResult(new TCPClientConnection(client_transient_socket));
}

struct OpenConnectionRequest
{
std::string host;
uint32_t port = 0;
OpenConnectionToHostResultCallback callback;
};

static int openDirectTCPConnectionAsyncImpl(void* data)
{
OpenConnectionRequest* pRequestInfo = (OpenConnectionRequest*)data;
if (!pRequestInfo)
{
return 1;
}

pRequestInfo->callback(socketOpenTCPConnectionSync(pRequestInfo->host.c_str(), pRequestInfo->port));
delete pRequestInfo;
return 0;
}

} // anonymous namespace

bool TCPConnectionProvider::openClientConnectionAsync(const std::string& host, uint32_t port, OpenConnectionToHostResultCallback callback)
{
// spawn background thread to handle this
auto pRequest = new OpenConnectionRequest();
pRequest->host = host;
pRequest->port = port;
pRequest->callback = callback;

WZ_THREAD* pOpenConnectionThread = wzThreadCreate(openDirectTCPConnectionAsyncImpl, pRequest);
if (pOpenConnectionThread == nullptr)
{
debug(LOG_ERROR, "Failed to create thread for opening connection");
delete pRequest;
return false;
}

wzThreadDetach(pOpenConnectionThread);
// the thread handles deleting pRequest
pOpenConnectionThread = nullptr;

return true;
}

IConnectionPollGroup* TCPConnectionProvider::newConnectionPollGroup()
{
auto* sset = allocSocketSet();
Expand Down
1 change: 0 additions & 1 deletion lib/netplay/tcp/tcp_connection_provider.h
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,6 @@ class TCPConnectionProvider final : public WzConnectionProvider
virtual net::result<IListenSocket*> openListenSocket(uint16_t port) override;

virtual net::result<IClientConnection*> openClientConnectionAny(const IConnectionAddress& addr, unsigned timeout) override;
virtual bool openClientConnectionAsync(const std::string& host, uint32_t port, OpenConnectionToHostResultCallback callback) override;

virtual IConnectionPollGroup* newConnectionPollGroup() override;
};
Expand Down
93 changes: 93 additions & 0 deletions lib/netplay/wz_connection_provider.cpp
Original file line number Diff line number Diff line change
@@ -0,0 +1,93 @@
/*
This file is part of Warzone 2100.
Copyright (C) 2024 Warzone 2100 Project
Warzone 2100 is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
Warzone 2100 is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with Warzone 2100; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/

#include "wz_connection_provider.h"

#include "lib/framework/wzapp.h"

namespace
{

OpenConnectionResult openClientConnectionSyncImpl(const char* host, uint32_t port, std::chrono::milliseconds timeout, WzConnectionProvider* connProvider)
{
auto addrResult = connProvider->resolveHost(host, port);
if (!addrResult.has_value())
{
const auto hostsErr = addrResult.error();
const auto hostsErrMsg = hostsErr.message();
return OpenConnectionResult(hostsErr, astringf("Cannot resolve host \"%s\": [%d]: %s", host, hostsErr.value(), hostsErrMsg.c_str()));
}
auto connRes = connProvider->openClientConnectionAny(*addrResult.value(), timeout.count());
if (!connRes.has_value())
{
const auto connErr = connRes.error();
const auto connErrMsg = connErr.message();
return OpenConnectionResult(connErr, astringf("Cannot resolve host \"%s\": [%d]: %s", host, connErr.value(), connErrMsg.c_str()));
}
return OpenConnectionResult(connRes.value());
}

struct OpenConnectionRequest
{
std::string host;
uint32_t port = 0;
std::chrono::milliseconds timeout{ 15000 };
OpenConnectionToHostResultCallback callback;
WzConnectionProvider* connProvider;
};

int openDirectConnectionAsyncImpl(void* data)
{
OpenConnectionRequest* pRequestInfo = (OpenConnectionRequest*)data;
if (!pRequestInfo)
{
return 1;
}
pRequestInfo->callback(openClientConnectionSyncImpl(
pRequestInfo->host.c_str(),
pRequestInfo->port,
pRequestInfo->timeout,
pRequestInfo->connProvider));
delete pRequestInfo;
return 0;
}

} // anonymous namespace

bool WzConnectionProvider::openClientConnectionAsync(const std::string& host, uint32_t port, std::chrono::milliseconds timeout, OpenConnectionToHostResultCallback callback)
{
// spawn background thread to handle this
auto pRequest = new OpenConnectionRequest();
pRequest->host = host;
pRequest->port = port;
pRequest->timeout = timeout;
pRequest->callback = callback;
pRequest->connProvider = this;
WZ_THREAD* pOpenConnectionThread = wzThreadCreate(openDirectConnectionAsyncImpl, pRequest);
if (pOpenConnectionThread == nullptr)
{
debug(LOG_ERROR, "Failed to create thread for opening connection");
delete pRequest;
return false;
}
wzThreadDetach(pOpenConnectionThread);
// the thread handles deleting pRequest
pOpenConnectionThread = nullptr;
return true;
}
7 changes: 5 additions & 2 deletions lib/netplay/wz_connection_provider.h
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,9 @@
#pragma once

#include <stdint.h>
#include <chrono>
#include <memory>
#include <string>

#include "lib/netplay/connection_address.h"
#include "lib/netplay/net_result.h"
Expand Down Expand Up @@ -72,9 +74,10 @@ class WzConnectionProvider
/// <param name="timeout">Timeout in milliseconds.</param>
virtual net::result<IClientConnection*> openClientConnectionAny(const IConnectionAddress& addr, unsigned timeout) = 0;
/// <summary>
/// Async variant of `openClientConnectionAny()`.
/// Async variant of `openClientConnectionAny()` with the default implementation, which
/// spawns a new thread and piggybacks on the `resolveHost()` and `openClientConnectionAny()` combination.
/// </summary>
virtual bool openClientConnectionAsync(const std::string& host, uint32_t port, OpenConnectionToHostResultCallback callback) = 0;
virtual bool openClientConnectionAsync(const std::string& host, uint32_t port, std::chrono::milliseconds timeout, OpenConnectionToHostResultCallback callback);
/// <summary>
/// Create a group for polling client connections.
/// </summary>
Expand Down
21 changes: 12 additions & 9 deletions src/screens/joiningscreen.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1239,16 +1239,19 @@ void WzJoiningGameScreen_HandlerRoot::attemptToOpenConnection(size_t connectionI
}
auto weakSelf = std::weak_ptr<WzJoiningGameScreen_HandlerRoot>(std::dynamic_pointer_cast<WzJoiningGameScreen_HandlerRoot>(shared_from_this()));

constexpr std::chrono::milliseconds CLIENT_OPEN_ASYNC_TIMEOUT{ 15000 }; // Default timeout of 15s

auto& connProvider = ConnectionProviderRegistry::Instance().Get(ConnectionProviderType::TCP_DIRECT);
connProvider.openClientConnectionAsync(description.host, description.port, [weakSelf, connectionIdx](OpenConnectionResult&& result) {
auto strongSelf = weakSelf.lock();
if (!strongSelf)
{
// background thread ultimately returned after the requester has gone away (join was cancelled?) - just return
return;
}
strongSelf->processOpenConnectionResultOnMainThread(connectionIdx, std::move(result));
});
connProvider.openClientConnectionAsync(description.host, description.port, CLIENT_OPEN_ASYNC_TIMEOUT,
[weakSelf, connectionIdx](OpenConnectionResult&& result) {
auto strongSelf = weakSelf.lock();
if (!strongSelf)
{
// background thread ultimately returned after the requester has gone away (join was cancelled?) - just return
return;
}
strongSelf->processOpenConnectionResultOnMainThread(connectionIdx, std::move(result));
});
break;
}
updateJoiningStatus(_("Establishing connection with host"));
Expand Down

0 comments on commit 1ae4f40

Please sign in to comment.