extern/netbird
1
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2025-06-21 18:22:37 +02:00
Code Issues Packages Projects Releases Wiki Activity

added logging on lock duration

Browse Source
This commit is contained in:
crn4 2025-06-20 16:00:34 +02:00
parent 853c5abcf8
commit ce8e651eb9
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
management/server/loginfilter.go
View File

@ -6,6 +6,8 @@ import (
"sync" "sync"
"time" "time"
"gvisor.dev/gvisor/pkg/log"
nbpeer "github.com/netbirdio/netbird/management/server/peer" nbpeer "github.com/netbirdio/netbird/management/server/peer"
) )
@ -62,8 +64,12 @@ func newLoginFilterWithCfg(cfg *config) *loginFilter {
} }
func (l *loginFilter) allowLogin(wgPubKey string, metaHash uint64) bool { func (l *loginFilter) allowLogin(wgPubKey string, metaHash uint64) bool {
now := time.Now()
l.mu.RLock() l.mu.RLock()
defer l.mu.RUnlock() defer func() {
l.mu.RUnlock()
log.Infof("allowLogin duration for %s: %v", wgPubKey, time.Since(now))
}()
state, ok := l.logged[wgPubKey] state, ok := l.logged[wgPubKey]
if !ok { if !ok {
return true return true
@ -80,10 +86,13 @@ func (l *loginFilter) allowLogin(wgPubKey string, metaHash uint64) bool {
} }
func (l *loginFilter) addLogin(wgPubKey string, metaHash uint64) { func (l *loginFilter) addLogin(wgPubKey string, metaHash uint64) {
l.mu.Lock()
defer l.mu.Unlock()
now := time.Now() now := time.Now()
l.mu.Lock()
defer func() {
l.mu.Unlock()
log.Infof("addLogin duration for %s: %v", wgPubKey, time.Since(now))
}()
state, ok := l.logged[wgPubKey] state, ok := l.logged[wgPubKey]
if !ok { if !ok {