From 31d1fc229cf42ee67a5468489fa4b102543ae238 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Wed, 5 Apr 2023 11:34:15 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9B=E7=A8=8B=E9=80=80=E5=87=BA=E6=97=B6?= =?UTF-8?q?=E5=81=9C=E6=AD=A2=E4=B8=8A=E4=BC=A0=E5=B8=A6=E5=AE=BD=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/stats/bandwidth_stat_manager.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/internal/stats/bandwidth_stat_manager.go b/internal/stats/bandwidth_stat_manager.go index 6db2589..9793869 100644 --- a/internal/stats/bandwidth_stat_manager.go +++ b/internal/stats/bandwidth_stat_manager.go @@ -36,6 +36,8 @@ func init() { }) events.On(events.EventQuit, func() { + SharedBandwidthStatManager.Cancel() + err := SharedBandwidthStatManager.Save() if err != nil { remotelogs.Error("STAT", "save bandwidth stats failed: "+err.Error()) @@ -277,6 +279,11 @@ func (this *BandwidthStatManager) Save() error { return os.WriteFile(this.cacheFile, data, 0666) } +// Cancel 取消上传 +func (this *BandwidthStatManager) Cancel() { + this.ticker.Stop() +} + // 从本地缓存文件中恢复数据 func (this *BandwidthStatManager) recover() { cacheData, err := os.ReadFile(this.cacheFile)