|
|
|
/*
|
|
|
|
* This file is part of OpenTTD.
|
|
|
|
* OpenTTD 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, version 2.
|
|
|
|
* OpenTTD 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 OpenTTD. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
*/
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @file tcp.h Basic functions to receive and send TCP packets.
|
|
|
|
*/
|
|
|
|
|
|
|
|
#ifndef NETWORK_CORE_TCP_H
|
|
|
|
#define NETWORK_CORE_TCP_H
|
|
|
|
|
|
|
|
#include "address.h"
|
|
|
|
#include "packet.h"
|
|
|
|
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
#include <chrono>
|
|
|
|
#include <atomic>
|
|
|
|
|
|
|
|
/** The states of sending the packets. */
|
|
|
|
enum SendPacketsState {
|
|
|
|
SPS_CLOSED, ///< The connection got closed.
|
|
|
|
SPS_NONE_SENT, ///< The buffer is still full, so no (parts of) packets could be sent.
|
|
|
|
SPS_PARTLY_SENT, ///< The packets are partly sent; there are more packets to be sent in the queue.
|
|
|
|
SPS_ALL_SENT, ///< All packets in the queue are sent.
|
|
|
|
};
|
|
|
|
|
|
|
|
/** Base socket handler for all TCP sockets */
|
|
|
|
class NetworkTCPSocketHandler : public NetworkSocketHandler {
|
|
|
|
private:
|
|
|
|
Packet *packet_queue; ///< Packets that are awaiting delivery
|
|
|
|
Packet *packet_recv; ///< Partially received packet
|
|
|
|
public:
|
|
|
|
SOCKET sock; ///< The socket currently connected to
|
|
|
|
bool writable; ///< Can we write to this socket?
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Whether this socket is currently bound to a socket.
|
|
|
|
* @return true when the socket is bound, false otherwise
|
|
|
|
*/
|
|
|
|
bool IsConnected() const { return this->sock != INVALID_SOCKET; }
|
|
|
|
|
|
|
|
NetworkRecvStatus CloseConnection(bool error = true) override;
|
|
|
|
virtual void SendPacket(Packet *packet);
|
|
|
|
SendPacketsState SendPackets(bool closing_down = false);
|
|
|
|
|
|
|
|
virtual Packet *ReceivePacket();
|
|
|
|
|
|
|
|
bool CanSendReceive();
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Whether there is something pending in the send queue.
|
|
|
|
* @return true when something is pending in the send queue.
|
|
|
|
*/
|
|
|
|
bool HasSendQueue() { return this->packet_queue != nullptr; }
|
|
|
|
|
|
|
|
NetworkTCPSocketHandler(SOCKET s = INVALID_SOCKET);
|
|
|
|
~NetworkTCPSocketHandler();
|
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* "Helper" class for creating TCP connections in a non-blocking manner
|
|
|
|
*/
|
|
|
|
class TCPConnecter {
|
|
|
|
private:
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
addrinfo *ai = nullptr; ///< getaddrinfo() allocated linked-list of resolved addresses.
|
|
|
|
std::vector<addrinfo *> addresses; ///< Addresses we can connect to.
|
|
|
|
size_t current_address = 0; ///< Current index in addresses we are trying.
|
|
|
|
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
std::vector<SOCKET> sockets; ///< Pending connect() attempts.
|
|
|
|
std::chrono::steady_clock::time_point last_attempt; ///< Time we last tried to connect.
|
|
|
|
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
std::atomic<bool> is_resolved = false; ///< Whether resolving is done.
|
|
|
|
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
void Resolve();
|
|
|
|
void OnResolved(addrinfo *ai);
|
|
|
|
bool TryNextAddress();
|
|
|
|
void Connect(addrinfo *address);
|
|
|
|
bool CheckActivity();
|
|
|
|
|
|
|
|
static void ResolveThunk(TCPConnecter *connecter);
|
|
|
|
|
|
|
|
public:
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
std::string connection_string; ///< Current address we are connecting to (before resolving).
|
|
|
|
|
|
|
|
TCPConnecter(const std::string &connection_string, uint16 default_port);
|
Feature: use Happy Eyeballs to make network connections (TCP-only) (#9199)
Hostnames like "content.openttd.org" resolve into multiple IPv4 and IPv6.
It is possible that either of the IPs is not working, either due to
a poorly configured OS (having IPv6 but no valid route), broken network
paths, or a service that is temporary unavailable.
Instead of trying the IPs one by one, waiting for a 3s timeout between
each, be a bit more like browsers, and stack attempts on top of each
other with slight delays. This is called Happy Eyebells.
Initially, try the first IPv6 address. If within 250ms there is no
connection yet, try the first IPv4 address. 250ms later, try the
second IPv6 address, etc, till all addresses are tried.
If any connection is created, abort all the other (pending) connections
and use the one that is created. If all fail 3s after the last connect(),
trigger a timeout for all.
3 years ago
|
|
|
virtual ~TCPConnecter();
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Callback when the connection succeeded.
|
|
|
|
* @param s the socket that we opened
|
|
|
|
*/
|
|
|
|
virtual void OnConnect(SOCKET s) {}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Callback for when the connection attempt failed.
|
|
|
|
*/
|
|
|
|
virtual void OnFailure() {}
|
|
|
|
|
|
|
|
static void CheckCallbacks();
|
|
|
|
static void KillAll();
|
|
|
|
};
|
|
|
|
|
|
|
|
#endif /* NETWORK_CORE_TCP_H */
|