Compare commits

..

4 Commits

Author SHA1 Message Date
世界
66a767d083
Fix ssm-api 2025-07-24 12:22:18 +08:00
世界
9095e5763a
documentation: Bump version 2025-07-24 09:21:30 +08:00
世界
a11384b286
Fix time service wrapper 2025-07-24 09:21:08 +08:00
dyhkwong
9dd9fb27cd
Fix disable_sni nil time func 2025-07-24 09:21:08 +08:00
2 changed files with 19 additions and 7 deletions

View File

@ -2,7 +2,7 @@
icon: material/alert-decagram icon: material/alert-decagram
--- ---
#### 1.12.0-rc.2 #### 1.12.0-rc.3
* Fixes and improvements * Fixes and improvements

View File

@ -50,12 +50,24 @@ func (s *TrafficManager) UpdateUsers(users []string) {
newUserTCPSessions := make(map[string]*atomic.Int64) newUserTCPSessions := make(map[string]*atomic.Int64)
newUserUDPSessions := make(map[string]*atomic.Int64) newUserUDPSessions := make(map[string]*atomic.Int64)
for _, user := range users { for _, user := range users {
newUserUplink[user] = s.userUplinkPackets[user] if counter, loaded := s.userUplink[user]; loaded {
newUserDownlink[user] = s.userDownlinkPackets[user] newUserUplink[user] = counter
newUserUplinkPackets[user] = s.userUplinkPackets[user] }
newUserDownlinkPackets[user] = s.userDownlinkPackets[user] if counter, loaded := s.userDownlink[user]; loaded {
newUserTCPSessions[user] = s.userTCPSessions[user] newUserDownlink[user] = counter
newUserUDPSessions[user] = s.userUDPSessions[user] }
if counter, loaded := s.userUplinkPackets[user]; loaded {
newUserUplinkPackets[user] = counter
}
if counter, loaded := s.userDownlinkPackets[user]; loaded {
newUserDownlinkPackets[user] = counter
}
if counter, loaded := s.userTCPSessions[user]; loaded {
newUserTCPSessions[user] = counter
}
if counter, loaded := s.userUDPSessions[user]; loaded {
newUserUDPSessions[user] = counter
}
} }
s.userUplink = newUserUplink s.userUplink = newUserUplink
s.userDownlink = newUserDownlink s.userDownlink = newUserDownlink