network_command.cpp File Reference

Command handling over network connections. More...

#include "../stdafx.h"
#include "network_admin.h"
#include "network_client.h"
#include "network_server.h"
#include "../command_func.h"
#include "../company_func.h"
#include "../settings_type.h"
#include "../airport_cmd.h"
#include "../aircraft_cmd.h"
#include "../autoreplace_cmd.h"
#include "../company_cmd.h"
#include "../depot_cmd.h"
#include "../dock_cmd.h"
#include "../economy_cmd.h"
#include "../engine_cmd.h"
#include "../error_func.h"
#include "../goal_cmd.h"
#include "../group_cmd.h"
#include "../industry_cmd.h"
#include "../landscape_cmd.h"
#include "../league_cmd.h"
#include "../misc_cmd.h"
#include "../news_cmd.h"
#include "../object_cmd.h"
#include "../order_cmd.h"
#include "../rail_cmd.h"
#include "../road_cmd.h"
#include "../roadveh_cmd.h"
#include "../settings_cmd.h"
#include "../signs_cmd.h"
#include "../station_cmd.h"
#include "../story_cmd.h"
#include "../subsidy_cmd.h"
#include "../terraform_cmd.h"
#include "../timetable_cmd.h"
#include "../town_cmd.h"
#include "../train_cmd.h"
#include "../tree_cmd.h"
#include "../tunnelbridge_cmd.h"
#include "../vehicle_cmd.h"
#include "../viewport_cmd.h"
#include "../water_cmd.h"
#include "../waypoint_cmd.h"
#include "../script/script_cmd.h"
#include "../safeguards.h"

Go to the source code of this file.

Data Structures
struct	CallbackArgsHelper< void(*const)(Commands, const CommandCost &, Targs...)>
struct	CommandDispatch

Typedefs
using	UnpackNetworkCommandProc = void(*)(const CommandPacket &)
using	UnpackDispatchT = std::array< UnpackNetworkCommandProc, _callback_tuple_size >

Functions
template<size_t... i>
auto	MakeCallbackTable (std::index_sequence< i... >) noexcept
template<Commands Tcmd>
static CommandDataBuffer	SanitizeCmdStrings (const CommandDataBuffer &data)
	Validate and sanitize strings in command data.
template<Commands Tcmd, size_t cb>
static void	UnpackNetworkCommand (const CommandPacket &cp)
	Unpack a generic command packet into its actual typed components.
template<Commands Tcmd>
static void	NetworkReplaceCommandClientId (CommandPacket &cp, ClientID client_id)
template<Commands Tcmd, size_t Tcb>
constexpr UnpackNetworkCommandProc	MakeUnpackNetworkCommandCallback () noexcept
template<Commands Tcmd, size_t... i>
constexpr UnpackDispatchT	MakeUnpackNetworkCommand (std::index_sequence< i... >) noexcept
template<typename T , T... i, size_t... j>
constexpr auto	MakeDispatchTable (std::integer_sequence< T, i... >, std::index_sequence< j... >) noexcept
static size_t	FindCallbackIndex (CommandCallback *callback)
	Find the callback index of a callback pointer.
void	NetworkSendCommand (Commands cmd, StringID err_message, CommandCallback *callback, CompanyID company, const CommandDataBuffer &cmd_data)
	Prepare a DoCommand to be send over the network.
void	NetworkSyncCommandQueue (NetworkClientSocket *cs)
	Sync our local command queue to the command queue of the given socket.
void	NetworkExecuteLocalCommandQueue ()
	Execute all commands on the local command queue that ought to be executed this frame.
void	NetworkFreeLocalCommandQueue ()
	Free the local command queues.
static void	DistributeCommandPacket (CommandPacket &cp, const NetworkClientSocket *owner)
	"Send" a particular CommandPacket to all clients.
static void	DistributeQueue (CommandQueue &queue, const NetworkClientSocket *owner)
	"Send" a particular CommandQueue to all clients.
void	NetworkDistributeCommands ()
	Distribute the commands of ourself and the clients.
template<class T >
static void	SetClientIdHelper (T &data, ClientID client_id)
	Helper to process a single ClientID argument.
template<class Ttuple , size_t... Tindices>
static void	SetClientIds (Ttuple &values, ClientID client_id, std::index_sequence< Tindices... >)
	Set all invalid ClientID's to the proper value.
void	NetworkReplaceCommandClientId (CommandPacket &cp, ClientID client_id)
	Insert a client ID into the command data in a command packet.
