Ignore received time of late delta

planetarium · May 8, 2019 · c3cd022 · c3cd022
1 parent bd38510
commit c3cd022
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/Libplanet/Net/Swarm.cs b/Libplanet/Net/Swarm.cs
@@ -1354,8 +1354,17 @@ CancellationToken cancellationToken
                 _logger.Debug($"Trying to apply the delta[{delta}]...");
                 await ApplyDelta(delta, cancellationToken);
 
-                LastReceived = delta.Timestamp;
-                LastSeenTimestamps[delta.Sender] = delta.Timestamp;
+                bool alreadyReceived =
+                    LastSeenTimestamps.TryGetValue(
+                        delta.Sender,
+                        out DateTimeOffset existingTimestamp) &&
+                    existingTimestamp > delta.Timestamp;
+
+                if (!alreadyReceived)
+                {
+                    LastReceived = delta.Timestamp;
+                    LastSeenTimestamps[delta.Sender] = delta.Timestamp;
+                }
 
                 DeltaReceived.Set();
             }