From 84de659219c590aab9630237d3a1e849f5b9713a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BE=E9=87=8C=28barry=29?= Date: Fri, 12 Jul 2024 12:11:15 +0800 Subject: [PATCH] Fix traffic init time (#10) --- server/dashboard_api.go | 4 ++++ server/service.go | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/server/dashboard_api.go b/server/dashboard_api.go index 4bfc891a..dde35772 100644 --- a/server/dashboard_api.go +++ b/server/dashboard_api.go @@ -457,6 +457,10 @@ func (svr *Service) deleteProxies(w http.ResponseWriter, r *http.Request) { log.Infof("cleared [%d] offline proxies, total [%d] proxies", cleared, total) } +func newProxyTraffic() *proxyTraffic { + return &proxyTraffic{lastTrafficTime: time.Now().Unix()} +} + type proxyTraffic struct { lastTraffic int64 lastTrafficTime int64 diff --git a/server/service.go b/server/service.go index 79c999da..5b0ba8a7 100644 --- a/server/service.go +++ b/server/service.go @@ -749,7 +749,7 @@ func (svr *Service) checkProxyStatusTimer() { if vv, ok := svr.proxyTraffic.Load(info.Name); ok { vv.(*proxyTraffic).Set(info.TodayTrafficOut) } else { - svr.proxyTraffic.Store(info.Name, new(proxyTraffic).Set(info.TodayTrafficOut)) + svr.proxyTraffic.Store(info.Name, newProxyTraffic().Set(info.TodayTrafficOut)) } }