template<class T >
static void	SanitizeSingleStringHelper (CommandFlags cmd_flags, T &data)
	Validate a single string argument coming from network.
template<class Ttuple , size_t... Tindices>
static void	SanitizeStringsHelper (CommandFlags cmd_flags, Ttuple &values, std::index_sequence< Tindices... >)
	Helper function to perform validation on command data strings.
template<Commands Tcmd>
CommandDataBuffer	SanitizeCmdStrings (const CommandDataBuffer &data)
	Validate and sanitize strings in command data.
template<Commands Tcmd, size_t Tcb>
void	UnpackNetworkCommand (const CommandPacket &cp)
	Unpack a generic command packet into its actual typed components.

Variables
static constexpr auto	_callback_tuple
	Typed list of all possible callbacks.
constexpr size_t	_callback_tuple_size = std::tuple_size_v<decltype(_callback_tuple)>
static auto	_callback_table = MakeCallbackTable(std::make_index_sequence<_callback_tuple_size>{})
	Type-erased table of callbacks.
static constexpr auto	_cmd_dispatch = MakeDispatchTable(std::make_integer_sequence<std::underlying_type_t<Commands>, CMD_END>{}, std::make_index_sequence<_callback_tuple_size>{})
	Command dispatch table.
static CommandQueue	_local_wait_queue
	Local queue of packets waiting for handling.
static CommandQueue	_local_execution_queue
	Local queue of packets waiting for execution.

Detailed Description

Command handling over network connections.

Definition in file network_command.cpp.

Typedef Documentation

UnpackDispatchT

using UnpackDispatchT = std::array<UnpackNetworkCommandProc, _callback_tuple_size>

Definition at line 128 of file network_command.cpp.

UnpackNetworkCommandProc

using UnpackNetworkCommandProc = void (*)(const CommandPacket &)

Definition at line 127 of file network_command.cpp.

Function Documentation

DistributeCommandPacket()

static void DistributeCommandPacket ( CommandPacket &  cp, const NetworkClientSocket *  owner  )

static

"Send" a particular CommandPacket to all clients.

Parameters

cp	The command that has to be distributed.
owner	The client that owns the command,

Definition at line 290 of file network_command.cpp.

References _frame_counter_max, _local_execution_queue, CommandPacket::callback, CommandPacket::frame, and CommandPacket::my_cmd.

Referenced by DistributeQueue().

DistributeQueue()

static void DistributeQueue ( CommandQueue &  queue, const NetworkClientSocket *  owner  )

static

"Send" a particular CommandQueue to all clients.

Parameters

queue	The queue of commands that has to be distributed.
owner	The client that owns the commands,

Definition at line 315 of file network_command.cpp.

References _pause_mode, _settings_client, NetworkSettings::commands_per_frame, NetworkSettings::commands_per_frame_server, DistributeCommandPacket(), IsCommandAllowedWhilePaused(), ClientSettings::network, NetworkAdminCmdLogging(), and PM_UNPAUSED.

Referenced by NetworkDistributeCommands().

FindCallbackIndex()

static size_t FindCallbackIndex ( CommandCallback *  callback )

static

Find the callback index of a callback pointer.

Parameters

callback

Address of callback to search for.

Returns

Callback index or std::numeric_limits<size_t>::max() if the function wasn't found in the callback list.

Definition at line 179 of file network_command.cpp.

References _callback_table.

Referenced by NetworkGameSocketHandler::SendCommand().

MakeCallbackTable()

template<size_t... i>

auto MakeCallbackTable ( std::index_sequence< i... >  )

inlinenoexcept

Definition at line 107 of file network_command.cpp.

MakeDispatchTable()

template<typename T , T... i, size_t... j>

constexpr auto MakeDispatchTable ( std::integer_sequence< T, i... >  , std::index_sequence< j... >    )

inlineconstexprnoexcept

Definition at line 157 of file network_command.cpp.

MakeUnpackNetworkCommand()

template<Commands Tcmd, size_t... i>

constexpr UnpackDispatchT MakeUnpackNetworkCommand ( std::index_sequence< i... >  )

constexprnoexcept

Definition at line 151 of file network_command.cpp.

MakeUnpackNetworkCommandCallback()

template<Commands Tcmd, size_t Tcb>

constexpr UnpackNetworkCommandProc MakeUnpackNetworkCommandCallback ( )

constexprnoexcept

Definition at line 136 of file network_command.cpp.

NetworkDistributeCommands()

void NetworkDistributeCommands

(

)

Distribute the commands of ourself and the clients.

