"Helper" class for creating TCP connections in a non-blocking manner More...

#include <tcp.h>

Inheritance diagram for TCPConnecter:

Public Member Functions
	TCPConnecter (const std::string &connection_string, uint16_t default_port, const NetworkAddress &bind_address={}, int family=AF_UNSPEC)
	Create a new connecter for the given address.

virtual void	OnConnect (SOCKET s)
	Callback when the connection succeeded.

virtual void	OnFailure ()
	Callback for when the connection attempt failed.

void	Kill ()
	Kill this connecter.

Static Public Member Functions
static void	CheckCallbacks ()
	Check whether we need to call the callback, i.e.

static void	KillAll ()
	Kill all connection attempts.

template<class T , typename... Args>
static std::shared_ptr< TCPConnecter >	Create (Args &&... args)
	Create the connecter, and initiate connecting by putting it in the collection of TCP connections to make.

Private Types
enum class	Status { Init , Resolving , Failure , Connecting , Connected }
	The current status of the connecter. More...

Private Member Functions
void	Resolve ()
	Start resolving the hostname.

void	OnResolved (addrinfo *ai)
	Callback when resolving is done.

bool	TryNextAddress ()
	Start the connect() for the next address in the list.

void	Connect (addrinfo *address)
	Start a connection to the indicated address.

virtual bool	CheckActivity ()
	Check if there was activity for this connecter.

Static Private Member Functions
static void	ResolveThunk (TCPConnecter *connecter)
	Thunk to start Resolve() on the right instance.

Private Attributes
std::thread	resolve_thread
	Thread used during resolving.

std::atomic< Status >	status = Status::Init
	The current status of the connecter.

std::atomic< bool >	killed = false
	Whether this connecter is marked as killed.

addrinfo *	ai = nullptr
	getaddrinfo() allocated linked-list of resolved addresses.

std::vector< addrinfo * >	addresses
	Addresses we can connect to.

std::map< SOCKET, NetworkAddress >	sock_to_address
	Mapping of a socket to the real address it is connecting to. USed for DEBUG statements.

size_t	current_address = 0
	Current index in addresses we are trying.

std::vector< SOCKET >	sockets
	Pending connect() attempts.

std::chrono::steady_clock::time_point	last_attempt
	Time we last tried to connect.

std::string	connection_string
	Current address we are connecting to (before resolving).

NetworkAddress	bind_address
	Address we're binding to, if any.

int	family = AF_UNSPEC
	Family we are using to connect with.

Static Private Attributes
static std::vector< std::shared_ptr< TCPConnecter > >	connecters
	List of connections that are currently being created.

Friends
class	TCPServerConnecter

Detailed Description

"Helper" class for creating TCP connections in a non-blocking manner

Definition at line 70 of file tcp.h.

Member Enumeration Documentation

◆ Status

enum class TCPConnecter::Status

strongprivate

The current status of the connecter.

We track the status like this to ensure everything is executed from the game-thread, and not at another random time where we might not have the lock on the game-state.

Enumerator
Init	TCPConnecter is created but resolving hasn't started.
Resolving	The hostname is being resolved (threaded).
Failure	Resolving failed.
Connecting	We are currently connecting.
Connected	The connection is established.

Definition at line 79 of file tcp.h.

Constructor & Destructor Documentation

◆ TCPConnecter() [1/2]

TCPConnecter::TCPConnecter ( )

inline

Definition at line 118 of file tcp.h.

◆ TCPConnecter() [2/2]

TCPConnecter::TCPConnecter	(	const std::string &	connection_string,
		uint16_t	default_port,
		const NetworkAddress &	bind_address = `{}`,
		int	family = `AF_UNSPEC`
	)

Create a new connecter for the given address.

Parameters

connection_string	The address to connect to.
default_port	If not indicated in connection_string, what port to use.
bind_address	The local bind address to use. Defaults to letting the OS find one.

Definition at line 29 of file tcp_connect.cpp.

References connection_string, and NormalizeConnectionString().

◆ ~TCPConnecter()

TCPConnecter::~TCPConnecter ( )

virtual

Definition at line 59 of file tcp_connect.cpp.

Member Function Documentation

◆ CheckActivity()

bool TCPConnecter::CheckActivity ( )

privatevirtual

Check if there was activity for this connecter.

Returns: True iff the TCPConnecter is done and can be cleaned up.

Reimplemented in TCPServerConnecter.

Definition at line 271 of file tcp_connect.cpp.

