diff --git a/network/state/info.go b/network/state/info.go index 818efda3..5dbdc788 100644 --- a/network/state/info.go +++ b/network/state/info.go @@ -25,12 +25,12 @@ type Info struct { func GetInfo() *Info { info := &Info{} - info.TCP4Connections, info.TCP4Listeners, _ = tcp4Table.updateTables(0) - info.UDP4Binds, _ = udp4Table.updateTables(0) + info.TCP4Connections, info.TCP4Listeners, _ = tcp4Table.updateTables(tcp4Table.updateIter.Load()) + info.UDP4Binds, _ = udp4Table.updateTables(udp4Table.updateIter.Load()) if netenv.IPv6Enabled() { info.TCP6Connections, info.TCP6Listeners, _ = tcp6Table.updateTables(tcp6Table.updateIter.Load()) - info.UDP6Binds, _ = udp6Table.updateTables(0) + info.UDP6Binds, _ = udp6Table.updateTables(udp6Table.updateIter.Load()) } info.UpdateMeta() diff --git a/network/state/udp.go b/network/state/udp.go index 353ba9b6..1823a371 100644 --- a/network/state/udp.go +++ b/network/state/udp.go @@ -168,11 +168,11 @@ func (table *udpTable) updateTables(previousUpdateIter uint64) ( func CleanUDPStates(_ context.Context) { now := time.Now().UTC() - udp4Table.updateTables(0) + udp4Table.updateTables(udp4Table.updateIter.Load()) udp4Table.cleanStates(now) if netenv.IPv6Enabled() { - udp6Table.updateTables(0) + udp6Table.updateTables(udp6Table.updateIter.Load()) udp6Table.cleanStates(now) } }