Definition at line 346 of file network_command.cpp.

References _local_wait_queue, and DistributeQueue().

NetworkExecuteLocalCommandQueue()

void NetworkExecuteLocalCommandQueue

(

)

Execute all commands on the local command queue that ought to be executed this frame.

Definition at line 245 of file network_command.cpp.

NetworkFreeLocalCommandQueue()

void NetworkFreeLocalCommandQueue

(

)

Free the local command queues.

Definition at line 279 of file network_command.cpp.

References _local_execution_queue, and _local_wait_queue.

NetworkReplaceCommandClientId() [1/2]

template<Commands Tcmd>

static void NetworkReplaceCommandClientId ( CommandPacket &  cp, ClientID  client_id  )

static

Definition at line 416 of file network_command.cpp.

NetworkReplaceCommandClientId() [2/2]

void NetworkReplaceCommandClientId	(	CommandPacket &	cp,
		ClientID	client_id
	)

Insert a client ID into the command data in a command packet.

Parameters

cp	Command packet to modify.
client_id	Client id to insert.

Definition at line 433 of file network_command.cpp.

References _cmd_dispatch, and CommandPacket::cmd.

Referenced by ServerNetworkGameSocketHandler::Receive_CLIENT_COMMAND().

NetworkSendCommand()

void NetworkSendCommand	(	Commands	cmd,
		StringID	err_message,
		CommandCallback *	callback,
		CompanyID	company,
		const CommandDataBuffer &	cmd_data
	)

Prepare a DoCommand to be send over the network.

Parameters

cmd	The command to execute (a CMD_* value)
err_message	Message prefix to show on error
callback	A callback function to call after the command is finished
company	The company that wants to send the command
cmd_data	The command proc arguments.

Definition at line 196 of file network_command.cpp.

References _frame_counter_max, _local_wait_queue, _network_server, CommandPacket::callback, CommandPacket::cmd, CommandPacket::company, CommandPacket::data, CommandPacket::err_msg, CommandPacket::frame, CommandPacket::my_cmd, and ClientNetworkGameSocketHandler::SendCommand().

Referenced by CommandHelper< Tcmd, Tret(*)(DoCommandFlag, Targs...), true >::SendNet().

NetworkSyncCommandQueue()

void NetworkSyncCommandQueue

(

NetworkClientSocket *

cs

)

Sync our local command queue to the command queue of the given socket.

This is needed for the case where we receive a command before saving the game for a joining client, but without the execution of those commands. Not syncing those commands means that the client will never get them and as such will be in a desynced state from the time it started with joining.

Parameters

cs	The client to sync the queue to.

Definition at line 234 of file network_command.cpp.

References _local_execution_queue, and CommandPacket::callback.

Referenced by ServerNetworkGameSocketHandler::SendMap().

SanitizeCmdStrings() [1/2]

template<Commands Tcmd>

static CommandDataBuffer SanitizeCmdStrings ( const CommandDataBuffer &  data )

static

Validate and sanitize strings in command data.

Template Parameters

Tcmd	Command this data belongs to.

Parameters

data	Command data.

Returns

Sanitized command data.

Definition at line 462 of file network_command.cpp.

References SanitizeStringsHelper().

SanitizeCmdStrings() [2/2]

template<Commands Tcmd>

CommandDataBuffer SanitizeCmdStrings

(

const CommandDataBuffer &

data

)

Validate and sanitize strings in command data.

Template Parameters

Tcmd	Command this data belongs to.

Parameters

data	Command data.

Returns

Sanitized command data.

Definition at line 462 of file network_command.cpp.

References SanitizeStringsHelper().

SanitizeSingleStringHelper()

template<class T >

static void SanitizeSingleStringHelper ( CommandFlags  cmd_flags, T &  data  )

inlinestatic

Validate a single string argument coming from network.

Definition at line 441 of file network_command.cpp.

References _network_server, CMD_STR_CTRL, HasFlag(), StrMakeValid(), SVS_ALLOW_CONTROL_CODE, and SVS_REPLACE_WITH_QUESTION_MARK.

Referenced by SanitizeStringsHelper().

SanitizeStringsHelper()

template<class Ttuple , size_t... Tindices>

static void SanitizeStringsHelper ( CommandFlags  cmd_flags, Ttuple &  values, std::index_sequence< Tindices... >    )

inlinestatic

Helper function to perform validation on command data strings.

Definition at line 450 of file network_command.cpp.

References SanitizeSingleStringHelper().

Referenced by SanitizeCmdStrings().

SetClientIdHelper()

template<class T >

static void SetClientIdHelper ( T &  data, ClientID  client_id  )

inlinestatic

Helper to process a single ClientID argument.

Definition at line 401 of file network_command.cpp.

Referenced by SetClientIds(), and CommandHelper< Tcmd, Tret(*)(DoCommandFlag, Targs...), true >::SetClientIds().

SetClientIds()

template<class Ttuple , size_t... Tindices>

static void SetClientIds ( Ttuple &  values, ClientID  client_id, std::index_sequence< Tindices... >    )

inlinestatic

Set all invalid ClientID's to the proper value.

Definition at line 410 of file network_command.cpp.

References SetClientIdHelper().

UnpackNetworkCommand() [1/2]

template<Commands Tcmd, size_t cb>

static void UnpackNetworkCommand ( const CommandPacket &  cp )

static

Unpack a generic command packet into its actual typed components.

Template Parameters

Tcmd	Command type to be unpacked.
Tcb	Index into the callback list.

Parameters

cp	Command packet to unpack.

Definition at line 476 of file network_command.cpp.

References _callback_tuple, CommandPacket::data, CommandPacket::err_msg, and CommandPacket::my_cmd.

UnpackNetworkCommand() [2/2]

template<Commands Tcmd, size_t Tcb>

void UnpackNetworkCommand

(

const CommandPacket &

cp

)

Unpack a generic command packet into its actual typed components.

Template Parameters

Tcmd	Command type to be unpacked.
Tcb	Index into the callback list.

Parameters

cp	Command packet to unpack.

Definition at line 476 of file network_command.cpp.

References _callback_tuple, CommandPacket::data, CommandPacket::err_msg, and CommandPacket::my_cmd.

Variable Documentation

_callback_table

auto _callback_table = MakeCallbackTable(std::make_index_sequence<_callback_tuple_size>{})

static

Type-erased table of callbacks.

Definition at line 113 of file network_command.cpp.

Referenced by FindCallbackIndex(), and NetworkGameSocketHandler::ReceiveCommand().

_callback_tuple

constexpr auto _callback_tuple

staticconstexpr

Initial value:

= std::make_tuple(
  (CommandCallback *)nullptr, 
  &CcBuildPrimaryVehicle,
  &CcBuildAirport,
  &CcBuildBridge,
  &CcPlaySound_CONSTRUCTION_WATER,
  &CcBuildDocks,
  &CcFoundTown,
  &CcBuildRoadTunnel,
  &CcBuildRailTunnel,
  &CcBuildWagon,
  &CcRoadDepot,
  &CcRailDepot,
  &CcPlaceSign,
  &CcPlaySound_EXPLOSION,
  &CcPlaySound_CONSTRUCTION_OTHER,
  &CcPlaySound_CONSTRUCTION_RAIL,
  &CcStation,
  &CcTerraform,
  &CcAI,
  &CcCloneVehicle,
  &CcCreateGroup,
  &CcFoundRandomTown,
  &CcRoadStop,
  &CcBuildIndustry,
  &CcStartStopVehicle,
  &CcGame,
  &CcAddVehicleNewGroup
)

Typed list of all possible callbacks.

Definition at line 58 of file network_command.cpp.

Referenced by UnpackNetworkCommand().

_callback_tuple_size

constexpr size_t _callback_tuple_size = std::tuple_size_v<decltype(_callback_tuple)>

inlineconstexpr

Definition at line 104 of file network_command.cpp.

_cmd_dispatch

constexpr auto _cmd_dispatch = MakeDispatchTable(std::make_integer_sequence<std::underlying_type_t<Commands>, CMD_END>{}, std::make_index_sequence<_callback_tuple_size>{})

staticconstexpr

Command dispatch table.

Definition at line 162 of file network_command.cpp.

Referenced by NetworkReplaceCommandClientId(), NetworkGameSocketHandler::ReceiveCommand(), and NetworkGameSocketHandler::SendCommand().

_local_execution_queue

CommandQueue _local_execution_queue

static

Local queue of packets waiting for execution.

Definition at line 171 of file network_command.cpp.

Referenced by DistributeCommandPacket(), NetworkFreeLocalCommandQueue(), and NetworkSyncCommandQueue().

_local_wait_queue

CommandQueue _local_wait_queue

static

Local queue of packets waiting for handling.

Definition at line 169 of file network_command.cpp.

Referenced by NetworkDistributeCommands(), NetworkFreeLocalCommandQueue(), and NetworkSendCommand().