References NetworkError::AsString(), Connected, Connecting, connection_string, Debug, Failure, NetworkError::GetLast(), NetworkAddress::GetPeerName(), GetSocketError(), NetworkError::HasError(), Init, killed, last_attempt, OnConnect(), OnFailure(), Resolve(), resolve_thread, ResolveThunk(), Resolving, sock_to_address, sockets, StartNewThread(), status, and TryNextAddress().

Referenced by TCPServerConnecter::CheckActivity().

◆ CheckCallbacks()

void TCPConnecter::CheckCallbacks ( )

static

Check whether we need to call the callback, i.e.

whether we have connected or aborted and call the appropriate callback for that. It's done this way to ease on the locking that would otherwise be needed everywhere.

Definition at line 463 of file tcp_connect.cpp.

References connecters.

Referenced by NetworkBackgroundLoop().

◆ Connect()

void TCPConnecter::Connect ( addrinfo * address )

private

Start a connection to the indicated address.

Parameters

address The address to connection to.

Definition at line 88 of file tcp_connect.cpp.

References NetworkAddress::AddressFamilyAsString(), NetworkError::AsString(), bind_address, Debug, NetworkAddress::GetAddress(), NetworkAddress::GetAddressAsString(), NetworkError::GetLast(), NetworkAddress::GetPort(), SetNoDelay(), SetNonBlocking(), SetReusePort(), sock_to_address, sockets, and NetworkAddress::SocketTypeAsString().

Referenced by TryNextAddress().

◆ Create()

template<class T , typename... Args>

static std::shared_ptr< TCPConnecter > TCPConnecter::Create ( Args &&... args )

inlinestatic

Create the connecter, and initiate connecting by putting it in the collection of TCP connections to make.

Template Parameters

T	The type of connecter to create.

Parameters

args	The arguments to the constructor of T.

Returns: Shared pointer to the connecter.

Definition at line 145 of file tcp.h.

References connecters.

◆ Kill()

void TCPConnecter::Kill ( )

Kill this connecter.

It will abort as soon as it can and not call any of the callbacks.

Definition at line 78 of file tcp_connect.cpp.

References killed.

◆ KillAll()

void TCPConnecter::KillAll ( )

static

Kill all connection attempts.

Definition at line 472 of file tcp_connect.cpp.

References connecters.

◆ OnConnect()

virtual void TCPConnecter::OnConnect ( SOCKET s )

inlinevirtual

Callback when the connection succeeded.

Parameters

s	the socket that we opened

Reimplemented in TCPQueryConnecter, TCPClientConnecter, NetworkContentConnecter, NetworkDirectConnecter, NetworkReuseStunConnecter, NetworkCoordinatorConnecter, NetworkStunConnecter, and NetworkTurnConnecter.

Definition at line 126 of file tcp.h.

Referenced by CheckActivity(), and TCPServerConnecter::CheckActivity().

◆ OnFailure()

virtual void TCPConnecter::OnFailure ( )

inlinevirtual

Callback for when the connection attempt failed.

Reimplemented in TCPQueryConnecter, TCPClientConnecter, NetworkContentConnecter, NetworkDirectConnecter, NetworkReuseStunConnecter, NetworkCoordinatorConnecter, NetworkStunConnecter, and NetworkTurnConnecter.

Definition at line 131 of file tcp.h.

Referenced by CheckActivity(), and TCPServerConnecter::CheckActivity().

◆ OnResolved()

void TCPConnecter::OnResolved ( addrinfo * ai )

private

Callback when resolving is done.

Parameters

ai	A linked-list of address information.

Definition at line 148 of file tcp_connect.cpp.

References addresses, ai, connection_string, current_address, Debug, family, and NetworkAddress::GetAddressAsString().

Referenced by Resolve().

◆ Resolve()

void TCPConnecter::Resolve ( )

private

Start resolving the hostname.

This function must change "status" to either Status::FAILURE or Status::CONNECTING before returning.

Definition at line 220 of file tcp_connect.cpp.

References ai, Connecting, connection_string, Debug, Failure, NetworkAddress::GetHostname(), NetworkAddress::GetPort(), OnResolved(), ParseConnectionString(), and status.

Referenced by CheckActivity(), and ResolveThunk().

◆ ResolveThunk()

void TCPConnecter::ResolveThunk ( TCPConnecter * connecter )

staticprivate

Thunk to start Resolve() on the right instance.

Definition at line 262 of file tcp_connect.cpp.

References Resolve().

Referenced by CheckActivity().

◆ TryNextAddress()

