sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-07-19 23:11:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

Measure lock times: wgIface, relayMgr, ingressGwMgr, eventStreams

Browse Source
This commit is contained in:
Zoltán Papp
2026-06-25 13:33:49 +02:00
parent 0afe52cfeb
commit 50ff095d68
1 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
client/internal/peer/status.go
View File

@@ -1020,6 +1020,11 @@ func (d *Status) GetSignalState() SignalState {
// GetRelayStates returns the stun/turn/permanent relay states
func (d *Status) GetRelayStates() []relay.ProbeResult {
d.muxRelays.RLock()
// debug lines
started := time.Now()
defer debugElapsed("GetRelayStates", started)
if d.relayMgr == nil {
defer d.muxRelays.RUnlock()
return d.relayStates
@@ -1059,6 +1064,11 @@ func (d *Status) GetRelayStates() []relay.ProbeResult {
func (d *Status) ForwardingRules() []firewall.ForwardRule {
d.mux.RLock()
// debug lines
started := time.Now()
defer debugElapsed("ForwardingRules", started)
defer d.mux.RUnlock()
if d.ingressGwMgr == nil {
return nil
@@ -1211,6 +1221,11 @@ func (d *Status) PublishEvent(
}
d.eventMux.Lock()
// debug lines
started := time.Now()
defer debugElapsed("PublishEvent", started)
defer d.eventMux.Unlock()
d.eventQueue.Add(event)
@@ -1270,6 +1285,11 @@ func (d *Status) SetWgIface(wgInterface WGIfaceStatus) {
func (d *Status) PeersStatus() (*configurer.Stats, error) {
d.mux.RLock()
// debug lines
started := time.Now()
defer debugElapsed("PeersStatus", started)
defer d.mux.RUnlock()
if d.wgIface == nil {
return nil, fmt.Errorf("wgInterface is nil, cannot retrieve peers status")
@@ -1283,6 +1303,11 @@ func (d *Status) PeersStatus() (*configurer.Stats, error) {
// transfer statistics in status reports without running full health probes.
func (d *Status) RefreshWireGuardStats() error {
d.mux.Lock()
// debug lines
started := time.Now()
defer debugElapsed("RefreshWireGuardStats", started)
defer d.mux.Unlock()
if d.wgIface == nil {
@@ -1447,3 +1472,9 @@ func (fs FullStatus) ToProto() *proto.FullStatus {
return &pbFullStatus
}
func debugElapsed(msg string, startTime time.Time) {
if elapsed := time.Since(startTime); elapsed > 1*time.Second {
log.Infof("run %s took %s", msg, elapsed)
}
}