Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -17,5 +17,6 @@ internal interface IInternalMessageHandler
void HandleUnnamedMessage(ulong clientId, Stream stream);
void HandleNamedMessage(ulong clientId, Stream stream);
void HandleNetworkLog(ulong clientId, Stream stream);
void HandleSnapshot(ulong clientId, Stream messageStream);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -306,9 +306,9 @@ public void HandleNetworkLog(ulong clientId, Stream stream)
}
}

internal static void HandleSnapshot(ulong clientId, Stream messageStream)
public void HandleSnapshot(ulong clientId, Stream messageStream)
{
NetworkManager.Singleton.SnapshotSystem.ReadSnapshot(clientId, messageStream);
m_NetworkManager.SnapshotSystem.ReadSnapshot(clientId, messageStream);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ public void ProcessMessage(in MessageFrameItem item)

break;
case MessageQueueContainer.MessageType.SnapshotData:
InternalMessageHandler.HandleSnapshot(item.NetworkId, item.NetworkBuffer);
m_NetworkManager.MessageHandler.HandleSnapshot(item.NetworkId, item.NetworkBuffer);
break;
case MessageQueueContainer.MessageType.NetworkVariableDelta:
m_NetworkManager.MessageHandler.HandleNetworkVariableDelta(item.NetworkId, item.NetworkBuffer);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,15 @@ public void HandleNetworkVariableDelta(ulong clientId, Stream stream)
m_HandleNetworkVariableDelta.End();
}

public void HandleSnapshot(ulong clientId, Stream stream)
{
m_HandleNetworkVariableDelta.Begin();

m_MessageHandler.HandleSnapshot(clientId, stream);

m_HandleNetworkVariableDelta.End();
}

public void MessageReceiveQueueItem(ulong clientId, Stream stream, float receiveTime, MessageQueueContainer.MessageType messageType)
{
switch (messageType)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,8 @@ public void MessageReceiveQueueItem(ulong clientId, Stream stream, float receive

public void HandleNetworkLog(ulong clientId, Stream stream) => VerifyCalled(nameof(HandleNetworkLog));

public void HandleSnapshot(ulong clientId, Stream stream) => VerifyCalled(nameof(HandleSnapshot));

public void HandleAllClientsSwitchSceneCompleted(ulong clientId, Stream stream) => VerifyCalled(nameof(HandleAllClientsSwitchSceneCompleted));

private void VerifyCalled(string method)
Expand Down