charleslemaux/Mirror
1
0
Fork 0
mirror of https://github.com/MirrorNetworking/Mirror.git synced 2024-11-18 11:00:32 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

NetworkServer: GetEntitySerializationForConnection helper function

Browse Source
This commit is contained in:
vis2k 2021-05-26 18:04:48 +08:00
parent ca319fdb32
commit b4cecccbcb
1 changed files with 42 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
Assets/Mirror/Runtime/NetworkServer.cs
View File

@ -1429,6 +1429,39 @@ static Serialization GetEntitySerialization(NetworkIdentity identity)
return serializations[identity]; return serializations[identity];
} }
// helper function to get the right serialization for a connection
static NetworkWriter GetEntitySerializationForConnection(NetworkIdentity identity, NetworkConnectionToClient connection)
{
// get serialization for this entity (cached)
Serialization serialization = GetEntitySerialization(identity);
// is this entity owned by this connection?
bool owned = identity.connectionToClient == connection;
// send serialized data
// owner writer if owned
if (owned)
{
// was it dirty / did we actually serialize anything?
if (serialization.ownerWritten > 0)
{
return serialization.ownerWriter;
}
}
// observers writer if not owned
else
{
// was it dirty / did we actually serialize anything?
if (serialization.observersWritten > 0)
{
return serialization.observersWriter;
}
}
// nothing was serialized
return null;
}
// helper function to clean up cached serializations // helper function to clean up cached serializations
static void CleanupSerializations() static void CleanupSerializations()
{ {
@ -1476,40 +1509,17 @@ static void BroadcastToConnection(NetworkConnectionToClient connection)
// NetworkServer.Destroy) // NetworkServer.Destroy)
if (identity != null) if (identity != null)
{ {
// get serialization for this entity (cached) // get serialization for this entity viewed by this connection
Serialization serialization = GetEntitySerialization(identity); // (if anything was serialized this time)
NetworkWriter serialization = GetEntitySerializationForConnection(identity, connection);
// is this entity owned by this connection? if (serialization != null)
bool owned = identity.connectionToClient == connection;
// send serialized data
// owner writer if owned
if (owned)
{ {
// was it dirty / did we actually serialize anything? UpdateVarsMessage message = new UpdateVarsMessage
if (serialization.ownerWritten > 0)
{ {
UpdateVarsMessage message = new UpdateVarsMessage netId = identity.netId,
{ payload = serialization.ToArraySegment()
netId = identity.netId, };
payload = serialization.ownerWriter.ToArraySegment() connection.Send(message);
};
connection.Send(message);
}
}
// observers writer if not owned
else
{
// was it dirty / did we actually serialize anything?
if (serialization.observersWritten > 0)
{
UpdateVarsMessage message = new UpdateVarsMessage
{
netId = identity.netId,
payload = serialization.observersWriter.ToArraySegment()
};
connection.Send(message);
}
} }
} }
// spawned list should have no null entries because we // spawned list should have no null entries because we