make sure offset less than size even it's checked inside (zeromicro#354)

kesonan · Mar 1, 2021 · 37b722c · 37b722c
1 parent a3f6978
commit 37b722c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/collection/rollingwindow.go b/core/collection/rollingwindow.go
@@ -87,7 +87,7 @@ func (rw *RollingWindow) updateOffset() {
 	offset := rw.offset
 	// reset expired buckets
 	for i := 0; i < span; i++ {
-		rw.win.resetBucket(offset + i + 1)
+		rw.win.resetBucket((offset + i + 1) % rw.size)
 	}
 
 	rw.offset = (offset + span) % rw.size