diff --git a/service/network/proc/pids_by_user.go b/service/network/proc/pids_by_user.go index 7fd451e7..8ea43dc4 100644 --- a/service/network/proc/pids_by_user.go +++ b/service/network/proc/pids_by_user.go @@ -19,7 +19,7 @@ var ( // pidsByUserLock is also used for locking the socketInfo.PID on all socket.*Info structs. pidsByUser = make(map[int][]int) pidsByUserLock sync.RWMutex - fetchPidsByUser = utils.NewCallLimiter(10 * time.Millisecond) + fetchPidsByUser = utils.NewCallLimiter2(10 * time.Millisecond) ) // getPidsByUser returns the cached PIDs for the given UID. diff --git a/service/network/state/tcp.go b/service/network/state/tcp.go index 5d08b054..e3883847 100644 --- a/service/network/state/tcp.go +++ b/service/network/state/tcp.go @@ -25,7 +25,7 @@ type tcpTable struct { // lastUpdateAt stores the time when the tables where last updated as unix nanoseconds. lastUpdateAt atomic.Int64 - fetchLimiter *utils.CallLimiter + fetchLimiter *utils.CallLimiter2 fetchTable func() (connections []*socket.ConnectionInfo, listeners []*socket.BindInfo, err error) dualStack *tcpTable @@ -34,13 +34,13 @@ type tcpTable struct { var ( tcp6Table = &tcpTable{ version: 6, - fetchLimiter: utils.NewCallLimiter(minDurationBetweenTableUpdates), + fetchLimiter: utils.NewCallLimiter2(minDurationBetweenTableUpdates), fetchTable: getTCP6Table, } tcp4Table = &tcpTable{ version: 4, - fetchLimiter: utils.NewCallLimiter(minDurationBetweenTableUpdates), + fetchLimiter: utils.NewCallLimiter2(minDurationBetweenTableUpdates), fetchTable: getTCP4Table, } ) diff --git a/service/network/state/udp.go b/service/network/state/udp.go index 1c534b7f..0dcecc84 100644 --- a/service/network/state/udp.go +++ b/service/network/state/udp.go @@ -24,7 +24,7 @@ type udpTable struct { // lastUpdateAt stores the time when the tables where last updated as unix nanoseconds. lastUpdateAt atomic.Int64 - fetchLimiter *utils.CallLimiter + fetchLimiter *utils.CallLimiter2 fetchTable func() (binds []*socket.BindInfo, err error) states map[string]map[string]*udpState @@ -52,14 +52,14 @@ const ( var ( udp6Table = &udpTable{ version: 6, - fetchLimiter: utils.NewCallLimiter(minDurationBetweenTableUpdates), + fetchLimiter: utils.NewCallLimiter2(minDurationBetweenTableUpdates), fetchTable: getUDP6Table, states: make(map[string]map[string]*udpState), } udp4Table = &udpTable{ version: 4, - fetchLimiter: utils.NewCallLimiter(minDurationBetweenTableUpdates), + fetchLimiter: utils.NewCallLimiter2(minDurationBetweenTableUpdates), fetchTable: getUDP4Table, states: make(map[string]map[string]*udpState), }