Add reset() to ResetBucketTo() (#403)

Alipebt · Alipebt · commit fa9f135a9d9d · 2023-04-03T20:33:52.000+08:00
Signed-off-by: Alipebt &lt;1160756683@qq.com&gt;
diff --git a/core/stat/base/bucket_leap_array.go b/core/stat/base/bucket_leap_array.go
@@ -38,7 +38,8 @@ func (bla *BucketLeapArray) NewEmptyBucket() interface{} {
 
 func (bla *BucketLeapArray) ResetBucketTo(bw *BucketWrap, startTime uint64) *BucketWrap {
 	atomic.StoreUint64(&bw.BucketStart, startTime)
-	bw.Value.Store(NewMetricBucket())
+	mb := bw.Value.Load().(*MetricBucket)
+	mb.reset()
 	return bw
 }
 

Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,8 @@ func (bla *BucketLeapArray) NewEmptyBucket() interface{} {`
`38`	`38`
`39`	`39`	`func (bla BucketLeapArray) ResetBucketTo(bw BucketWrap, startTime uint64) *BucketWrap {`
`40`	`40`	`atomic.StoreUint64(&bw.BucketStart, startTime)`
`41`		`- bw.Value.Store(NewMetricBucket())`
	`41`	`+ mb := bw.Value.Load().(*MetricBucket)`
	`42`	`+ mb.reset()`
`42`	`43`	`return bw`
`43`	`44`	`}`
`44`	`45`