Skip to content

Commit 6b78f32

Browse files
jeffreyrainy0xFA11
andauthored
refactor: snapshot. merge preparation. Removing old acks, removing unused varia… (#1013)
* snapshot: merge preparation. Removing old acks, removing unused variables * feat: snapshot. merge preparation. Removing old acks, removing unused variables Co-authored-by: M. Fatih MAR <[email protected]>
1 parent 9c73270 commit 6b78f32

File tree

4 files changed

+0
-26
lines changed

4 files changed

+0
-26
lines changed

com.unity.multiplayer.mlapi/Runtime/Core/SnapshotSystem.cs

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -472,8 +472,6 @@ public void ReadSnapshot(ulong clientId, Stream snapshotStream)
472472
snapshot.ReadIndex(reader);
473473
snapshot.ReadBuffer(reader, snapshotStream);
474474
}
475-
476-
SendAck(clientId, snapshotTick);
477475
}
478476

479477
public void ReadAck(ulong clientId, Stream snapshotStream)
@@ -485,21 +483,6 @@ public void ReadAck(ulong clientId, Stream snapshotStream)
485483
}
486484
}
487485

488-
public void SendAck(ulong clientId, int tick)
489-
{
490-
var context = m_NetworkManager.MessageQueueContainer.EnterInternalCommandContext(
491-
MessageQueueContainer.MessageType.SnapshotAck, NetworkChannel.SnapshotExchange,
492-
new[] { clientId }, NetworkUpdateLoop.UpdateStage);
493-
494-
if (context != null)
495-
{
496-
using (var nonNullContext = (InternalCommandContext)context)
497-
{
498-
nonNullContext.NetworkWriter.WriteInt32Packed(tick);
499-
}
500-
}
501-
}
502-
503486
// todo --M1--
504487
// This is temporary debugging code. Once the feature is complete, we can consider removing it
505488
// But we could also leave it in in debug to help developers

com.unity.multiplayer.mlapi/Runtime/Messaging/InternalMessageHandler.cs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -397,11 +397,6 @@ internal static void HandleSnapshot(ulong clientId, Stream messageStream)
397397
NetworkManager.Singleton.SnapshotSystem.ReadSnapshot(clientId, messageStream);
398398
}
399399

400-
internal static void HandleAck(ulong clientId, Stream messageStream)
401-
{
402-
NetworkManager.Singleton.SnapshotSystem.ReadAck(clientId, messageStream);
403-
}
404-
405400
public void HandleAllClientsSwitchSceneCompleted(ulong clientId, Stream stream)
406401
{
407402
using (var reader = PooledNetworkReader.Get(stream))

com.unity.multiplayer.mlapi/Runtime/Messaging/MessageQueue/MessageQueueContainer.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@ public enum MessageType
3333
NamedMessage,
3434
ServerLog,
3535
SnapshotData,
36-
SnapshotAck,
3736
NetworkVariableDelta,
3837
SwitchScene,
3938
ClientSwitchSceneCompleted,

com.unity.multiplayer.mlapi/Runtime/Messaging/MessageQueue/MessageQueueProcessor.cs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -120,9 +120,6 @@ public void ProcessMessage(in MessageFrameItem item)
120120
case MessageQueueContainer.MessageType.SnapshotData:
121121
InternalMessageHandler.HandleSnapshot(item.NetworkId, item.NetworkBuffer);
122122
break;
123-
case MessageQueueContainer.MessageType.SnapshotAck:
124-
InternalMessageHandler.HandleAck(item.NetworkId, item.NetworkBuffer);
125-
break;
126123
case MessageQueueContainer.MessageType.NetworkVariableDelta:
127124
m_NetworkManager.MessageHandler.HandleNetworkVariableDelta(item.NetworkId, item.NetworkBuffer);
128125
break;

0 commit comments

Comments
 (0)