GuanM/XrayR
1
0
Fork 0
mirror of https://github.com/XrayR-project/XrayR.git synced 2025-08-17 14:51:46 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Check Connect Redis Server

Browse Source
This commit is contained in:
AikoCute
2022-11-26 16:13:45 +07:00
parent 86324ff1ae
commit 872eb12d35
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
common/limiter/limiter.go
View File

@@ -48,7 +48,6 @@ func New() *Limiter {
func (l *Limiter) AddInboundLimiter(tag string, nodeSpeedLimit uint64, userList *[]api.UserInfo, globalDeviceLimit *GlobalDeviceLimitConfig) error {
// global limit
if globalDeviceLimit.Limit > 0 {
log.Printf("[%s] GlobalDeviceLimit limit: %d", tag, globalDeviceLimit.Limit)
l.r = redis.NewClient(&redis.Options{
Addr: globalDeviceLimit.RedisAddr,
Password: globalDeviceLimit.RedisPassword,
@@ -57,6 +56,13 @@ func (l *Limiter) AddInboundLimiter(tag string, nodeSpeedLimit uint64, userList
l.g.limit = globalDeviceLimit.Limit
l.g.timeout = globalDeviceLimit.Timeout
l.g.expiry = globalDeviceLimit.Expiry
_, err := l.r.Ping(context.Background()).Result()
if err != nil {
return fmt.Errorf("redis connect failed: %v", err)
} else {
log.Printf("[%s] Redis connect success", tag)
log.Printf("[%s] GlobalDeviceLimit : %d", tag, globalDeviceLimit.Limit)
}
}
inboundInfo := &InboundInfo{