bool TCPConnecter::TryNextAddress ( )

private

Start the connect() for the next address in the list.

Returns: True iff a new connect() is attempted.

Definition at line 134 of file tcp_connect.cpp.

References addresses, Connect(), current_address, and last_attempt.

Referenced by CheckActivity().

Friends And Related Symbol Documentation

◆ TCPServerConnecter

friend class TCPServerConnecter

friend

Definition at line 113 of file tcp.h.

Field Documentation

◆ addresses

std::vector<addrinfo *> TCPConnecter::addresses

private

Addresses we can connect to.

Definition at line 92 of file tcp.h.

Referenced by OnResolved(), and TryNextAddress().

◆ ai

addrinfo* TCPConnecter::ai = nullptr

private

getaddrinfo() allocated linked-list of resolved addresses.

Definition at line 91 of file tcp.h.

Referenced by OnResolved(), and Resolve().

◆ bind_address

NetworkAddress TCPConnecter::bind_address

private

Address we're binding to, if any.

Definition at line 100 of file tcp.h.

Referenced by Connect().

◆ connecters

std::vector< std::shared_ptr< TCPConnecter > > TCPConnecter::connecters

staticprivate

List of connections that are currently being created.

Definition at line 103 of file tcp.h.

Referenced by CheckCallbacks(), Create(), and KillAll().

◆ connection_string

std::string TCPConnecter::connection_string

private

Current address we are connecting to (before resolving).

Definition at line 99 of file tcp.h.

Referenced by CheckActivity(), OnResolved(), Resolve(), and TCPConnecter().

◆ current_address

size_t TCPConnecter::current_address = 0

private

Current index in addresses we are trying.

Definition at line 94 of file tcp.h.

Referenced by OnResolved(), and TryNextAddress().

◆ family

int TCPConnecter::family = AF_UNSPEC

private

Family we are using to connect with.

Definition at line 101 of file tcp.h.

Referenced by OnResolved().

◆ killed

std::atomic<bool> TCPConnecter::killed = false

private

Whether this connecter is marked as killed.

Definition at line 89 of file tcp.h.

Referenced by CheckActivity(), TCPServerConnecter::CheckActivity(), and Kill().

◆ last_attempt

std::chrono::steady_clock::time_point TCPConnecter::last_attempt

private

Time we last tried to connect.

Definition at line 97 of file tcp.h.

Referenced by CheckActivity(), and TryNextAddress().

◆ resolve_thread

std::thread TCPConnecter::resolve_thread

private

Thread used during resolving.

Definition at line 87 of file tcp.h.

Referenced by CheckActivity().

◆ sock_to_address

std::map<SOCKET, NetworkAddress> TCPConnecter::sock_to_address

private

Mapping of a socket to the real address it is connecting to. USed for DEBUG statements.

Definition at line 93 of file tcp.h.

Referenced by CheckActivity(), and Connect().

◆ sockets

std::vector<SOCKET> TCPConnecter::sockets

private

Pending connect() attempts.

Definition at line 96 of file tcp.h.

Referenced by CheckActivity(), and Connect().

◆ status

std::atomic<Status> TCPConnecter::status = Status::Init

private

The current status of the connecter.

Definition at line 88 of file tcp.h.

Referenced by CheckActivity(), TCPServerConnecter::CheckActivity(), Resolve(), TCPServerConnecter::SetConnected(), TCPServerConnecter::SetFailure(), and TCPServerConnecter::TCPServerConnecter().

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

src/network/core/tcp.h
src/network/core/tcp_connect.cpp

Public Member Functions

Static Public Member Functions

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Static Private Attributes

Friends

Detailed Description

Member Enumeration Documentation

◆ Status

Constructor & Destructor Documentation

◆ TCPConnecter() [1/2]

◆ TCPConnecter() [2/2]

◆ ~TCPConnecter()

Member Function Documentation

◆ CheckActivity()

◆ CheckCallbacks()

◆ Connect()

◆ Create()

◆ Kill()

◆ KillAll()

◆ OnConnect()

◆ OnFailure()

◆ OnResolved()

◆ Resolve()

◆ ResolveThunk()

◆ TryNextAddress()

Friends And Related Symbol Documentation

◆ TCPServerConnecter

Field Documentation

◆ addresses

◆ ai

◆ bind_address

◆ connecters

◆ connection_string

◆ current_address

◆ family

◆ killed

◆ last_attempt

◆ resolve_thread

◆ sock_to_address

◆ sockets

◆ status