GuanM/XrayR
1
0
Fork 0
mirror of https://github.com/XrayR-project/XrayR.git synced 2025-06-08 05:19:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: typo

Browse Source
This commit is contained in:
Senis John 2022-12-11 06:51:25 +08:00
parent 889160b908
commit eea6c0dea6
No known key found for this signature in database
GPG Key ID: 845E9E4727C3E1A4
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
common/limiter/limiter.go
View File

@ -250,18 +250,18 @@ func globalLimit(inboundInfo *InboundInfo, email string, uid int, ip string, dev
// If the ip is not in cache // If the ip is not in cache
if _, ok := (*ipMap)[ip]; !ok { if _, ok := (*ipMap)[ip]; !ok {
(*ipMap)[ip] = uid (*ipMap)[ip] = uid
go pushIP(inboundInfo, email, ipMap) go pushIP(inboundInfo, uniqueKey, ipMap)
} }
return false return false
} }
// push the ip to cache // push the ip to cache
func pushIP(inboundInfo *InboundInfo, email string, ipMap *map[string]int) { func pushIP(inboundInfo *InboundInfo, uniqueKey string, ipMap *map[string]int) {
ctx, cancel := context.WithTimeout(context.Background(), time.Duration(inboundInfo.GlobalLimit.config.Timeout)*time.Second) ctx, cancel := context.WithTimeout(context.Background(), time.Duration(inboundInfo.GlobalLimit.config.Timeout)*time.Second)
defer cancel() defer cancel()
if err := inboundInfo.GlobalLimit.globalOnlineIP.Set(ctx, email, ipMap); err != nil { if err := inboundInfo.GlobalLimit.globalOnlineIP.Set(ctx, uniqueKey, ipMap); err != nil {
newError("cache service").Base(err).AtError().WriteToLog() newError("cache service").Base(err).AtError().WriteToLog()
} }
} }