Ensure that the timestamp is only used if newer.

elastic · Dec 5, 2023 · c1a308b · c1a308b
1 parent 71b5b0e
commit c1a308b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/client/client_v2.go b/pkg/client/client_v2.go
@@ -1101,6 +1101,11 @@ func recvExpectedChunked(client proto.ElasticAgent_CheckinV2Client, chunk bool)
 				// first message in batch
 				initialMsg = msg
 			} else if initialMsg.UnitsTimestamp.AsTime() != msg.UnitsTimestamp.AsTime() {
+				// only used if the new timestamp is newer
+				if initialMsg.UnitsTimestamp.AsTime().After(msg.UnitsTimestamp.AsTime()) {
+					// not newer so we ignore the message
+					continue
+				}
 				// different batch; restart
 				initialMsg = msg
 			}