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

GetEntitySerializationForConnection helper function

Browse Source
This commit is contained in:
vis2k 2021-05-14 18:07:23 +08:00
parent f7b4749b5d
commit 03867e027d
1 changed files with 32 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1404,6 +1404,31 @@ static Serialization GetEntitySerialization(NetworkIdentity identity)
return serializations[identity]; return serializations[identity];
} }
// helper function to get the serialization that should be used for this
// NetworkConnection
// TODO out bytesWritten might not be needed anymore?
static NetworkWriter GetEntitySerializationForConnection(NetworkIdentity identity, NetworkConnection connection, out int bytesWritten)
{
// get serialization for this entity (cached)
Serialization serialization = GetEntitySerialization(identity);
// is this entity owned by this connection?
bool owned = identity.connectionToClient == connection;
// use owner writer if owned
if (owned)
{
bytesWritten = serialization.ownerWritten;
return serialization.ownerWriter;
}
// use observers writer if not owned
else
{
bytesWritten = serialization.observersWritten;
return serialization.observersWriter;
}
}
// avoid allocations in NetworkLateUpdate // avoid allocations in NetworkLateUpdate
static Queue<NetworkConnection> connectionsToDisconnect = new Queue<NetworkConnection>(); static Queue<NetworkConnection> connectionsToDisconnect = new Queue<NetworkConnection>();
@ -1450,32 +1475,15 @@ internal static void NetworkLateUpdate()
if (identity != null) if (identity != null)
{ {
// get serialization for this entity (cached) // get serialization for this entity (cached)
Serialization serialization = GetEntitySerialization(identity); // and this connection (depending on owned)
NetworkWriter serialization = GetEntitySerializationForConnection(identity, connection, out int bytesWritten);
// is this entity owned by this connection?
bool owned = identity.connectionToClient == connection;
// use owner writer if owned
if (owned)
{
// was it dirty / did we actually serialize anything? // was it dirty / did we actually serialize anything?
// TODO always write netId so we know it's still spawned? // TODO always write netId so we know it's still spawned?
if (serialization.ownerWritten > 0) if (bytesWritten > 0)
{ {
writer.WriteUInt32(identity.netId); writer.WriteUInt32(identity.netId);
writer.WriteBytesAndSizeSegment(serialization.ownerWriter.ToArraySegment()); writer.WriteBytesAndSizeSegment(serialization.ToArraySegment());
}
}
// use observers writer if not owned
else
{
// was it dirty / did we actually serialize anything?
// TODO always write netId so we know it's still spawned?
if (serialization.observersWritten > 0)
{
writer.WriteUInt32(identity.netId);
writer.WriteBytesAndSizeSegment(serialization.observersWriter.ToArraySegment());
}
} }
} }
// spawned list should have no null entries because we // spawned list should have no null entries because we