Files
@ r21947:4b2aaf36e24d
Branch filter:
Location: cpp/openttd-patchpack/source/src/network/network_server.h - annotation
r21947:4b2aaf36e24d
6.4 KiB
text/x-c
(svn r27102) -Fix [FS#6194]: money values would end up wrong in strings when outside of the bounds of a 32 bits integer
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 | r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r9111:983de9c5a848 r9111:983de9c5a848 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r14248:a9050881acd7 r16227:792ebc5cdc7d r16658:c5444a43aa65 r14248:a9050881acd7 r16224:976f6278a22b r19944:25a78576fb5e r16224:976f6278a22b r17642:ab10f4b22179 r17360:71e102cec3ce r16224:976f6278a22b r16224:976f6278a22b r16212:9367327f6880 r16227:792ebc5cdc7d r16213:0b4dd45d6d32 r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r17620:27d56dd8671d r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16226:c9a49f2c6446 r16212:9367327f6880 r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r16312:cb5c5460a42f r18737:1ee35da7fa2f r16312:cb5c5460a42f r16312:cb5c5460a42f r16226:c9a49f2c6446 r16620:1174af2ca847 r16620:1174af2ca847 r16226:c9a49f2c6446 r16226:c9a49f2c6446 r16622:867378c72700 r16226:c9a49f2c6446 r16657:eea3d874b487 r17594:41fdf750f16c r16657:eea3d874b487 r16212:9367327f6880 r16212:9367327f6880 r16218:1e9669cfbb04 r16622:867378c72700 r16218:1e9669cfbb04 r21386:3ba07c8f5bce r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16225:8b607445bb1a r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r16227:792ebc5cdc7d r17589:2470c8704f99 r17592:fe12d7ef5149 r17592:fe12d7ef5149 r17589:2470c8704f99 r16212:9367327f6880 r16212:9367327f6880 r5475:3f5cd13d1b63 r17107:f5abb48e2d5e r21467:8b87202cc00f r5475:3f5cd13d1b63 r17642:ab10f4b22179 r17642:ab10f4b22179 r17642:ab10f4b22179 r17642:ab10f4b22179 r17642:ab10f4b22179 r16224:976f6278a22b r17642:ab10f4b22179 r17642:ab10f4b22179 r17642:ab10f4b22179 r17642:ab10f4b22179 r17642:ab10f4b22179 r16224:976f6278a22b r16224:976f6278a22b r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r6247:96e840dbefcc r6247:96e840dbefcc r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 r5475:3f5cd13d1b63 | /* $Id$ */
/*
* 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 network_server.h Server part of the network protocol. */
#ifndef NETWORK_SERVER_H
#define NETWORK_SERVER_H
#ifdef ENABLE_NETWORK
#include "network_internal.h"
#include "core/tcp_listen.h"
#include "../thread/thread.h"
class ServerNetworkGameSocketHandler;
/** Make the code look slightly nicer/simpler. */
typedef ServerNetworkGameSocketHandler NetworkClientSocket;
/** Pool with all client sockets. */
typedef Pool<NetworkClientSocket, ClientIndex, 8, MAX_CLIENT_SLOTS, PT_NCLIENT> NetworkClientSocketPool;
extern NetworkClientSocketPool _networkclientsocket_pool;
/** Class for handling the server side of the game connection. */
class ServerNetworkGameSocketHandler : public NetworkClientSocketPool::PoolItem<&_networkclientsocket_pool>, public NetworkGameSocketHandler, public TCPListenHandler<ServerNetworkGameSocketHandler, PACKET_SERVER_FULL, PACKET_SERVER_BANNED> {
protected:
virtual NetworkRecvStatus Receive_CLIENT_JOIN(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_COMPANY_INFO(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_GAME_PASSWORD(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_COMPANY_PASSWORD(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_GETMAP(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_MAP_OK(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_ACK(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_COMMAND(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_CHAT(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_SET_PASSWORD(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_SET_NAME(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_QUIT(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_ERROR(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_RCON(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_NEWGRFS_CHECKED(Packet *p);
virtual NetworkRecvStatus Receive_CLIENT_MOVE(Packet *p);
NetworkRecvStatus SendCompanyInfo();
NetworkRecvStatus SendNewGRFCheck();
NetworkRecvStatus SendWelcome();
NetworkRecvStatus SendWait();
NetworkRecvStatus SendNeedGamePassword();
NetworkRecvStatus SendNeedCompanyPassword();
public:
/** Status of a client */
enum ClientStatus {
STATUS_INACTIVE, ///< The client is not connected nor active.
STATUS_NEWGRFS_CHECK, ///< The client is checking NewGRFs.
STATUS_AUTH_GAME, ///< The client is authorizing with game (server) password.
STATUS_AUTH_COMPANY, ///< The client is authorizing with company password.
STATUS_AUTHORIZED, ///< The client is authorized.
STATUS_MAP_WAIT, ///< The client is waiting as someone else is downloading the map.
STATUS_MAP, ///< The client is downloading the map.
STATUS_DONE_MAP, ///< The client has downloaded the map.
STATUS_PRE_ACTIVE, ///< The client is catching up the delayed frames.
STATUS_ACTIVE, ///< The client is active within in the game.
STATUS_END, ///< Must ALWAYS be on the end of this list!! (period).
};
byte lag_test; ///< Byte used for lag-testing the client
byte last_token; ///< The last random token we did send to verify the client is listening
uint32 last_token_frame; ///< The last frame we received the right token
ClientStatus status; ///< Status of this client
CommandQueue outgoing_queue; ///< The command-queue awaiting delivery
int receive_limit; ///< Amount of bytes that we can receive at this moment
struct PacketWriter *savegame; ///< Writer used to write the savegame.
NetworkAddress client_address; ///< IP-address of the client (so he can be banned)
ServerNetworkGameSocketHandler(SOCKET s);
~ServerNetworkGameSocketHandler();
virtual Packet *ReceivePacket();
NetworkRecvStatus CloseConnection(NetworkRecvStatus status);
void GetClientName(char *client_name, const char *last) const;
NetworkRecvStatus SendMap();
NetworkRecvStatus SendErrorQuit(ClientID client_id, NetworkErrorCode errorno);
NetworkRecvStatus SendQuit(ClientID client_id);
NetworkRecvStatus SendShutdown();
NetworkRecvStatus SendNewGame();
NetworkRecvStatus SendRConResult(uint16 colour, const char *command);
NetworkRecvStatus SendMove(ClientID client_id, CompanyID company_id);
NetworkRecvStatus SendClientInfo(NetworkClientInfo *ci);
NetworkRecvStatus SendError(NetworkErrorCode error);
NetworkRecvStatus SendChat(NetworkAction action, ClientID client_id, bool self_send, const char *msg, int64 data);
NetworkRecvStatus SendJoin(ClientID client_id);
NetworkRecvStatus SendFrame();
NetworkRecvStatus SendSync();
NetworkRecvStatus SendCommand(const CommandPacket *cp);
NetworkRecvStatus SendCompanyUpdate();
NetworkRecvStatus SendConfigUpdate();
static void Send();
static void AcceptConnection(SOCKET s, const NetworkAddress &address);
static bool AllowConnection();
/**
* Get the name used by the listener.
* @return the name to show in debug logs and the like.
*/
static const char *GetName()
{
return "server";
}
const char *GetClientIP();
static ServerNetworkGameSocketHandler *GetByClientID(ClientID client_id);
};
void NetworkServer_Tick(bool send_frame);
void NetworkServerSetCompanyPassword(CompanyID company_id, const char *password, bool already_hashed = true);
void NetworkServerUpdateCompanyPassworded(CompanyID company_id, bool passworded);
/**
* Iterate over all the sockets from a given starting point.
* @param var The variable to iterate with.
* @param start The start of the iteration.
*/
#define FOR_ALL_CLIENT_SOCKETS_FROM(var, start) FOR_ALL_ITEMS_FROM(NetworkClientSocket, clientsocket_index, var, start)
/**
* Iterate over all the sockets.
* @param var The variable to iterate with.
*/
#define FOR_ALL_CLIENT_SOCKETS(var) FOR_ALL_CLIENT_SOCKETS_FROM(var, 0)
#else /* ENABLE_NETWORK */
/* Network function stubs when networking is disabled */
static inline void NetworkServerMonthlyLoop() {}
static inline void NetworkServerYearlyLoop() {}
#endif /* ENABLE_NETWORK */
#endif /* NETWORK_SERVER_H */
|