From fa9f135a9d9d25074e77217667a021faa0382999 Mon Sep 17 00:00:00 2001 From: Alipebt <1160756683@qq.com> Date: Mon, 3 Apr 2023 20:33:52 +0800 Subject: [PATCH] Add reset() to ResetBucketTo() (#403) Signed-off-by: Alipebt <1160756683@qq.com> --- core/stat/base/bucket_leap_array.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/stat/base/bucket_leap_array.go b/core/stat/base/bucket_leap_array.go index 33beaaafd..cd9f89bd1 100644 --- 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 }