mirror of https://github.com/bjdgyc/anylink.git
优化代码
This commit is contained in:
parent
ea7a487c26
commit
c6ef0a28b4
|
@ -117,10 +117,18 @@ func checkSession() {
|
||||||
// 状态为过期的用户踢下线
|
// 状态为过期的用户踢下线
|
||||||
func CloseUserLimittimeSession() {
|
func CloseUserLimittimeSession() {
|
||||||
s := mapset.NewSetFromSlice(dbdata.CheckUserlimittime())
|
s := mapset.NewSetFromSlice(dbdata.CheckUserlimittime())
|
||||||
|
limitTimeToken := []string{}
|
||||||
|
sessMux.RLock()
|
||||||
for _, v := range sessions {
|
for _, v := range sessions {
|
||||||
|
v.mux.RLock()
|
||||||
if v.IsActive && s.Contains(v.Username) {
|
if v.IsActive && s.Contains(v.Username) {
|
||||||
CloseSess(v.Token)
|
limitTimeToken = append(limitTimeToken, v.Token)
|
||||||
}
|
}
|
||||||
|
v.mux.RUnlock()
|
||||||
|
}
|
||||||
|
sessMux.RUnlock()
|
||||||
|
for _, v := range limitTimeToken {
|
||||||
|
CloseSess(v)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue