您最多选择25个主题 主题必须以中文或者字母或数字开头,可以包含连字符 (-),并且长度不得超过35个字符

624 行
36 KiB

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.TestTools;
using NUnit.Framework;
using Unity.Netcode.TestHelpers.Runtime;
using Random = UnityEngine.Random;
namespace Unity.Netcode.RuntimeTests
{
[TestFixture(VariableLengthSafety.DisableNetVarSafety, HostOrServer.Host)]
[TestFixture(VariableLengthSafety.EnabledNetVarSafety, HostOrServer.Host)]
[TestFixture(VariableLengthSafety.DisableNetVarSafety, HostOrServer.Server)]
[TestFixture(VariableLengthSafety.EnabledNetVarSafety, HostOrServer.Server)]
public class NetworkObjectSynchronizationTests : NetcodeIntegrationTest
{
private const int k_NumberToSpawn = 30;
protected override int NumberOfClients => 0;
private GameObject m_NetworkPrefab;
private GameObject m_InValidNetworkPrefab;
private GameObject m_SynchronizationPrefab;
private GameObject m_OnSynchronizePrefab;
private VariableLengthSafety m_VariableLengthSafety;
private LogLevel m_CurrentLogLevel;
public enum VariableLengthSafety
{
DisableNetVarSafety,
EnabledNetVarSafety,
}
public NetworkObjectSynchronizationTests(VariableLengthSafety variableLengthSafety, HostOrServer hostOrServer)
{
m_VariableLengthSafety = variableLengthSafety;
m_UseHost = hostOrServer == HostOrServer.Host;
}
protected override void OnCreatePlayerPrefab()
{
m_PlayerPrefab.AddComponent<NetworkBehaviourWithOwnerNetworkVariables>();
base.OnCreatePlayerPrefab();
}
protected override void OnServerAndClientsCreated()
{
// Set the NetworkVariable Safety Check setting
m_ServerNetworkManager.NetworkConfig.EnsureNetworkVariableLengthSafety = m_VariableLengthSafety == VariableLengthSafety.EnabledNetVarSafety;
// Ignore the errors generated during this test (they are expected)
m_ServerNetworkManager.LogLevel = LogLevel.Nothing;
// Disable forcing the same prefabs to avoid failed connections
m_ServerNetworkManager.NetworkConfig.ForceSamePrefabs = false;
// Create the valid network prefab
m_NetworkPrefab = CreateNetworkObjectPrefab("ValidObject");
m_NetworkPrefab.AddComponent<NetworkBehaviourWithNetworkVariables>();
// Create the invalid network prefab (that will fail on client side)
m_InValidNetworkPrefab = CreateNetworkObjectPrefab("InvalidObject");
m_InValidNetworkPrefab.AddComponent<NetworkBehaviourWithNetworkVariables>();
// Create the synchronization network prefab (some pass and some fail)
m_SynchronizationPrefab = CreateNetworkObjectPrefab("SyncObject");
m_SynchronizationPrefab.AddComponent<NetworkBehaviourSynchronizeFailureComponent>();
m_SynchronizationPrefab.AddComponent<NetworkBehaviourWithNetworkVariables>();
m_OnSynchronizePrefab = CreateNetworkObjectPrefab("OnSyncObject");
m_OnSynchronizePrefab.AddComponent<NetworkBehaviourOnSynchronizeComponent>();
base.OnServerAndClientsCreated();
}
protected override void OnNewClientCreated(NetworkManager networkManager)
{
networkManager.NetworkConfig.PlayerPrefab = m_PlayerPrefab;
networkManager.NetworkConfig.EnsureNetworkVariableLengthSafety = m_VariableLengthSafety == VariableLengthSafety.EnabledNetVarSafety;
foreach (var networkPrefab in m_ServerNetworkManager.NetworkConfig.NetworkPrefabs)
{
// To simulate a failure, we exclude the m_InValidNetworkPrefab from the connecting
// client's side.
if (networkPrefab.Prefab.name != m_InValidNetworkPrefab.name)
{
networkManager.NetworkConfig.NetworkPrefabs.Add(networkPrefab);
}
}
// Disable forcing the same prefabs to avoid failed connections
networkManager.NetworkConfig.ForceSamePrefabs = false;
networkManager.LogLevel = m_CurrentLogLevel;
base.OnNewClientCreated(networkManager);
}
[UnityTest]
public IEnumerator NetworkObjectDeserializationFailure()
{
m_CurrentLogLevel = LogLevel.Nothing;
var validSpawnedNetworkObjects = new List<GameObject>();
NetworkBehaviourWithNetworkVariables.ResetSpawnCount();
// Spawn NetworkObjects on the server side with half of them being the
// invalid network prefabs to simulate NetworkObject synchronization failure
for (int i = 0; i < k_NumberToSpawn; i++)
{
if (i % 2 == 0)
{
SpawnObject(m_InValidNetworkPrefab, m_ServerNetworkManager);
}
else
{
// Keep track of the prefabs that should successfully spawn on the client side
validSpawnedNetworkObjects.Add(SpawnObject(m_NetworkPrefab, m_ServerNetworkManager));
}
}
// Assure the server-side spawned all NetworkObjects
yield return WaitForConditionOrTimeOut(() => NetworkBehaviourWithNetworkVariables.ServerSpawnCount == k_NumberToSpawn);
// Now spawn and connect a client that will fail to spawn half of the NetworkObjects spawned
yield return CreateAndStartNewClient();
if (m_UseHost)
{
var serverSideClientPlayerComponent = m_PlayerNetworkObjects[m_ServerNetworkManager.LocalClientId][m_ClientNetworkManagers[0].LocalClientId].GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var serverSideHostPlayerComponent = m_ServerNetworkManager.LocalClient.PlayerObject.GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var clientSidePlayerComponent = m_ClientNetworkManagers[0].LocalClient.PlayerObject.GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var clientSideHostPlayerComponent = m_PlayerNetworkObjects[m_ClientNetworkManagers[0].LocalClientId][m_ServerNetworkManager.LocalClientId].GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
// Validate that the client side player values match the server side value of the client's player
Assert.IsTrue(serverSideClientPlayerComponent.NetworkVariableData1.Value == clientSidePlayerComponent.NetworkVariableData1.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData1)}][Client Player] Client side value ({serverSideClientPlayerComponent.NetworkVariableData1.Value})" +
$" does not equal the server side value ({serverSideClientPlayerComponent.NetworkVariableData1.Value})!");
Assert.IsTrue(serverSideClientPlayerComponent.NetworkVariableData2.Value == clientSidePlayerComponent.NetworkVariableData2.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData2)}][Client Player] Client side value ({serverSideClientPlayerComponent.NetworkVariableData2.Value})" +
$" does not equal the server side value ({serverSideClientPlayerComponent.NetworkVariableData2.Value})!");
Assert.IsTrue(serverSideClientPlayerComponent.NetworkVariableData3.Value == clientSidePlayerComponent.NetworkVariableData3.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData3)}][Client Player] Client side value ({serverSideClientPlayerComponent.NetworkVariableData3.Value})" +
$" does not equal the server side value ({serverSideClientPlayerComponent.NetworkVariableData3.Value})!");
Assert.IsTrue(serverSideClientPlayerComponent.NetworkVariableData4.Value == clientSidePlayerComponent.NetworkVariableData4.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData4)}][Client Player] Client side value ({serverSideClientPlayerComponent.NetworkVariableData4.Value})" +
$" does not equal the server side value ({serverSideClientPlayerComponent.NetworkVariableData4.Value})!");
// Validate that only the 2nd and 4th NetworkVariable on the client side instance of the host's player is the same and the other two do not match
// (i.e. NetworkVariables owned by the server should not get synchronized on client)
Assert.IsTrue(serverSideHostPlayerComponent.NetworkVariableData1.Value != clientSideHostPlayerComponent.NetworkVariableData1.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData1)}][Host Player] Client side value ({serverSideHostPlayerComponent.NetworkVariableData1.Value})" +
$" should not be equal to the server side value ({clientSideHostPlayerComponent.NetworkVariableData1.Value})!");
Assert.IsTrue(serverSideHostPlayerComponent.NetworkVariableData2.Value == clientSideHostPlayerComponent.NetworkVariableData2.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData2)}][Host Player] Client side value ({serverSideHostPlayerComponent.NetworkVariableData2.Value})" +
$" does not equal the server side value ({clientSideHostPlayerComponent.NetworkVariableData2.Value})!");
Assert.IsTrue(serverSideHostPlayerComponent.NetworkVariableData3.Value != clientSideHostPlayerComponent.NetworkVariableData3.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData3)}][Host Player] Client side value ({serverSideHostPlayerComponent.NetworkVariableData3.Value})" +
$" should not be equal to the server side value ({clientSideHostPlayerComponent.NetworkVariableData3.Value})!");
Assert.IsTrue(serverSideHostPlayerComponent.NetworkVariableData4.Value == clientSideHostPlayerComponent.NetworkVariableData4.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData4)}][Host Player] Client side value ({serverSideHostPlayerComponent.NetworkVariableData4.Value})" +
$" does not equal the server side value ({clientSideHostPlayerComponent.NetworkVariableData4.Value})!");
}
else
{
// Spawn and connect another client when running as a server
yield return CreateAndStartNewClient();
yield return WaitForConditionOrTimeOut(() => m_PlayerNetworkObjects[2].Count > 1);
AssertOnTimeout($"Timed out waiting for second client to have access to the first client's cloned player object!");
var clientSide1PlayerComponent = m_ClientNetworkManagers[0].LocalClient.PlayerObject.GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var clientSide2Player1Clone = m_PlayerNetworkObjects[2][clientSide1PlayerComponent.OwnerClientId].GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var clientOneId = clientSide1PlayerComponent.OwnerClientId;
var clientSide2PlayerComponent = m_ClientNetworkManagers[1].LocalClient.PlayerObject.GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var clientSide1Player2Clone = m_PlayerNetworkObjects[1][clientSide2PlayerComponent.OwnerClientId].GetComponent<NetworkBehaviourWithOwnerNetworkVariables>();
var clientTwoId = clientSide2PlayerComponent.OwnerClientId;
// Validate that client one's 2nd and 4th NetworkVariables for the local and clone instances match and the other two do not
Assert.IsTrue(clientSide1PlayerComponent.NetworkVariableData1.Value != clientSide2Player1Clone.NetworkVariableData1.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData1)}][Player-{clientOneId}] Client-{clientOneId} value ({clientSide1PlayerComponent.NetworkVariableData1.Value})" +
$" should not be equal to Client-{clientTwoId}'s clone side value ({clientSide2Player1Clone.NetworkVariableData1.Value})!");
Assert.IsTrue(clientSide1PlayerComponent.NetworkVariableData2.Value == clientSide2Player1Clone.NetworkVariableData2.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData2)}][Player-{clientOneId}] Client-{clientOneId} value ({clientSide1PlayerComponent.NetworkVariableData2.Value})" +
$" does not equal Client-{clientTwoId}'s clone side value ({clientSide2Player1Clone.NetworkVariableData2.Value})!");
Assert.IsTrue(clientSide1PlayerComponent.NetworkVariableData3.Value != clientSide2Player1Clone.NetworkVariableData3.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData3)}][Player-{clientOneId}] Client-{clientOneId} value ({clientSide1PlayerComponent.NetworkVariableData3.Value})" +
$" should not be equal to Client-{clientTwoId}'s clone side value ({clientSide2Player1Clone.NetworkVariableData3.Value})!");
Assert.IsTrue(clientSide1PlayerComponent.NetworkVariableData4.Value == clientSide2Player1Clone.NetworkVariableData4.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData4)}][Player-{clientOneId}] Client-{clientOneId} value ({clientSide1PlayerComponent.NetworkVariableData4.Value})" +
$" does not equal Client-{clientTwoId}'s clone side value ({clientSide2Player1Clone.NetworkVariableData4.Value})!");
// Validate that client two's 2nd and 4th NetworkVariables for the local and clone instances match and the other two do not
Assert.IsTrue(clientSide2PlayerComponent.NetworkVariableData1.Value != clientSide1Player2Clone.NetworkVariableData1.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData1)}][Player-{clientTwoId}] Client-{clientTwoId} value ({clientSide2PlayerComponent.NetworkVariableData1.Value})" +
$" should not be equal to Client-{clientOneId}'s clone side value ({clientSide1Player2Clone.NetworkVariableData1.Value})!");
Assert.IsTrue(clientSide2PlayerComponent.NetworkVariableData2.Value == clientSide1Player2Clone.NetworkVariableData2.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData2)}][Player-{clientTwoId}] Client-{clientTwoId} value ({clientSide2PlayerComponent.NetworkVariableData2.Value})" +
$" does not equal Client-{clientOneId}'s clone side value ({clientSide1Player2Clone.NetworkVariableData2.Value})!");
Assert.IsTrue(clientSide2PlayerComponent.NetworkVariableData3.Value != clientSide1Player2Clone.NetworkVariableData3.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData3)}][Player-{clientTwoId}] Client-{clientTwoId} value ({clientSide2PlayerComponent.NetworkVariableData3.Value})" +
$" should not be equal to Client-{clientOneId}'s clone side value ({clientSide1Player2Clone.NetworkVariableData3.Value})!");
Assert.IsTrue(clientSide2PlayerComponent.NetworkVariableData4.Value == clientSide1Player2Clone.NetworkVariableData4.Value,
$"[{nameof(NetworkBehaviourWithOwnerNetworkVariables.NetworkVariableData4)}][Player-{clientTwoId}] Client-{clientTwoId} value ({clientSide2PlayerComponent.NetworkVariableData4.Value})" +
$" does not equal Client-{clientOneId}'s clone side value ({clientSide1Player2Clone.NetworkVariableData4.Value})!");
}
// Now validate all of the NetworkVariable values match to assure everything synchronized properly
foreach (var spawnedObject in validSpawnedNetworkObjects)
{
foreach (var clientNetworkManager in m_ClientNetworkManagers)
{
//Validate that the connected client has spawned all of the instances that shouldn't have failed.
var clientSideNetworkObjects = s_GlobalNetworkObjects[clientNetworkManager.LocalClientId];
Assert.IsTrue(NetworkBehaviourWithNetworkVariables.ClientSpawnCount[clientNetworkManager.LocalClientId] == validSpawnedNetworkObjects.Count, $"Client-{clientNetworkManager.LocalClientId} spawned " +
$"({NetworkBehaviourWithNetworkVariables.ClientSpawnCount}) {nameof(NetworkObject)}s but the expected number of {nameof(NetworkObject)}s should have been ({validSpawnedNetworkObjects.Count})!");
var spawnedNetworkObject = spawnedObject.GetComponent<NetworkObject>();
Assert.IsTrue(clientSideNetworkObjects.ContainsKey(spawnedNetworkObject.NetworkObjectId), $"Failed to find valid spawned {nameof(NetworkObject)} on the client-side with a " +
$"{nameof(NetworkObject.NetworkObjectId)} of {spawnedNetworkObject.NetworkObjectId}");
var clientSideObject = clientSideNetworkObjects[spawnedNetworkObject.NetworkObjectId];
Assert.IsTrue(clientSideObject.NetworkManager == clientNetworkManager, $"Client-side object {clientSideObject}'s {nameof(NetworkManager)} is not valid!");
ValidateNetworkBehaviourWithNetworkVariables(spawnedNetworkObject, clientSideObject);
}
}
}
private void ValidateNetworkBehaviourWithNetworkVariables(NetworkObject serverSideNetworkObject, NetworkObject clientSideNetworkObject)
{
var serverSideComponent = serverSideNetworkObject.GetComponent<NetworkBehaviourWithNetworkVariables>();
var clientSideComponent = clientSideNetworkObject.GetComponent<NetworkBehaviourWithNetworkVariables>();
string netVarName1 = nameof(NetworkBehaviourWithNetworkVariables.NetworkVariableData1);
string netVarName2 = nameof(NetworkBehaviourWithNetworkVariables.NetworkVariableData1);
string netVarName3 = nameof(NetworkBehaviourWithNetworkVariables.NetworkVariableData1);
string netVarName4 = nameof(NetworkBehaviourWithNetworkVariables.NetworkVariableData1);
Assert.IsTrue(serverSideComponent.NetworkVariableData1.Count == clientSideComponent.NetworkVariableData1.Count, $"[{serverSideComponent.name}:{netVarName1}] Server side {nameof(NetworkList<byte>)} " +
$"count ({serverSideComponent.NetworkVariableData1.Count}) does not match the client side {nameof(NetworkList<byte>)} count ({clientSideComponent.NetworkVariableData1.Count})!");
for (int i = 0; i < serverSideComponent.NetworkVariableData1.Count; i++)
{
Assert.IsTrue(serverSideComponent.NetworkVariableData1[i] == clientSideComponent.NetworkVariableData1[i], $"[{serverSideComponent.name}:{netVarName1}][Index:{i}] Server side instance value " +
$"({serverSideComponent.NetworkVariableData1[i]}) does not match the client side instance value ({clientSideComponent.NetworkVariableData1[i]})!");
}
Assert.IsTrue(serverSideComponent.NetworkVariableData2.Value == clientSideComponent.NetworkVariableData2.Value, $"[{serverSideComponent.name}:{netVarName2}] Server side instance value ({serverSideComponent.NetworkVariableData2.Value}) " +
$"does not match the client side instance value ({clientSideComponent.NetworkVariableData2.Value})!");
Assert.IsTrue(serverSideComponent.NetworkVariableData3.Value == clientSideComponent.NetworkVariableData3.Value, $"[{serverSideComponent.name}:{netVarName3}] Server side instance value ({serverSideComponent.NetworkVariableData3.Value}) " +
$"does not match the client side instance value ({clientSideComponent.NetworkVariableData3.Value})!");
Assert.IsTrue(serverSideComponent.NetworkVariableData4.Value == clientSideComponent.NetworkVariableData4.Value, $"[{serverSideComponent.name}:{netVarName4}] Server side instance value ({serverSideComponent.NetworkVariableData4.Value}) " +
$"does not match the client side instance value ({clientSideComponent.NetworkVariableData4.Value})!");
}
/// <summary>
/// This validates that when a NetworkBehaviour fails serialization or deserialization during synchronizations that other NetworkBehaviours
/// will still be initialized properly
/// </summary>
[UnityTest]
public IEnumerator NetworkBehaviourSynchronization()
{
m_ServerNetworkManager.LogLevel = LogLevel.Normal;
m_CurrentLogLevel = LogLevel.Normal;
NetworkBehaviourSynchronizeFailureComponent.ResetBehaviour();
var spawnedObjectList = new List<GameObject>();
var numberOfObjectsToSpawn = NetworkBehaviourSynchronizeFailureComponent.NumberOfFailureTypes * 4;
// Spawn 11 more NetworkObjects where there should be 4 of each failure type
for (int i = 0; i < numberOfObjectsToSpawn; i++)
{
var synchronizationObject = SpawnObject(m_SynchronizationPrefab, m_ServerNetworkManager);
var synchronizationBehaviour = synchronizationObject.GetComponent<NetworkBehaviourSynchronizeFailureComponent>();
synchronizationBehaviour.AssignNextFailureType();
spawnedObjectList.Add(synchronizationObject);
}
// Now spawn and connect a client that will fail to spawn half of the NetworkObjects spawned
yield return CreateAndStartNewClient();
// Validate that when a NetworkBehaviour fails to synchronize and is skipped over it does not
// impact the rest of the NetworkBehaviours.
var clientSideNetworkObjects = s_GlobalNetworkObjects[m_ClientNetworkManagers[0].LocalClientId];
foreach (var spawnedObject in spawnedObjectList)
{
var serverSideSpawnedNetworkObject = spawnedObject.GetComponent<NetworkObject>();
var clientSideObject = clientSideNetworkObjects[serverSideSpawnedNetworkObject.NetworkObjectId];
var clientSideSpawnedNetworkObject = clientSideObject.GetComponent<NetworkObject>();
ValidateNetworkBehaviourWithNetworkVariables(serverSideSpawnedNetworkObject, clientSideSpawnedNetworkObject);
}
}
/// <summary>
/// A basic validation for the NetworkBehaviour.OnSynchronize method
/// </summary>
[UnityTest]
public IEnumerator NetworkBehaviourOnSynchronize()
{
var serverSideInstance = SpawnObject(m_OnSynchronizePrefab, m_ServerNetworkManager).GetComponent<NetworkBehaviourOnSynchronizeComponent>();
// Now spawn and connect a client that will have custom serialized data applied during the client synchronization process.
yield return CreateAndStartNewClient();
var clientSideNetworkObjects = s_GlobalNetworkObjects[m_ClientNetworkManagers[0].LocalClientId];
var clientSideInstance = clientSideNetworkObjects[serverSideInstance.NetworkObjectId].GetComponent<NetworkBehaviourOnSynchronizeComponent>();
// Validate the values match
Assert.IsTrue(serverSideInstance.CustomSerializationData.Value1 == clientSideInstance.CustomSerializationData.Value1, $"Client-side instance Value1 ({serverSideInstance.CustomSerializationData.Value1}) does not equal server-side instance Value1 ({clientSideInstance.CustomSerializationData.Value1})");
Assert.IsTrue(serverSideInstance.CustomSerializationData.Value2 == clientSideInstance.CustomSerializationData.Value2, $"Client-side instance Value1 ({serverSideInstance.CustomSerializationData.Value2}) does not equal server-side instance Value1 ({clientSideInstance.CustomSerializationData.Value2})");
Assert.IsTrue(serverSideInstance.CustomSerializationData.Value3 == clientSideInstance.CustomSerializationData.Value3, $"Client-side instance Value1 ({serverSideInstance.CustomSerializationData.Value3}) does not equal server-side instance Value1 ({clientSideInstance.CustomSerializationData.Value3})");
Assert.IsTrue(serverSideInstance.CustomSerializationData.Value4 == clientSideInstance.CustomSerializationData.Value4, $"Client-side instance Value1 ({serverSideInstance.CustomSerializationData.Value4}) does not equal server-side instance Value1 ({clientSideInstance.CustomSerializationData.Value4})");
}
}
/// <summary>
/// A test NetworkBeahviour that provides a varying NetworkList size as well as
/// additional NetworkVariables to assure if a NetworkObject fails to be created
/// the synchronization process will continue (i.e. it will skip over that block
/// of the reader buffer).
/// </summary>
public class NetworkBehaviourWithNetworkVariables : NetworkBehaviour
{
public static int ServerSpawnCount { get; internal set; }
public static readonly Dictionary<ulong, int> ClientSpawnCount = new Dictionary<ulong, int>();
public static void ResetSpawnCount()
{
ServerSpawnCount = 0;
ClientSpawnCount.Clear();
}
private const uint k_MinDataBlocks = 1;
private const uint k_MaxDataBlocks = 64;
// Add various types of NetworkVariables
public NetworkList<ulong> NetworkVariableData1;
public NetworkVariable<int> NetworkVariableData2;
public NetworkVariable<long> NetworkVariableData3;
public NetworkVariable<byte> NetworkVariableData4;
private void Awake()
{
var dataBlocksAssigned = new List<ulong>();
var numberDataBlocks = Random.Range(k_MinDataBlocks, k_MaxDataBlocks);
for (var i = 0; i < numberDataBlocks; i++)
{
dataBlocksAssigned.Add((ulong)Random.Range(0.0f, float.MaxValue));
}
NetworkVariableData1 = new NetworkList<ulong>(dataBlocksAssigned);
NetworkVariableData2 = new NetworkVariable<int>(Random.Range(1, 1000));
NetworkVariableData3 = new NetworkVariable<long>(Random.Range(1, 1000));
NetworkVariableData4 = new NetworkVariable<byte>((byte)Random.Range(1, 255));
}
public override void OnNetworkSpawn()
{
if (IsServer)
{
ServerSpawnCount++;
}
else
{
if (!ClientSpawnCount.ContainsKey(NetworkManager.LocalClientId))
{
ClientSpawnCount.Add(NetworkManager.LocalClientId, 0);
}
ClientSpawnCount[NetworkManager.LocalClientId]++;
}
base.OnNetworkSpawn();
}
}
/// <summary>
/// A test NetworkBeahviour that has varying permissions in order to validate that
/// when variable length safety checks are off NetworkVariables still are updated
/// properly.
/// </summary>
public class NetworkBehaviourWithOwnerNetworkVariables : NetworkBehaviour
{
// Should not synchronize on non-owners
public NetworkVariable<int> NetworkVariableData1 = new NetworkVariable<int>(default, NetworkVariableReadPermission.Owner, NetworkVariableWritePermission.Server);
// Should synchronize with everyone
public NetworkVariable<long> NetworkVariableData2 = new NetworkVariable<long>();
// Should not synchronize on non-owners
public NetworkVariable<byte> NetworkVariableData3 = new NetworkVariable<byte>(default, NetworkVariableReadPermission.Owner, NetworkVariableWritePermission.Server);
// Should synchronize with everyone
public NetworkVariable<ushort> NetworkVariableData4 = new NetworkVariable<ushort>();
public override void OnNetworkSpawn()
{
if (IsServer)
{
NetworkVariableData1.Value = Random.Range(1, 1000);
NetworkVariableData2.Value = Random.Range(1, 1000);
NetworkVariableData3.Value = (byte)Random.Range(1, 255);
NetworkVariableData4.Value = (ushort)Random.Range(1, ushort.MaxValue);
}
}
}
/// <summary>
/// A test NetworkBeahviour that simulates various types of synchronization failures
/// and provides a synchronization success version to validate that synchronization
/// will continue if user synchronization code fails.
/// </summary>
public class NetworkBehaviourSynchronizeFailureComponent : NetworkBehaviour
{
public static int NumberOfFailureTypes { get; internal set; }
public static int ServerSpawnCount { get; internal set; }
public static int ClientSpawnCount { get; internal set; }
private static FailureTypes s_FailureType = FailureTypes.None;
public enum FailureTypes
{
None,
DuringWriting,
DuringReading,
DontReadAnything,
ThrowWriteSideException,
ThrowReadSideException
}
public static void ResetBehaviour()
{
ServerSpawnCount = 0;
ClientSpawnCount = 0;
s_FailureType = FailureTypes.None;
NumberOfFailureTypes = System.Enum.GetValues(typeof(FailureTypes)).Length;
}
private MyCustomData m_MyCustomData;
private struct MyCustomData : INetworkSerializable
{
public FailureTypes FailureType;
private ushort m_DataSize;
private byte[] m_DataBlock;
public void NetworkSerialize<T>(BufferSerializer<T> serializer) where T : IReaderWriter
{
if (serializer.IsWriter)
{
var writer = serializer.GetFastBufferWriter();
switch (FailureType)
{
case FailureTypes.None:
// We want to write something for these two cases
case FailureTypes.DuringReading:
case FailureTypes.DontReadAnything:
{
writer.WriteValueSafe(m_DataSize);
for (int i = 0; i < m_DataSize; i++)
{
writer.WriteValueSafe(m_DataBlock[i]);
}
break;
}
case FailureTypes.DuringWriting:
{
writer.WriteValueSafe(m_DataSize);
// Try to write past the allocated size to generate an exception
// while also filling the buffer to verify that the buffer will be
// reset back to the original position.
for (int i = 0; i <= m_DataSize; i++)
{
writer.WriteValueSafe(m_DataBlock[i]);
}
break;
}
case FailureTypes.ThrowWriteSideException:
{
throw new System.Exception("Write side exception!");
}
}
}
else
{
var reader = serializer.GetFastBufferReader();
switch (FailureType)
{
case FailureTypes.None:
{
reader.ReadValueSafe(out m_DataSize);
m_DataBlock = new byte[m_DataSize];
for (int i = 0; i < m_DataSize; i++)
{
reader.ReadValueSafe(out m_DataBlock[i]);
}
break;
}
case FailureTypes.DuringReading:
{
reader.ReadValueSafe(out m_DataSize);
// Allocate more space than needed
m_DataBlock = new byte[(int)(m_DataSize * 1.5f)];
// Now read past the size of this message to verify
// that the reader will get rest back to the appropriate
// position and an error will be generated for this
for (int i = 0; i < m_DataBlock.Length; i++)
{
reader.ReadValueSafe(out m_DataBlock[i]);
}
break;
}
case FailureTypes.DontReadAnything:
{
// Don't read anything
break;
}
case FailureTypes.ThrowReadSideException:
{
throw new System.Exception("Read side exception!");
}
}
}
}
public void GenerateData(ushort size)
{
m_DataSize = size;
m_DataBlock = new byte[size];
for (int i = 0; i < m_DataSize; i++)
{
m_DataBlock[i] = (byte)Random.Range(0, 512);
}
}
}
// This NetworkVariable is synchronized before OnSynchronize is invoked
// which enables us to perform the tests.
// Users could follow the same pattern for game assets and synchronize
// clients based on NetworkVariable settings. (i.e. a specific NPC type or the like)
private NetworkVariable<FailureTypes> m_FailureType;
public void AssignNextFailureType()
{
var currentPosition = (int)s_FailureType;
currentPosition = (++currentPosition) % NumberOfFailureTypes;
s_FailureType = (FailureTypes)currentPosition;
m_FailureType.Value = s_FailureType;
}
private void Awake()
{
m_FailureType = new NetworkVariable<FailureTypes>();
m_MyCustomData = new MyCustomData();
}
public override void OnNetworkSpawn()
{
if (IsServer)
{
ServerSpawnCount++;
m_MyCustomData.GenerateData((ushort)Random.Range(1, 512));
}
else
{
ClientSpawnCount++;
}
base.OnNetworkSpawn();
}
protected override void OnSynchronize<T>(ref BufferSerializer<T> serializer)
{
// Assign the failure type first
m_MyCustomData.FailureType = m_FailureType.Value;
// Now handle the serialization for this failure type
m_MyCustomData.NetworkSerialize(serializer);
}
}
public class NetworkBehaviourOnSynchronizeComponent : NetworkBehaviour
{
public SomeCustomSerializationData CustomSerializationData = new SomeCustomSerializationData();
public struct SomeCustomSerializationData : INetworkSerializable
{
public uint Value1;
public bool Value2;
public long Value3;
public float Value4;
public void NetworkSerialize<T>(BufferSerializer<T> serializer) where T : IReaderWriter
{
serializer.SerializeValue(ref Value1);
serializer.SerializeValue(ref Value2);
serializer.SerializeValue(ref Value3);
serializer.SerializeValue(ref Value4);
}
}
public override void OnNetworkSpawn()
{
if (IsServer)
{
CustomSerializationData.Value1 = (uint)Random.Range(0, 10000);
CustomSerializationData.Value2 = true;
CustomSerializationData.Value3 = Random.Range(0, 10000);
CustomSerializationData.Value4 = Random.Range(-1000.0f, 1000.0f);
}
base.OnNetworkSpawn();
}
protected override void OnSynchronize<T>(ref BufferSerializer<T> serializer)
{
serializer.SerializeNetworkSerializable(ref CustomSerializationData);
base.OnSynchronize(ref serializer);
}
}
}