소스 검색

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

Kevin Wan 4 년 전
부모
커밋
57b73d8b49
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      core/collection/rollingwindow.go

+ 1 - 1
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