TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-06 18:10:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
刘祥超
2022-10-14 15:00:05 +08:00
parent 7da9363336
commit 1fec88dfc6
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
internal/stats/bandwidth_stat_manager.go
View File

@@ -77,13 +77,13 @@ func (this *BandwidthStatManager) Loop() error {
for key, stat := range this.m { for key, stat := range this.m {
if stat.Day < day || stat.TimeAt < currentTime { if stat.Day < day || stat.TimeAt < currentTime {
pbStats = append(pbStats, &pb.ServerBandwidthStat{ pbStats = append(pbStats, &pb.ServerBandwidthStat{
Id: 0, Id: 0,
UserId: stat.UserId, UserId: stat.UserId,
ServerId: stat.ServerId, ServerId: stat.ServerId,
Day: stat.Day, Day: stat.Day,
TimeAt: stat.TimeAt, TimeAt: stat.TimeAt,
Bytes: stat.MaxBytes / bandwidthTimestampDelim, Bytes: stat.MaxBytes / bandwidthTimestampDelim,
RegionId: regionId, NodeRegionId: regionId,
}) })
delete(this.m, key) delete(this.m, key)
} }

2
internal/stats/traffic_stat_manager.go
View File

@@ -174,7 +174,7 @@ func (this *TrafficStatManager) Upload() error {
pbServerStats = append(pbServerStats, &pb.ServerDailyStat{ pbServerStats = append(pbServerStats, &pb.ServerDailyStat{
ServerId: serverId, ServerId: serverId,
RegionId: config.RegionId, NodeRegionId: config.RegionId,
Bytes: item.Bytes, Bytes: item.Bytes,
CachedBytes: item.CachedBytes, CachedBytes: item.CachedBytes,
CountRequests: item.CountRequests, CountRequests: item.CountRequests,