diff --git a/syncapi/sync/requestpool.go b/syncapi/sync/requestpool.go index 3c547dc2e..448b751ce 100644 --- a/syncapi/sync/requestpool.go +++ b/syncapi/sync/requestpool.go @@ -400,6 +400,9 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request, device *userapi. reasonablePositions := findReasonableIncrementalSyncWindow( syncReq.Since, rp.Notifier.CurrentPosition(), ) + // Also update the currentPos, which is used for the retry logic below. + // Otherwise we may skip over some events. + currentPos = reasonablePositions syncReq.Response.NextBatch = types.StreamingToken{ PDUPosition: withTransaction( syncReq.Since.PDUPosition,