fix update inbound failed

This commit is contained in:
yuzuki999
2022-06-06 10:08:02 +08:00
parent df08cd96a0
commit d8bbe7ddaa

View File

@@ -193,18 +193,18 @@ func (c *Controller) nodeInfoMonitor() (err error) {
if newUserInfo != nil { if newUserInfo != nil {
c.userList = newUserInfo c.userList = newUserInfo
} }
err = c.addNewUser(newUserInfo, newNodeInfo) newUserInfo = nil
err = c.addNewUser(c.userList, newNodeInfo)
if err != nil { if err != nil {
log.Print(err) log.Print(err)
return nil return nil
} }
newNodeInfo = nil newNodeInfo = nil
// Add Limiter // Add Limiter
if err := c.AddInboundLimiter(c.Tag, newUserInfo); err != nil { if err := c.AddInboundLimiter(c.Tag, c.userList); err != nil {
log.Print(err) log.Print(err)
return nil return nil
} }
newUserInfo = nil
runtime.GC() runtime.GC()
} else if newUserInfo != nil { } else if newUserInfo != nil {
deleted, added := compareUserList(c.userList, newUserInfo) deleted, added := compareUserList(c.userList, newUserInfo)