Multiplayer Scripting – Arma Reforger
Lou Montana (talk | contribs) (→Methods: Fix arguments) |
Lou Montana (talk | contribs) m (Fix syntax highlight, Some wiki formatting) |
||
(7 intermediate revisions by the same user not shown) | |||
Line 2: | Line 2: | ||
'''Multiplayer Scripting''' in Enfusion is based on '''Replication''' - it determines which machine does what in a situation. | '''Multiplayer Scripting''' in Enfusion is based on '''Replication''' - it determines which machine does what in a situation. | ||
When a Prefab entity is created on the server (and has a replication node set to broadcast), it is ''replicated'' on other network machines for them to see a representation of this object. This created representation is called a ''proxy'' – more information below. | When a Prefab entity is created on the server (and has a replication node set to broadcast), it is ''replicated'' on other network machines for them to see a representation of this object. | ||
This created representation is called a ''proxy'' – more information below. | |||
Line 11: | Line 12: | ||
{{Feature|informative| | {{Feature|informative| | ||
In '''single player''', the local machine is considered a '''player-hosted server'''. | In '''single player''', the local machine is considered a '''player-hosted server'''. | ||
A properly designed | A properly designed multiplayer code should run flawlessly in single player, and ideally ''vice versa''. | ||
}} | }} | ||
=== Server === | === Server === | ||
The '''Server''' is the core network machine: it is the central system that receives and redistributes network information. There is only '''one''' server per multiplayer game, and the multiplayer game is destroyed if the server loses connection (server role does not get transferred). | The '''Server''' is the core network machine: it is the central system that receives and redistributes network information. | ||
There is only '''one''' server per multiplayer game, and the multiplayer game is destroyed if the server loses connection (server role does not get transferred). | |||
{{Feature|informative|A server can be | {{Feature|informative| | ||
A server can be: | |||
* '''dedicated''', as in it is a game instance running by itself, without a player behind | * '''dedicated''', as in it is a game instance running by itself, without a player behind | ||
* '''player-hosted''' (also known as '''listen server'''), meaning that a player's game instance is also hosting a game. | * {{GVI|armaR|0.9.7|size= 0.75}} '''player-hosted''' (also known as '''listen server'''), meaning that a player's game instance is also hosting a game. | ||
Distributed server (multiple servers) is '''not''' a thing in {{armaR}}. | |||
}} | |||
{{Feature|important| | |||
The following Components and others inheriting from them are '''not''' instanciated on a Dedicated Server: | |||
* {{Link/Enfusion|armaR|BaseFlattenGrassComponent}} | |||
* {{Link/Enfusion|armaR|CameraHandlerComponent}} | |||
* {{Link/Enfusion|armaR|DebugShootComponent}} | |||
* {{Link/Enfusion|armaR|MotorExhaustEffectComponent}} | |||
* {{Link/Enfusion|armaR|BaseSoundComponent}} | |||
}} | }} | ||
=== Client === | === Client === | ||
A '''Client''' is a machine that is connected to the server. A client is everything else that is '''not''' the server. | A '''Client''' is a machine that is connected to the server. A client is everything else that is '''not''' the server. | ||
A client can join after a game has started (even leave and join again) depending on the scenario. Such client is known as '''JIP''', standing for Join in Progress - see the {{Link|#Join In Progress}} section below. | |||
{{Feature|informative|A client can be | {{Feature|informative| | ||
A client can be | |||
* a '''player client''', the most common understanding of a client: a machine connecting to the server with a player behind it to play the game and control a character | * a '''player client''', the most common understanding of a client: a machine connecting to the server with a player behind it to play the game and control a character | ||
<!-- * a '''headless client''', which is the "dedicated server equivalent" for a client: this is a game instance that has no player behind, and this client's resources can be used to offload the server from calculations. --> | <!-- * a '''headless client''', which is the "dedicated server equivalent" for a client: this is a game instance that has no player behind, and this client's resources can be used to offload the server from calculations. --> | ||
{{arma3}}'s [[Arma 3: Headless Client|Headless Client]] system is '''not''' a thing in {{armaR}}. | |||
}} | }} | ||
Line 104: | Line 114: | ||
Giving ownership is '''not''' giving authority and is unrelated to it!<br> | Giving ownership is '''not''' giving authority and is unrelated to it!<br> | ||
Ownership can be changed, authority location is set in stone. | Ownership can be changed, authority location is set in stone. | ||
}} | |||
=== Replication State === | |||
There are two main replication game states which replication distinguishes and which affect some characteristics of replicated items: loadtime state and runtime state. Items inserted into replication while game is loading (ie. at loadtime) are treated as loadtime items, while those inserted once the game is running (ie. at runtime) are treated as runtime items when inserted on server, or local items when inserted on client (as they only exist locally). | |||
{{Feature|informative| | |||
Previously, loadtime items were referred to as ''static'', while runtime items were referred to as ''dynamic''. | |||
However, for several reasons (mainly naming consistency and collision with other systems using the same terminology), they were renamed to hopefully better reflect their nature. | |||
}} | |||
for simplicity, this page will use "items" to refer to both entities, components and in general anything else that might be replicated. | |||
==== Loadtime ==== | |||
'''Loadtime''' items are generally entity instances placed in world. These are objects that shouldn't be moved around too much (though some degree of movement is allowed) and usually need to be visible from greater distances. Typical examples are buildings or street signs. | |||
Main things to keep in mind: | |||
* They do '''not''' require prefab for spawning. | |||
* Their insertion '''must''' be deterministic on the server and clients. The server relies on clients to have the same initial world state after the map has been loaded so it can replicate changes from this initial state as they become relevant for a given client, reducing overall traffic (by sending only changes) and spreading the load over time. Clients will still be able to see things in the distance, even though their state has not been perfectly synchronised. | |||
** Replication validates that the initial world state matches. That is, RplId and type information of each loadtime item is the same on client as it initially was on the server. When a mismatch is detected, "inconsistent item table" error will appear in log and client will be disconnected with {{hl|JIP_ERROR}}. | |||
* They may be out-of-sync with the server '''for a long time''' (possibly through the whole game session). The replication scheduler (running server-side) decides when to stream their current state to each client. When this decision is based on proximity, clients will only get the current state streamed in when they get "close enough" for these changes to be relevant. Because of the world size, this may take time or never happen at all. | |||
** The only exception is complete removal of these items on the server. In that case, removal will be replicated to clients unconditionally. | |||
* As long as the authority exists on the server, the proxy exists on the clients. | |||
** Streaming in synchronizes state of proxy with authority. Once streamed in, proxy starts receiving state updates and it can send and receive RPCs.<br><!-- | |||
-->{{Feature|warning|Streaming out while the authority exists on the server is currently considered undefined behaviour and must be avoided!}} | |||
==== Runtime ==== | |||
'''Runtime''' items generally come from a game system that creates them during the session (A game mode, [[Arma Reforger:Game Master]], etc). | |||
They can move around the map freely and they are usually not visible from far away. Typical examples are vehicles, player characters, collectible items. | |||
Main things to keep in mind: | |||
* They require prefab for spawning. | |||
* They may only be inserted on the server. This is the authority. | |||
* Their proxy may or may not exist on a client. | |||
===== Local Runtime ===== | |||
Local items are items created on client during the session. | |||
They can be used for locally predicted effects of player actions, such as firing from rocket launcher immediately creating a flying rocket on client who fired it, instead of waiting for server-side rocket to be streamed to this client. | |||
Main things to keep in mind: | |||
* They do not require prefab for spawning. | |||
* They may only be inserted '''on a client'''. This is the authority. | |||
* There are no proxies on the server or other clients. | |||
==== Replication State Override ==== | |||
Replication state override (a.k.a "Rpl State Override") is a {{Link/Enfusion|armaR|RplComponent}} property that allows modifying the behaviour of spawning and insertion process to behave as-if insertion of node hierarchy happened in the specified state. | |||
The currently supported values are: | |||
* {{hl|None}}: no override. The state for this node and its descendants at the time of insertion is inherited from its parent node (whether it is Loadtime or Runtime). | |||
* {{hl|Runtime}}: The state for this node and its descendants at the time of insertion is overridden to be Runtime. | |||
{{Feature|important| | |||
With entities and components, child entities spawned during initialisation must be attached to parent as part of spawning process. | |||
A common mistake is to spawn an entity first and then attach it as child of entity that spawned it. However, this results in spawned entity being inserted separately from parent. | |||
If this happens at loadtime and the parent entity had its state overridden to be runtime, it will revert state override back to loadtime, which is currently considered '''undefined behaviour''' and must be avoided! | |||
}} | }} | ||
Line 116: | Line 181: | ||
=== Streaming === | === Streaming === | ||
'''Streaming''' is the system creating/updating/deleting entities that are '''relevant''' to the local machine. | |||
An entity is '''not''' always present on all machines. Streaming is the way of saving network and CPU process by only sending '''relevant''' entities' information. | An entity is '''not''' always present on all machines. Streaming is the way of saving network and CPU process by only sending '''relevant''' entities' information. | ||
Consider a server hosting a game with multiple clients, with "player" designating the local player on the local client machine. | |||
A car parked 5 km away from the player is not important to them, so only the server and players near the car have this entity's information - it actually does not exist on the player's machine. | |||
If someone damages that car, the server is informed and this information is transferred to whomever it is relevant - nearby players, not distant players. | |||
If the player gets close to it, the server decides this car becomes relevant to that client and streams it the proxy's information along with its current state (damage, position, etc). | |||
* Streaming in creates a proxy | |||
* Streaming out destroys this proxy | |||
* While the proxy exists, it receives state updates and can send and receive RPCs. | |||
{{Feature|informative|The streaming system is also what is at work during '''Join In Progress'''.}} | {{Feature|informative|The streaming system is also what is at work during '''Join In Progress'''.}} | ||
Line 163: | Line 239: | ||
=== Rpc Method === | === Rpc Method === | ||
The {{hl|Rpc}} method (present in both {{ | The {{hl|Rpc}} method (present in both {{Link/Enfusion|armaR|GenericEntity}} and {{Link/Enfusion|armaR|GenericComponent}}) is the starting point to trigger a network-friendly code call. | ||
<enforce> | <enforce methods="Rpc_MyMethod"> | ||
Rpc(Rpc_MyMethod, parameter1, parameter2); | Rpc(Rpc_MyMethod, parameter1, parameter2); | ||
</enforce> | </enforce> | ||
Line 223: | Line 299: | ||
|- | |- | ||
| colspan="5" | | | colspan="5" | | ||
<div style="display: inline-block; margin: auto; text-align: left"> | |||
{{Icon|checked}} = RPL call is processed over the network<br> | {{Icon|checked}} = RPL call is processed over the network<br> | ||
{{Icon|unchecked}} = RPL call is abandoned | {{Icon|unchecked}} = RPL call is abandoned | ||
</div> | |||
|- | |- | ||
! rowspan="2" | Action | ! rowspan="2" | Action | ||
Line 281: | Line 359: | ||
{ | { | ||
[RplProp(onRplName: "OnBroadcastValueUpdated", condition: RplCondition.Custom, customConditionName: "RpcConditionMethod")] | [RplProp(onRplName: "OnBroadcastValueUpdated", condition: RplCondition.Custom, customConditionName: "RpcConditionMethod")] | ||
protected | protected int m_iBroadcastValue; | ||
void OnBroadcastValueUpdated() | void OnBroadcastValueUpdated() | ||
{ | { | ||
// this method will only run on proxies if authority's RpcConditionMethod returns true | // this method will only run on proxies if authority's RpcConditionMethod returns true | ||
} | } | ||
[RplRpc(RplChannel.Reliable, RplRcver.Server)] | [RplRpc(RplChannel.Reliable, RplRcver.Server)] | ||
void RpcAsk_Method() | void RpcAsk_Method() | ||
Line 294: | Line 372: | ||
Replication.BumpMe(); | Replication.BumpMe(); | ||
} | } | ||
bool RpcConditionMethod() | bool RpcConditionMethod() | ||
{ | { | ||
Line 307: | Line 385: | ||
The {{hl|RplProp}} attribute is to decorate an object's '''property''', allowing the engine to synchronise values on network machines. | The {{hl|RplProp}} attribute is to decorate an object's '''property''', allowing the engine to synchronise values on network machines. | ||
Only a change on the authority '''and''' notifying the replication system with {{hl|Replication.BumpMe()}} method will trigger a broadcast to other machines (see the {{ | Only a change on the authority '''and''' notifying the replication system with {{hl|Replication.BumpMe()}} method will trigger a broadcast to other machines (see the {{Link|#BumpMe}} section). | ||
{{Feature|informative| | {{Feature|informative| | ||
{{hl|RplProp}}-decorated properties are automatically synchronised by the {{ | {{hl|RplProp}}-decorated properties are automatically synchronised by the {{Link|#Streaming}} system. | ||
<enforce> | <enforce> | ||
[RplProp()] | [RplProp()] | ||
Line 366: | Line 444: | ||
{ | { | ||
[RplProp(onRplName: "OnBroadcastValueUpdated", condition: RplCondition.Custom, customConditionName: "RpcConditionMethod")] | [RplProp(onRplName: "OnBroadcastValueUpdated", condition: RplCondition.Custom, customConditionName: "RpcConditionMethod")] | ||
protected | protected int m_iBroadcastValue; | ||
void OnBroadcastValueUpdated() | void OnBroadcastValueUpdated() | ||
{ | { | ||
// this method will only run on proxies if authority's RpcConditionMethod returns true | // this method will only run on proxies if authority's RpcConditionMethod returns true | ||
} | } | ||
[RplRpc(RplChannel.Reliable, RplRcver.Server)] | [RplRpc(RplChannel.Reliable, RplRcver.Server)] | ||
void RpcAsk_Method() | void RpcAsk_Method() | ||
Line 379: | Line 457: | ||
Replication.BumpMe(); | Replication.BumpMe(); | ||
} | } | ||
bool RpcConditionMethod() | bool RpcConditionMethod() | ||
{ | { | ||
Line 406: | Line 484: | ||
{{Feature|important| | {{Feature|important| | ||
{{hl|RplLoad}} reads data from a provided {{hl|ScriptBitReader}} instance. | {{hl|RplLoad}} reads data from a provided {{hl|ScriptBitReader}} instance. | ||
Reading from it '''must''' be done in the same order and with the same number of bits than the writing that happened in {{hl|RplSave | Reading from it '''must''' be done in the same order and with the same number of bits than the writing that happened in {{hl|RplSave}}, otherwise data discrepancy may happen and behaviour is not guaranteed. | ||
}} | }} | ||
Line 438: | Line 516: | ||
[RplProp()] | [RplProp()] | ||
protected int m_iValue; | protected int m_iValue; | ||
[RplRpc(RplChannel.Reliable, RplRcver.Server)] | [RplRpc(RplChannel.Reliable, RplRcver.Server)] | ||
protected void RpcAsk_Authority_Method(int newValue) | protected void RpcAsk_Authority_Method(int newValue) | ||
Line 454: | Line 532: | ||
== Network Modding == | == Network Modding == | ||
Defining codec methods is required when a scripted class is marked with <enforce inline>[RplProp()]</enforce>. It is recommended to | |||
=== Definitions === | === Definitions === | ||
; Codec | |||
: A '''Cod'''er-'''Dec'''oder - an element that is in charge of encoding/decoding data | |||
; Snapshot | ; Snapshot | ||
Line 471: | Line 554: | ||
{ | { | ||
//! From snapshot to packet. | //! From snapshot to packet. | ||
// Takes snapshot and compresses it into packet. Opposite of Decode() | |||
static void Encode(SSnapSerializerBase snapshot, ScriptCtx ctx, ScriptBitSerializer packet); | static void Encode(SSnapSerializerBase snapshot, ScriptCtx ctx, ScriptBitSerializer packet); | ||
//! From packet to snapshot. | //! From packet to snapshot. | ||
// Takes packet and decompresses it into snapshot. Opposite of Encode() | |||
static bool Decode(ScriptBitSerializer packet, ScriptCtx ctx, SSnapSerializerBase snapshot); | static bool Decode(ScriptBitSerializer packet, ScriptCtx ctx, SSnapSerializerBase snapshot); | ||
//! Snapshot to snapshot comparison. | //! Snapshot to snapshot comparison. | ||
// Compares two snapshots to see whether they are the same or not | |||
static bool SnapCompare(SSnapSerializerBase lhs, SSnapSerializerBase rhs, ScriptCtx ctx); | static bool SnapCompare(SSnapSerializerBase lhs, SSnapSerializerBase rhs, ScriptCtx ctx); | ||
//! Property mem to snapshot comparison. | //! Property mem to snapshot comparison. | ||
// Compares instance and a snapshot to see if any property has changed enough to require a new snapshot | |||
static bool PropCompare(CustomClass prop, SSnapSerializerBase snapshot, ScriptCtx ctx); | static bool PropCompare(CustomClass prop, SSnapSerializerBase snapshot, ScriptCtx ctx); | ||
//! Property mem to snapshot extraction. | //! Property mem to snapshot extraction. | ||
// Extracts relevant properties from an instance of type T into snapshot. Opposite of Inject() | |||
static bool Extract(CustomClass prop, ScriptCtx ctx, SSnapSerializerBase snapshot); | static bool Extract(CustomClass prop, ScriptCtx ctx, SSnapSerializerBase snapshot); | ||
//! Snapshot to property memory injection. | //! Snapshot to property memory injection. | ||
// Injects relevant properties from snapshot into an instance of type T . Opposite of Extract() | |||
static bool Inject(SSnapSerializerBase snapshot, ScriptCtx ctx, RplTestPropType prop); | static bool Inject(SSnapSerializerBase snapshot, ScriptCtx ctx, RplTestPropType prop); | ||
} | } | ||
</enforce> | </enforce> | ||
<spoiler text="See a full codec implementation"> | |||
<enforce> | |||
class ComplexType | |||
{ | |||
bool m_bValue; | |||
int m_iValue; | |||
float m_fValue; | |||
vector m_vValue; | |||
// ## Extract/Inject | |||
// Extracting data from instance into snapshot, and injecting data from snapshot to instance. | |||
// Snapshot is meant to be fast to work with, so values are left uncompressed to avoid extra work when accessing these values. | |||
// ## Encode/Decode | |||
// Encoding snapshot into a packet and decoding snapshot from a packet. | |||
// Packets need to be as small as possible, so this process tries to reduce the size as much as it can. | |||
// Knowing what range of values can certain variable have and encoding that range in minimum number of bits required is key. | |||
// If it is to assume the full range of values is needed, helpers that already implement those for different types can be used. | |||
static bool Extract(ComplexType instance, ScriptCtx ctx, SSnapSerializerBase snapshot) | |||
{ | |||
// Fill a snapshot with values from an instance. | |||
snapshot.SerializeBool(instance.m_bValue); | |||
snapshot.SerializeInt(instance.m_iValue); | |||
snapshot.SerializeFloat(instance.m_fValue); | |||
snapshot.SerializeVector(instance.m_vValue); | |||
return true; | |||
} | |||
static bool Inject(SSnapSerializerBase snapshot, ScriptCtx ctx, ComplexType instance) | |||
{ | |||
// Fill an instance with values from snapshot. | |||
snapshot.SerializeBool(instance.m_bValue); | |||
snapshot.SerializeInt(instance.m_iValue); | |||
snapshot.SerializeFloat(instance.m_fValue); | |||
snapshot.SerializeVector(instance.m_vValue); | |||
return true; | |||
} | |||
static void Encode(SSnapSerializerBase snapshot, ScriptCtx ctx, ScriptBitSerializer packet) | |||
{ | |||
// Read values from snapshot, encode them into smaller representation, then | |||
// write them into packet. | |||
snapshot.EncodeBool(packet); // m_bValue | |||
snapshot.EncodeInt(packet); // m_iValue | |||
snapshot.EncodeFloat(packet); // m_fValue | |||
snapshot.EncodeVector(packet); // m_vValue | |||
} | |||
static bool Decode(ScriptBitSerializer packet, ScriptCtx ctx, SSnapSerializerBase snapshot) | |||
{ | |||
// Read values from packet, decode them into their original representation, | |||
// then write them into snapshot. | |||
snapshot.DecodeBool(packet); // m_bValue | |||
snapshot.DecodeInt(packet); // m_iValue | |||
snapshot.DecodeFloat(packet); // m_fValue | |||
snapshot.DecodeVector(packet); // m_vValue | |||
return true; | |||
} | |||
static bool SnapCompare(SSnapSerializerBase lhs, SSnapSerializerBase rhs, ScriptCtx ctx) | |||
{ | |||
// Compare two snapshots and determine whether they are the same. | |||
return lhs.CompareSnapshots(rhs, 4 + 4 + 4 + 12); | |||
} | |||
static bool PropCompare(ComplexType instance, SSnapSerializerBase snapshot, ScriptCtx ctx) | |||
{ | |||
// Determine whether current values in instance are sufficiently different from | |||
// an existing snapshot that it's worth creating new one. | |||
// For float or vector values, it is possible to use some threshold to avoid creating too | |||
// many snapshots due to tiny changes in these values. | |||
return snapshot.CompareBool(instance.m_bValue) | |||
&& snapshot.CompareInt(instance.m_iValue) | |||
&& snapshot.CompareFloat(instance.m_fValue) | |||
&& snapshot.CompareVector(instance.m_vValue); | |||
} | |||
} | |||
</enforce> | |||
</spoiler> | |||
=== Codec Steps === | === Codec Steps === | ||
Line 557: | Line 726: | ||
{ | { | ||
protected bool m_bIsTurnedOn; // this value is edited only on authority's side | protected bool m_bIsTurnedOn; // this value is edited only on authority's side | ||
[RplRpc(RplChannel.Reliable, RplRcver.Server)] | [RplRpc(RplChannel.Reliable, RplRcver.Server)] | ||
protected void RpcAsk_Authority_Method(bool turningOn) | protected void RpcAsk_Authority_Method(bool turningOn) | ||
{ | { | ||
Print("authority-side code"); | Print("authority-side code"); | ||
if (turningOn == m_bIsTurnedOn) // the authority has authority | if (turningOn == m_bIsTurnedOn) // the authority has authority | ||
return; // prevent useless network messages | return; // prevent useless network messages | ||
m_bIsTurnedOn = turningOn; | m_bIsTurnedOn = turningOn; | ||
PlayMusic(turnOn); // play music on authority | PlayMusic(turnOn); // play music on authority | ||
Rpc(RpcDo_Broadcast_Method, turningOn); // send the music broadcast request | Rpc(RpcDo_Broadcast_Method, turningOn); // send the music broadcast request | ||
Rpc(RpcDo_Owner_Method); // run specific code on the owner's entity (that may or may not be the authority) | Rpc(RpcDo_Owner_Method); // run specific code on the owner's entity (that may or may not be the authority) | ||
} | } | ||
[RplRpc(RplChannel.Reliable, RplRcver.Owner)] | [RplRpc(RplChannel.Reliable, RplRcver.Owner)] | ||
protected void RpcDo_Owner_Method() | protected void RpcDo_Owner_Method() | ||
Line 580: | Line 747: | ||
Print("owner-side code"); | Print("owner-side code"); | ||
} | } | ||
[RplRpc(RplChannel.Reliable, RplRcver.Broadcast)] | [RplRpc(RplChannel.Reliable, RplRcver.Broadcast)] | ||
protected void RpcDo_Broadcast_Method(bool turningOn) | protected void RpcDo_Broadcast_Method(bool turningOn) | ||
Line 587: | Line 754: | ||
PlayMusic(turningOn); | PlayMusic(turningOn); | ||
} | } | ||
protected void PlayMusic(bool turningOn) | protected void PlayMusic(bool turningOn) | ||
{ | { | ||
if (turningOn) | if (turningOn) | ||
SomeSoundClass.PlayMusic(this, "OSWelcome"); | SomeSoundClass.PlayMusic(this, "OSWelcome"); | ||
else | else | ||
SomeSoundClass.PlayMusic(this, "OSGoodbye"); | SomeSoundClass.PlayMusic(this, "OSGoodbye"); | ||
} | } | ||
// public methods | // public methods | ||
void TurnOn() | void TurnOn() | ||
{ | { | ||
Rpc(RpcAsk_Authority_Method, true); | Rpc(RpcAsk_Authority_Method, true); | ||
} | } | ||
void TurnOff() | void TurnOff() | ||
{ | { | ||
Line 646: | Line 809: | ||
// if it is set locally, the change will not broadcast and there will be a difference between the proxy and the authority | // if it is set locally, the change will not broadcast and there will be a difference between the proxy and the authority | ||
// this state discrepancy will last until authority's next update broadcast | // this state discrepancy will last until authority's next update broadcast | ||
[RplRpc(RplChannel.Reliable, RplRcver.Server)] | [RplRpc(RplChannel.Reliable, RplRcver.Server)] | ||
protected void RpcAsk_Authority_Method(bool turningOn) | protected void RpcAsk_Authority_Method(bool turningOn) | ||
{ | { | ||
if (turningOn == m_bIsTurnedOn) | if (turningOn == m_bIsTurnedOn) | ||
return; // prevent useless network messages | return; // prevent useless network messages | ||
Print("authority-side code"); | Print("authority-side code"); | ||
m_bIsTurnedOn = turningOn; // m_bIsTurnedOn is changed only in an authority-targeting method | m_bIsTurnedOn = turningOn; // m_bIsTurnedOn is changed only in an authority-targeting method | ||
// it will broadcast over the network automatically due to Replication setting (line 3) | // it will broadcast over the network automatically due to Replication setting (line 3) | ||
SetLedLightColour(); // SetLedLightColour is not automatically called on the authority | SetLedLightColour(); // SetLedLightColour is not automatically called on the authority | ||
Replication.BumpMe(); // tell the Replication system this entity has changes to be broadcast | Replication.BumpMe(); // tell the Replication system this entity has changes to be broadcast | ||
// the Replication system will update the member variable AFTER RpcAsk_Authority_Method is done | // the Replication system will update the member variable AFTER RpcAsk_Authority_Method is done | ||
} | } | ||
protected void OnTurnedOnUpdated() | protected void OnTurnedOnUpdated() | ||
{ | { | ||
Line 671: | Line 832: | ||
SetLedLightColour(); | SetLedLightColour(); | ||
} | } | ||
protected void SetLedLightColour() | protected void SetLedLightColour() | ||
{ | { | ||
if (m_bIsTurnedOn) | if (m_bIsTurnedOn) | ||
SomeLightClass.SetLedLightColour(this, Color.Green); | SomeLightClass.SetLedLightColour(this, Color.Green); | ||
else | else | ||
SomeLightClass.SetLedLightColour(this, Color.Red); | |||
} | } | ||
// public methods | // public methods | ||
void TurnOn() | void TurnOn() | ||
{ | { | ||
if (m_bIsTurnedOn) // m_bIsTurnedOn can be read from any entity | if (m_bIsTurnedOn) // m_bIsTurnedOn can be read from any entity | ||
return; | return; | ||
Rpc(RpcAsk_Authority_Method, true); | Rpc(RpcAsk_Authority_Method, true); | ||
} | } | ||
void TurnOff() | void TurnOff() | ||
{ | { | ||
if (!m_bIsTurnedOn) | if (!m_bIsTurnedOn) | ||
return; | return; | ||
Rpc(RpcAsk_Authority_Method, false); | Rpc(RpcAsk_Authority_Method, false); | ||
} | } | ||
Line 708: | Line 863: | ||
=== RplSave/RplLoad === | === RplSave/RplLoad === | ||
Without {{hl|RplSave}}/{{hl|RplLoad}} override, the following entity would be created with {{hl|m_iSoldierId}}, {{hl| | Without {{hl|RplSave}}/{{hl|RplLoad}} override, the following entity would be created with {{hl|m_iSoldierId}}, {{hl|m_iHealth}} and {{hl|m_bHadLunch}} set to their default value, as these are not decorated with {{hl|RplProp}}. | ||
<enforce> | <enforce> | ||
class SCR_RplTestSoldier : IEntity | class SCR_RplTestSoldier : IEntity | ||
Line 714: | Line 869: | ||
[RplProp()] | [RplProp()] | ||
protected string m_sName = "Player 1"; // joining in progress automatically synchronises RplProp variables | protected string m_sName = "Player 1"; // joining in progress automatically synchronises RplProp variables | ||
protected int m_iSoldierId = 12345678; | protected int m_iSoldierId = 12345678; | ||
protected int m_iHealth = 100; // range 0..100 | protected int m_iHealth = 100; // range 0..100 | ||
protected bool m_bHadLunch = false; | protected bool m_bHadLunch = false; | ||
protected string m_sSoldierDogTag = "PID 1234"; | protected string m_sSoldierDogTag = "PID 1234"; | ||
// Called on the authority when an entity gets streamed | // Called on the authority when an entity gets streamed | ||
override bool RplSave(ScriptBitWriter writer) | override bool RplSave(ScriptBitWriter writer) | ||
{ | { | ||
// m_sName is automatically synchronised, no need to do it manually | // m_sName is automatically synchronised, no need to do it manually | ||
writer.Write(m_iSoldierId, 32); | writer.Write(m_iSoldierId, 32); // write 32 bits of soldier ID - int is 32 bits in size | ||
writer.Write(m_iHealth, 7); | writer.Write(m_iHealth, 7); // write 7 bits of health - 7 bits are enough if the value cannot go over 100 (7 bits range is 0..127) | ||
writer.WriteBool(m_bHadLunch); | writer.WriteBool(m_bHadLunch); // write 1 bit only | ||
writer.WriteString(m_sSoldierDogTag); // write the string - the size varies with the string and characters used | |||
writer. | |||
return true; | return true; | ||
} | } | ||
// Called on the streamed proxy | // Called on the streamed proxy | ||
override bool RplLoad(ScriptBitReader reader) | override bool RplLoad(ScriptBitReader reader) | ||
{ | { | ||
// m_sName is automatically synchronised, no need to do it manually | // m_sName is automatically synchronised, no need to do it manually | ||
if (!reader.Read(m_iSoldierId, 32)) // read 32 bits of data - the authority wrote soldier ID first, so it needs to be read first | if (!reader.Read(m_iSoldierId, 32)) // read 32 bits of data - the authority wrote soldier ID first, so it needs to be read first | ||
return false; | return false; | ||
if (!reader.Read(m_iHealth, 7)) // read 7 bits of data - the authority wrote health second, so it needs to be read second | if (!reader.Read(m_iHealth, 7)) // read 7 bits of data - the authority wrote health second, so it needs to be read second | ||
return false; | return false; | ||
if (!reader.ReadBool(m_bHadLunch)) // read 1 bit only | if (!reader.ReadBool(m_bHadLunch)) // read 1 bit only | ||
return false; | return false; | ||
if (!reader.ReadString(m_sSoldierDogTag)) // read the string - size is managed automatically | |||
if (!reader. | |||
return false; | return false; | ||
return true; | return true; | ||
} | } |
Latest revision as of 15:28, 25 July 2023
Multiplayer Scripting in Enfusion is based on Replication - it determines which machine does what in a situation.
When a Prefab entity is created on the server (and has a replication node set to broadcast), it is replicated on other network machines for them to see a representation of this object. This created representation is called a proxy – more information below.
Network
The Arma Reforger network architecture is a classical one with one server to which clients connect. Clients do not communicate between each others, they communicate with the server which redistributes data.
Server
The Server is the core network machine: it is the central system that receives and redistributes network information. There is only one server per multiplayer game, and the multiplayer game is destroyed if the server loses connection (server role does not get transferred).
Client
A Client is a machine that is connected to the server. A client is everything else that is not the server. A client can join after a game has started (even leave and join again) depending on the scenario. Such client is known as JIP, standing for Join in Progress - see the Join In Progress section below.
Replication
Replication (shortened as RPL) is the name of the system used to replicate an entity or effect on all the concerned machines. For example, when a grenade explodes the damage is calculated on the server, whereas the visual effect is broadcast (replicated) to all the clients.
Remote Procedure Call (shortened as RPC) is the system allowing to queue network messages on other machines.
Preamble
The network structure is based on server-client relationship; Scripting and RPC Replication methods, on the other hand, should be oriented towards Roles - code should be written on authority role principle, server-client principle should be avoided:
- is the entity present on this machine the Authority?
- if not, the local entity is a Proxy
- if so, is it an Owner entity?
See the next chapters for further explanations.
Entity Role
When an entity gets created on a network machine, this entity is the Authority and this role is set in stone; it can never get changed or transferred.
If the network machine is the server, the entity's existence is broadcast to other network machines; the authority (server's entity) is represented on each client by locally-created entities named Proxies (local representation of the authority's reference).
- For an entity created on the server:
- the server hosts the authority entity
- the entity is replicated as proxy on other machines
- ownership can be given and taken by the authority
- For an entity created on a client:
- the client hosts the authority entity
- the server being unaware of it, the entity is not replicated on any network machine
Authority
The Authority is the reference entity.
All mission objects belong to the server; the server has almost if not all the authority entities.
Proxy
A Proxy is an entity that represents an authority on another machine; it only receives entity updates from the authority and cannot send network updates about it - unless the machine has been designated owner (see below).
Owner
An Owner is a special entity role that comes in addition to an authority or a proxy. An owner entity is the entity that has minor rights on the entity such as owner-specific methods. Only one machine can own an entity. The server can be an owner, and ownership can be transferred by the authority.
A client owner is only a machine with an "elevated" proxy access, being able to use RPC methods about this entity towards the authority (and only towards the authority).
Ownership behaviour example:
- a machinegun car exists on the server; the server is hosting the authority and is the owner of it
- a player enters the car as the driver; the host (the server) gives car's ownership to the player's machine, which becomes the owner of the car
- another player enters the car's machinegun; the host (still and always the server) gives machinegun's ownership to this player's machine, which becomes the owner of the car's machinegun entity
- the server keeps authority of this car and its machinegun - it is the one that overrides all clients' positions/states
- when said players leave their respective entities, the server takes ownership back
Replication State
There are two main replication game states which replication distinguishes and which affect some characteristics of replicated items: loadtime state and runtime state. Items inserted into replication while game is loading (ie. at loadtime) are treated as loadtime items, while those inserted once the game is running (ie. at runtime) are treated as runtime items when inserted on server, or local items when inserted on client (as they only exist locally).
for simplicity, this page will use "items" to refer to both entities, components and in general anything else that might be replicated.
Loadtime
Loadtime items are generally entity instances placed in world. These are objects that shouldn't be moved around too much (though some degree of movement is allowed) and usually need to be visible from greater distances. Typical examples are buildings or street signs. Main things to keep in mind:
- They do not require prefab for spawning.
- Their insertion must be deterministic on the server and clients. The server relies on clients to have the same initial world state after the map has been loaded so it can replicate changes from this initial state as they become relevant for a given client, reducing overall traffic (by sending only changes) and spreading the load over time. Clients will still be able to see things in the distance, even though their state has not been perfectly synchronised.
- Replication validates that the initial world state matches. That is, RplId and type information of each loadtime item is the same on client as it initially was on the server. When a mismatch is detected, "inconsistent item table" error will appear in log and client will be disconnected with JIP_ERROR.
- They may be out-of-sync with the server for a long time (possibly through the whole game session). The replication scheduler (running server-side) decides when to stream their current state to each client. When this decision is based on proximity, clients will only get the current state streamed in when they get "close enough" for these changes to be relevant. Because of the world size, this may take time or never happen at all.
- The only exception is complete removal of these items on the server. In that case, removal will be replicated to clients unconditionally.
- As long as the authority exists on the server, the proxy exists on the clients.
- Streaming in synchronizes state of proxy with authority. Once streamed in, proxy starts receiving state updates and it can send and receive RPCs.
- Streaming in synchronizes state of proxy with authority. Once streamed in, proxy starts receiving state updates and it can send and receive RPCs.
Runtime
Runtime items generally come from a game system that creates them during the session (A game mode, Arma Reforger:Game Master, etc). They can move around the map freely and they are usually not visible from far away. Typical examples are vehicles, player characters, collectible items. Main things to keep in mind:
- They require prefab for spawning.
- They may only be inserted on the server. This is the authority.
- Their proxy may or may not exist on a client.
Local Runtime
Local items are items created on client during the session. They can be used for locally predicted effects of player actions, such as firing from rocket launcher immediately creating a flying rocket on client who fired it, instead of waiting for server-side rocket to be streamed to this client. Main things to keep in mind:
- They do not require prefab for spawning.
- They may only be inserted on a client. This is the authority.
- There are no proxies on the server or other clients.
Replication State Override
Replication state override (a.k.a "Rpl State Override") is a RplComponent property that allows modifying the behaviour of spawning and insertion process to behave as-if insertion of node hierarchy happened in the specified state. The currently supported values are:
- None: no override. The state for this node and its descendants at the time of insertion is inherited from its parent node (whether it is Loadtime or Runtime).
- Runtime: The state for this node and its descendants at the time of insertion is overridden to be Runtime.
RPC Call
An RPC call is an entity method's call through the network, e.g from the authority to its proxies (on other machines). Specific targets can be defined, such as "all proxies" or "owner only".
Join In Progress
Join In Progress is the fact of having a client that connects to the server while a multiplayer game is already running.
Streaming
Streaming is the system creating/updating/deleting entities that are relevant to the local machine. An entity is not always present on all machines. Streaming is the way of saving network and CPU process by only sending relevant entities' information.
Consider a server hosting a game with multiple clients, with "player" designating the local player on the local client machine. A car parked 5 km away from the player is not important to them, so only the server and players near the car have this entity's information - it actually does not exist on the player's machine. If someone damages that car, the server is informed and this information is transferred to whomever it is relevant - nearby players, not distant players.
If the player gets close to it, the server decides this car becomes relevant to that client and streams it the proxy's information along with its current state (damage, position, etc).
- Streaming in creates a proxy
- Streaming out destroys this proxy
- While the proxy exists, it receives state updates and can send and receive RPCs.
Relevance
Relevance is a value decided authority-side by the engine that sets whether or not a proxy should be streamed to a network machine or not, in order to save network messages and CPU cycles.
A simple example would be a car that is five kilometres away from a player is not relevant to that player; so the proxy on this player's machine is deleted by the replication system automatically, and re-created/synchronised again when it becomes relevant (e.g close-by) again.
Special Cases
The authority always exists, as it is the reference entity for replication.
The owner entity is always present on its machine; it is never unloaded/reloaded depending on relevance unless ownership is taken away.
Broadcast
An RPC call with broadcast as a target will send the message on machines that have said entity present on their system; as seen above, a proxy owner entity is guaranteed to exist on
Operations Order
Current loading order:
Order | Operation |
---|---|
1 | entity hierarchy creation |
2 | RplLoad operations |
3 | member variable values in unguaranteed order
triggering their respective onRplName methods |
Code
Entity methods get executed with the Rpc method using their RplRpc attribute to determine the targets.
Rpc Method
The Rpc method (present in both GenericEntity and GenericComponent) is the starting point to trigger a network-friendly code call.
The engine will make it so that this method will call the provided one where it needs to be, depending on the RplRpc target method attribute.
By convention, methods that can be called through replication are prefixed with the Rpc_ prefix: e.g Rpc_MyMethod().
the RpcAsk_ prefix is used by the owner to ask the authority to do an action (sender = owner, receiver = authority).
the RpcDo_ prefix is used by the authority to do an action (sender = authority, receiver = owner proxy or all proxies).
Usage
Network-wise, a method RPC is added to a list of "to do tasks"; it means that they might be sent separately, or all in one network packet. The order of the calls between two machines is however guaranteed.
RplRpc Attribute
The RplRpc attribute is to decorate an entity's method, allowing the engine to run said method on targeted machines through the Rpc method.
Usage
Here is RplRpc attribute's signature:
Parameter | Usage | ||||||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
channel | RplChannel enum, can be one of:
| ||||||||||||||||||||||||||||||||||
rcver (receiver) | RplRcver enum, can be one of:
| ||||||||||||||||||||||||||||||||||
condition | RplCondition enum, can be one of:
| ||||||||||||||||||||||||||||||||||
customConditionName | if condition has been set to Custom, customConditionName must be set to the name of the method to be checked. This method must return a bool.
Example: class RplClass
{
[RplProp(onRplName: "OnBroadcastValueUpdated", condition: RplCondition.Custom, customConditionName: "RpcConditionMethod")]
protected int m_iBroadcastValue;
void OnBroadcastValueUpdated()
{
// this method will only run on proxies if authority's RpcConditionMethod returns true
}
[RplRpc(RplChannel.Reliable, RplRcver.Server)]
void RpcAsk_Method()
{
m_iBroadcastValue = 33;
Replication.BumpMe();
}
bool RpcConditionMethod()
{
return m_iBroadcastValue < 50;
}
} |
RplProp Attribute
The RplProp attribute is to decorate an object's property, allowing the engine to synchronise values on network machines.
Only a change on the authority and notifying the replication system with Replication.BumpMe() method will trigger a broadcast to other machines (see the BumpMe section).
Usage
Here is RplProp attribute's signature:
Parameter | Usage |
---|---|
group | RplGroup enum, can be one of:
|
onRplName | The method name to be called on proxies when the property's value is changed on the authority (and synchronised with Replication.BumpMe() method). |
ctx | Script context - engine only, unused script-side |
condition | RplCondition, can be one of:
|
customConditionName | if condition has been set to Custom, customConditionName must be set to the name of the method to be checked. This method must return a bool.
Example: class RplClass
{
[RplProp(onRplName: "OnBroadcastValueUpdated", condition: RplCondition.Custom, customConditionName: "RpcConditionMethod")]
protected int m_iBroadcastValue;
void OnBroadcastValueUpdated()
{
// this method will only run on proxies if authority's RpcConditionMethod returns true
}
[RplRpc(RplChannel.Reliable, RplRcver.Server)]
void RpcAsk_Method()
{
m_iBroadcastValue = 33;
Replication.BumpMe();
}
bool RpcConditionMethod()
{
return m_iBroadcastValue < 50;
}
} |
RplSave/RplLoad
RplSave
RplSave is the method called on the authority's side to write custom synchronisation data.
RplLoad
RplLoad is the method called on the streamed entity after the entity, its components and the whole entities hierarchy to which it belongs has been loaded, if any.
It is called immediately after initialisation but before anything else (EOnFrame, etc).
Replication Class
The Replication class is a very useful Replication tool, holding the following methods (only the most used ones are listed here).
FindId
Return the provided entity's id. should be an RplId
If the entity does not have one, it returns Replication.INVALID_ID.
FindItem
Return the provided id's entity.
If no entities have the provided id, it returns null.
FindOwner
Return the owner machine's network id.
If the entity has no owner id, it returns Replication.INVALID_IDENTITY.
BumpMe
This method tells the Replication system that at least one property has been updated and that the change(s) should be broadcast.
Network Modding
Defining codec methods is required when a scripted class is marked with [RplProp()]. It is recommended to
Definitions
- Codec
- A Coder-Decoder - an element that is in charge of encoding/decoding data
- Snapshot
- An "image" of an object's replicated properties - used by the engine to compare with the current status' snapshot and detect a change
- Packet
- (naming may change) An object's transferrable data - unrelated to network packet
Methods
EnNetwork.c provides an example class with declarable methods overriding the default behaviour. These methods can be written/overridden in any Enforce Script classes.
Codec Steps
On Server | On Client |
---|---|
|
|
Examples
For the sake of the examples, let's assume that:
- the server hosts the ComputerEntity authority entity
- a client hosts the owner entity
RplRpc
In the following code:
- the protected RpcAsk_Authority_Method method is set to be RPC-called on the authority
- the protected RpcDo_Owner_Method method is set to be RPC-called on the owner
- the protected RpcDo_Broadcast_Method method is set to be RPC-called on every proxy
We assume the public TurnOn method has been triggered owner-side, making the following events happen:
- the TurnOn method calls the RpcAsk_Authority_Method through RPC; as stated earlier, this method executes on the authority's machine - the server in this case
- the RpcAsk_Authority_Method method (running on the authority):
- prints "authority-side code" in the authority machine's logs
- calls the PlayMusic method on the authority
- calls the RpcDo_Broadcast_Method method on all the proxies (see below)
- calls the RpcDo_Owner_Method method on the owner's proxy (see below)
- the RpcDo_Broadcast_Method method (running on every proxy, including owner's):
- prints "proxy-side code" in proxy machines' logs
- calls the PlayMusic method on the proxy
- the RpcDo_Owner_Method method (running on the owner's proxy):
- prints "owner-side code"
The end result:
- all the machines' instances:
- called the PlayMusic method and played the "OSWelcome" music
- the authority's machine has
- "authority-side code" in the logs - had the server been the owner too, "owner-side code" would be present as well
- the owner's machine has
- "proxy-side code" then "owner-side code" in the logs (the order is guaranteed)
- all other machines have
- "proxy-side code" in the logs
RplProp
In the following code:
- the m_bIsTurnedOn property is set to update to all the proxies on authority value's modification
- the m_bIsTurnedOn property is set to execute the OnTurnedOnUpdated method on proxies when its value is updated by Replication (JIP included)
We assume the public TurnOn method has been triggered owner-side, making the following events happen:
- the TurnOn method calls the RpcAsk_Authority_Method through RPC; as stated earlier, this method executes on the authority's machine - the server in this case
- the RpcAsk_Authority_Method method (running on the server):
- sets LED colour on the server
- sets the m_bIsTurnedOn property to "true" on the authority; as the m_bIsTurnedOn property is set to broadcast its changes thanks to the RplProp attribute, the change is broadcast to every proxy machine
- the OnTurnedOn method is triggered on proxies and "The proxy has been updated" is printed
The end result:
- all the machines' instances:
- have the m_bIsTurnedOn property set to "true"
- have their light set to green
- the authority:
- printed "authority-side code"
- all the proxies:
- printed "proxy-side code"
RplSave/RplLoad
Without RplSave/RplLoad override, the following entity would be created with m_iSoldierId, m_iHealth and m_bHadLunch set to their default value, as these are not decorated with RplProp.