[client] Fix elapsed time calculation when machine is in sleep mode (#4140)

pappz · web-flow · commit 3e6eede1523f · 2025-07-12T11:10:45.000+02:00
diff --git a/client/iface/bind/activity.go b/client/iface/bind/activity.go
@@ -34,14 +34,14 @@ func NewActivityRecorder() *ActivityRecorder {
 }
 
 // GetLastActivities returns a snapshot of peer last activity
-func (r *ActivityRecorder) GetLastActivities() map[string]time.Time {
+func (r *ActivityRecorder) GetLastActivities() map[string]monotime.Time {
 	r.mu.RLock()
 	defer r.mu.RUnlock()
 
-	activities := make(map[string]time.Time, len(r.peers))
+	activities := make(map[string]monotime.Time, len(r.peers))
 	for key, record := range r.peers {
-		unixNano := record.LastActivity.Load()
-		activities[key] = time.Unix(0, unixNano)
+		monoTime := record.LastActivity.Load()
+		activities[key] = monotime.Time(monoTime)
 	}
 	return activities
 }
@@ -51,18 +51,20 @@ func (r *ActivityRecorder) UpsertAddress(publicKey string, address netip.AddrPor
 	r.mu.Lock()
 	defer r.mu.Unlock()
 
-	if pr, exists := r.peers[publicKey]; exists {
-		delete(r.addrToPeer, pr.Address)
-		pr.Address = address
+	var record *PeerRecord
+	record, exists := r.peers[publicKey]
+	if exists {
+		delete(r.addrToPeer, record.Address)
+		record.Address = address
 	} else {
-		record := &PeerRecord{
+		record = &PeerRecord{
 			Address: address,
 		}
-		record.LastActivity.Store(monotime.Now())
+		record.LastActivity.Store(int64(monotime.Now()))
 		r.peers[publicKey] = record
 	}
 
-	r.addrToPeer[address] = r.peers[publicKey]
+	r.addrToPeer[address] = record
 }
 
 func (r *ActivityRecorder) Remove(publicKey string) {
@@ -84,7 +86,7 @@ func (r *ActivityRecorder) record(address netip.AddrPort) {
 		return
 	}
 
-	now := monotime.Now()
+	now := int64(monotime.Now())
 	last := record.LastActivity.Load()
 	if now-last < saveFrequency {
 		return
diff --git a/client/iface/bind/activity_test.go b/client/iface/bind/activity_test.go
@@ -4,6 +4,8 @@ import (
 	"net/netip"
 	"testing"
 	"time"
+
+	"github.com/netbirdio/netbird/monotime"
 )
 
 func TestActivityRecorder_GetLastActivities(t *testing.T) {
@@ -17,11 +19,7 @@ func TestActivityRecorder_GetLastActivities(t *testing.T) {
 		t.Fatalf("Expected activity for peer %s, but got none", peer)
 	}
 
-	if p.IsZero() {
-		t.Fatalf("Expected activity for peer %s, but got zero", peer)
-	}
-
-	if p.Before(time.Now().Add(-2 * time.Minute)) {
+	if monotime.Since(p) > 5*time.Second {
 		t.Fatalf("Expected activity for peer %s to be recent, but got %v", peer, p)
 	}
 }
diff --git a/client/iface/configurer/kernel_unix.go b/client/iface/configurer/kernel_unix.go
@@ -11,6 +11,8 @@ import (
 	log "github.com/sirupsen/logrus"
 	"golang.zx2c4.com/wireguard/wgctrl"
 	"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
+
+	"github.com/netbirdio/netbird/monotime"
 )
 
 var zeroKey wgtypes.Key
@@ -277,6 +279,6 @@ func (c *KernelConfigurer) GetStats() (map[string]WGStats, error) {
 	return stats, nil
 }
 
-func (c *KernelConfigurer) LastActivities() map[string]time.Time {
+func (c *KernelConfigurer) LastActivities() map[string]monotime.Time {
 	return nil
 }
diff --git a/client/iface/configurer/usp.go b/client/iface/configurer/usp.go
@@ -17,6 +17,7 @@ import (
 	"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
 
 	"github.com/netbirdio/netbird/client/iface/bind"
+	"github.com/netbirdio/netbird/monotime"
 	nbnet "github.com/netbirdio/netbird/util/net"
 )
 
@@ -223,7 +224,7 @@ func (c *WGUSPConfigurer) FullStats() (*Stats, error) {
 	return parseStatus(c.deviceName, ipcStr)
 }
 
-func (c *WGUSPConfigurer) LastActivities() map[string]time.Time {
+func (c *WGUSPConfigurer) LastActivities() map[string]monotime.Time {
 	return c.activityRecorder.GetLastActivities()
 }
 
diff --git a/client/iface/device/interface.go b/client/iface/device/interface.go
@@ -8,6 +8,7 @@ import (
 	"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
 
 	"github.com/netbirdio/netbird/client/iface/configurer"
+	"github.com/netbirdio/netbird/monotime"
 )
 
 type WGConfigurer interface {
@@ -19,5 +20,5 @@ type WGConfigurer interface {
 	Close()
 	GetStats() (map[string]configurer.WGStats, error)
 	FullStats() (*configurer.Stats, error)
-	LastActivities() map[string]time.Time
+	LastActivities() map[string]monotime.Time
 }
diff --git a/client/iface/iface.go b/client/iface/iface.go
@@ -21,6 +21,7 @@ import (
 	"github.com/netbirdio/netbird/client/iface/device"
 	"github.com/netbirdio/netbird/client/iface/wgaddr"
 	"github.com/netbirdio/netbird/client/iface/wgproxy"
+	"github.com/netbirdio/netbird/monotime"
 )
 
 const (
@@ -237,7 +238,7 @@ func (w *WGIface) GetStats() (map[string]configurer.WGStats, error) {
 	return w.configurer.GetStats()
 }
 
-func (w *WGIface) LastActivities() map[string]time.Time {
+func (w *WGIface) LastActivities() map[string]monotime.Time {
 	w.mu.Lock()
 	defer w.mu.Unlock()
 
diff --git a/client/internal/conn_mgr.go b/client/internal/conn_mgr.go
@@ -226,7 +226,6 @@ func (e *ConnMgr) ActivatePeer(ctx context.Context, conn *peer.Conn) {
 	}
 
 	if found := e.lazyConnMgr.ActivatePeer(conn.GetKey()); found {
-		conn.Log.Infof("activated peer from inactive state")
 		if err := conn.Open(ctx); err != nil {
 			conn.Log.Errorf("failed to open connection: %v", err)
 		}
diff --git a/client/internal/engine_test.go b/client/internal/engine_test.go
@@ -52,6 +52,7 @@ import (
 	"github.com/netbirdio/netbird/management/server/store"
 	"github.com/netbirdio/netbird/management/server/telemetry"
 	"github.com/netbirdio/netbird/management/server/types"
+	"github.com/netbirdio/netbird/monotime"
 	relayClient "github.com/netbirdio/netbird/relay/client"
 	"github.com/netbirdio/netbird/route"
 	signal "github.com/netbirdio/netbird/signal/client"
@@ -96,7 +97,7 @@ type MockWGIface struct {
 	GetInterfaceGUIDStringFunc func() (string, error)
 	GetProxyFunc               func() wgproxy.Proxy
 	GetNetFunc                 func() *netstack.Net
-	LastActivitiesFunc         func() map[string]time.Time
+	LastActivitiesFunc         func() map[string]monotime.Time
 }
 
 func (m *MockWGIface) FullStats() (*configurer.Stats, error) {
@@ -187,7 +188,7 @@ func (m *MockWGIface) GetNet() *netstack.Net {
 	return m.GetNetFunc()
 }
 
-func (m *MockWGIface) LastActivities() map[string]time.Time {
+func (m *MockWGIface) LastActivities() map[string]monotime.Time {
 	if m.LastActivitiesFunc != nil {
 		return m.LastActivitiesFunc()
 	}
diff --git a/client/internal/iface_common.go b/client/internal/iface_common.go
@@ -14,6 +14,7 @@ import (
 	"github.com/netbirdio/netbird/client/iface/device"
 	"github.com/netbirdio/netbird/client/iface/wgaddr"
 	"github.com/netbirdio/netbird/client/iface/wgproxy"
+	"github.com/netbirdio/netbird/monotime"
 )
 
 type wgIfaceBase interface {
@@ -38,5 +39,5 @@ type wgIfaceBase interface {
 	GetStats() (map[string]configurer.WGStats, error)
 	GetNet() *netstack.Net
 	FullStats() (*configurer.Stats, error)
-	LastActivities() map[string]time.Time
+	LastActivities() map[string]monotime.Time
 }
diff --git a/client/internal/lazyconn/activity/listener.go b/client/internal/lazyconn/activity/listener.go
@@ -48,7 +48,7 @@ func (d *Listener) ReadPackets() {
 		n, remoteAddr, err := d.conn.ReadFromUDP(make([]byte, 1))
 		if err != nil {
 			if d.isClosed.Load() {
-				d.peerCfg.Log.Debugf("exit from activity listener")
+				d.peerCfg.Log.Infof("exit from activity listener")
 			} else {
 				d.peerCfg.Log.Errorf("failed to read from activity listener: %s", err)
 			}
@@ -59,9 +59,11 @@ func (d *Listener) ReadPackets() {
 			d.peerCfg.Log.Warnf("received %d bytes from %s, too short", n, remoteAddr)
 			continue
 		}
+		d.peerCfg.Log.Infof("activity detected")
 		break
 	}
 
+	d.peerCfg.Log.Debugf("removing lazy endpoint: %s", d.endpoint.String())
 	if err := d.removeEndpoint(); err != nil {
 		d.peerCfg.Log.Errorf("failed to remove endpoint: %s", err)
 	}
@@ -71,7 +73,7 @@ func (d *Listener) ReadPackets() {
 }
 
 func (d *Listener) Close() {
-	d.peerCfg.Log.Infof("closing listener: %s", d.conn.LocalAddr().String())
+	d.peerCfg.Log.Infof("closing activity listener: %s", d.conn.LocalAddr().String())
 	d.isClosed.Store(true)
 
 	if err := d.conn.Close(); err != nil {
@@ -81,7 +83,6 @@ func (d *Listener) Close() {
 }
 
 func (d *Listener) removeEndpoint() error {
-	d.peerCfg.Log.Debugf("removing lazy endpoint: %s", d.endpoint.String())
 	return d.wgIface.RemovePeer(d.peerCfg.PublicKey)
 }
 
diff --git a/client/internal/lazyconn/inactivity/manager.go b/client/internal/lazyconn/inactivity/manager.go
@@ -8,6 +8,7 @@ import (
 	log "github.com/sirupsen/logrus"
 
 	"github.com/netbirdio/netbird/client/internal/lazyconn"
+	"github.com/netbirdio/netbird/monotime"
 )
 
 const (
@@ -18,7 +19,7 @@ const (
 )
 
 type WgInterface interface {
-	LastActivities() map[string]time.Time
+	LastActivities() map[string]monotime.Time
 }
 
 type Manager struct {
@@ -124,6 +125,7 @@ func (m *Manager) checkStats() (map[string]struct{}, error) {
 
 	idlePeers := make(map[string]struct{})
 
+	checkTime := time.Now()
 	for peerID, peerCfg := range m.interestedPeers {
 		lastActive, ok := lastActivities[peerID]
 		if !ok {
@@ -132,8 +134,9 @@ func (m *Manager) checkStats() (map[string]struct{}, error) {
 			continue
 		}
 
-		if time.Since(lastActive) > m.inactivityThreshold {
-			peerCfg.Log.Infof("peer is inactive since: %v", lastActive)
+		since := monotime.Since(lastActive)
+		if since > m.inactivityThreshold {
+			peerCfg.Log.Infof("peer is inactive since time: %s", checkTime.Add(-since).String())
 			idlePeers[peerID] = struct{}{}
 		}
 	}
diff --git a/client/internal/lazyconn/inactivity/manager_test.go b/client/internal/lazyconn/inactivity/manager_test.go
@@ -9,22 +9,23 @@ import (
 	"github.com/stretchr/testify/assert"
 
 	"github.com/netbirdio/netbird/client/internal/lazyconn"
+	"github.com/netbirdio/netbird/monotime"
 )
 
 type mockWgInterface struct {
-	lastActivities map[string]time.Time
+	lastActivities map[string]monotime.Time
 }
 
-func (m *mockWgInterface) LastActivities() map[string]time.Time {
+func (m *mockWgInterface) LastActivities() map[string]monotime.Time {
 	return m.lastActivities
 }
 
 func TestPeerTriggersInactivity(t *testing.T) {
 	peerID := "peer1"
 
 	wgMock := &mockWgInterface{
-		lastActivities: map[string]time.Time{
-			peerID: time.Now().Add(-20 * time.Minute),
+		lastActivities: map[string]monotime.Time{
+			peerID: monotime.Time(int64(monotime.Now()) - int64(20*time.Minute)),
 		},
 	}
 
@@ -64,8 +65,8 @@ func TestPeerTriggersActivity(t *testing.T) {
 	peerID := "peer1"
 
 	wgMock := &mockWgInterface{
-		lastActivities: map[string]time.Time{
-			peerID: time.Now().Add(-5 * time.Minute),
+		lastActivities: map[string]monotime.Time{
+			peerID: monotime.Time(int64(monotime.Now()) - int64(5*time.Minute)),
 		},
 	}
 
diff --git a/client/internal/lazyconn/manager/manager.go b/client/internal/lazyconn/manager/manager.go
@@ -258,12 +258,13 @@ func (m *Manager) ActivatePeer(peerID string) (found bool) {
 		return false
 	}
 
+	cfg.Log.Infof("activate peer from inactive state by remote signal message")
+
 	if !m.activateSinglePeer(cfg, mp) {
 		return false
 	}
 
 	m.activateHAGroupPeers(cfg)
-
 	return true
 }
 
@@ -571,12 +572,12 @@ func (m *Manager) onPeerInactivityTimedOut(peerIDs map[string]struct{}) {
 		// this is blocking operation, potentially can be optimized
 		m.peerStore.PeerConnIdle(mp.peerCfg.PublicKey)
 
-		mp.peerCfg.Log.Infof("start activity monitor")
-
 		mp.expectedWatcher = watcherActivity
 
 		m.inactivityManager.RemovePeer(mp.peerCfg.PublicKey)
 
+		mp.peerCfg.Log.Infof("start activity monitor")
+
 		if err := m.activityManager.MonitorPeerActivity(*mp.peerCfg); err != nil {
 			mp.peerCfg.Log.Errorf("failed to create activity monitor: %v", err)
 			continue
diff --git a/client/internal/lazyconn/wgiface.go b/client/internal/lazyconn/wgiface.go
@@ -6,11 +6,13 @@ import (
 	"time"
 
 	"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
+
+	"github.com/netbirdio/netbird/monotime"
 )
 
 type WGIface interface {
 	RemovePeer(peerKey string) error
 	UpdatePeer(peerKey string, allowedIps []netip.Prefix, keepAlive time.Duration, endpoint *net.UDPAddr, preSharedKey *wgtypes.Key) error
 	IsUserspaceBind() bool
-	LastActivities() map[string]time.Time
+	LastActivities() map[string]monotime.Time
 }
diff --git a/monotime/time.go b/monotime/time.go
@@ -9,6 +9,8 @@ var (
 	baseWallNano int64
 )
 
+type Time int64
+
 func init() {
 	baseWallTime = time.Now()
 	baseWallNano = baseWallTime.UnixNano()
@@ -23,7 +25,11 @@ func init() {
 // and using time.Since() for elapsed calculation, this avoids repeated
 // time.Now() calls and leverages Go's internal monotonic clock for
 // efficient duration measurement.
-func Now() int64 {
+func Now() Time {
 	elapsed := time.Since(baseWallTime)
-	return baseWallNano + int64(elapsed)
+	return Time(baseWallNano + int64(elapsed))
+}
+
+func Since(t Time) time.Duration {
+	return time.Duration(Now() - t)
 }

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,8 @@ import (`
`4`	`4`	`"net/netip"`
`5`	`5`	`"testing"`
`6`	`6`	`"time"`
	`7`	`+`
	`8`	`+ "github.com/netbirdio/netbird/monotime"`
`7`	`9`	`)`
`8`	`10`
`9`	`11`	`func TestActivityRecorder_GetLastActivities(t *testing.T) {`
`@@ -17,11 +19,7 @@ func TestActivityRecorder_GetLastActivities(t *testing.T) {`
`17`	`19`	`t.Fatalf("Expected activity for peer %s, but got none", peer)`
`18`	`20`	`}`
`19`	`21`
`20`		`- if p.IsZero() {`
`21`		`- t.Fatalf("Expected activity for peer %s, but got zero", peer)`
`22`		`- }`
`23`		`-`
`24`		`- if p.Before(time.Now().Add(-2 * time.Minute)) {`
	`22`	`+ if monotime.Since(p) > 5*time.Second {`
`25`	`23`	`t.Fatalf("Expected activity for peer %s to be recent, but got %v", peer, p)`
`26`	`24`	`}`
`27`	`25`	`}`
Original file line number	Diff line number	Diff line change
`@@ -11,6 +11,8 @@ import (`
`11`	`11`	`log "github.com/sirupsen/logrus"`
`12`	`12`	`"golang.zx2c4.com/wireguard/wgctrl"`
`13`	`13`	`"golang.zx2c4.com/wireguard/wgctrl/wgtypes"`
	`14`	`+`
	`15`	`+ "github.com/netbirdio/netbird/monotime"`
`14`	`16`	`)`
`15`	`17`
`16`	`18`	`var zeroKey wgtypes.Key`
`@@ -277,6 +279,6 @@ func (c *KernelConfigurer) GetStats() (map[string]WGStats, error) {`
`277`	`279`	`return stats, nil`
`278`	`280`	`}`
`279`	`281`
`280`		`-func (c *KernelConfigurer) LastActivities() map[string]time.Time {`
	`282`	`+func (c *KernelConfigurer) LastActivities() map[string]monotime.Time {`
`281`	`283`	`return nil`
`282`	`284`	`}`
Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,7 @@ import (`
`17`	`17`	`"golang.zx2c4.com/wireguard/wgctrl/wgtypes"`
`18`	`18`
`19`	`19`	`"github.com/netbirdio/netbird/client/iface/bind"`
	`20`	`+ "github.com/netbirdio/netbird/monotime"`
`20`	`21`	`nbnet "github.com/netbirdio/netbird/util/net"`
`21`	`22`	`)`
`22`	`23`
`@@ -223,7 +224,7 @@ func (c WGUSPConfigurer) FullStats() (Stats, error) {`
`223`	`224`	`return parseStatus(c.deviceName, ipcStr)`
`224`	`225`	`}`
`225`	`226`
`226`		`-func (c *WGUSPConfigurer) LastActivities() map[string]time.Time {`
	`227`	`+func (c *WGUSPConfigurer) LastActivities() map[string]monotime.Time {`
`227`	`228`	`return c.activityRecorder.GetLastActivities()`
`228`	`229`	`}`
`229`	`230`
Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,7 @@ import (`
`8`	`8`	`"golang.zx2c4.com/wireguard/wgctrl/wgtypes"`
`9`	`9`
`10`	`10`	`"github.com/netbirdio/netbird/client/iface/configurer"`
	`11`	`+ "github.com/netbirdio/netbird/monotime"`
`11`	`12`	`)`
`12`	`13`
`13`	`14`	`type WGConfigurer interface {`
`@@ -19,5 +20,5 @@ type WGConfigurer interface {`
`19`	`20`	`Close()`
`20`	`21`	`GetStats() (map[string]configurer.WGStats, error)`
`21`	`22`	`FullStats() (*configurer.Stats, error)`
`22`		`- LastActivities() map[string]time.Time`
	`23`	`+ LastActivities() map[string]monotime.Time`
`23`	`24`	`}`
Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,7 @@ import (`
`21`	`21`	`"github.com/netbirdio/netbird/client/iface/device"`
`22`	`22`	`"github.com/netbirdio/netbird/client/iface/wgaddr"`
`23`	`23`	`"github.com/netbirdio/netbird/client/iface/wgproxy"`
	`24`	`+ "github.com/netbirdio/netbird/monotime"`
`24`	`25`	`)`
`25`	`26`
`26`	`27`	`const (`
`@@ -237,7 +238,7 @@ func (w *WGIface) GetStats() (map[string]configurer.WGStats, error) {`
`237`	`238`	`return w.configurer.GetStats()`
`238`	`239`	`}`
`239`	`240`
`240`		`-func (w *WGIface) LastActivities() map[string]time.Time {`
	`241`	`+func (w *WGIface) LastActivities() map[string]monotime.Time {`
`241`	`242`	`w.mu.Lock()`
`242`	`243`	`defer w.mu.Unlock()`
`243`	`244`
Original file line number	Diff line number	Diff line change
`@@ -226,7 +226,6 @@ func (e ConnMgr) ActivatePeer(ctx context.Context, conn peer.Conn) {`
`226`	`226`	`}`
`227`	`227`
`228`	`228`	`if found := e.lazyConnMgr.ActivatePeer(conn.GetKey()); found {`
`229`		`- conn.Log.Infof("activated peer from inactive state")`
`230`	`229`	`if err := conn.Open(ctx); err != nil {`
`231`	`230`	`conn.Log.Errorf("failed to open connection: %v", err)`
`232`	`231`	`}`
Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@ import (`
`14`	`14`	`"github.com/netbirdio/netbird/client/iface/device"`
`15`	`15`	`"github.com/netbirdio/netbird/client/iface/wgaddr"`
`16`	`16`	`"github.com/netbirdio/netbird/client/iface/wgproxy"`
	`17`	`+ "github.com/netbirdio/netbird/monotime"`
`17`	`18`	`)`
`18`	`19`
`19`	`20`	`type wgIfaceBase interface {`
`@@ -38,5 +39,5 @@ type wgIfaceBase interface {`
`38`	`39`	`GetStats() (map[string]configurer.WGStats, error)`
`39`	`40`	`GetNet() *netstack.Net`
`40`	`41`	`FullStats() (*configurer.Stats, error)`
`41`		`- LastActivities() map[string]time.Time`
	`42`	`+ LastActivities() map[string]monotime.Time`
`42`	`43`	`}`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ func (d *Listener) ReadPackets() {`
`48`	`48`	`n, remoteAddr, err := d.conn.ReadFromUDP(make([]byte, 1))`
`49`	`49`	`if err != nil {`
`50`	`50`	`if d.isClosed.Load() {`
`51`		`- d.peerCfg.Log.Debugf("exit from activity listener")`
	`51`	`+ d.peerCfg.Log.Infof("exit from activity listener")`
`52`	`52`	`} else {`
`53`	`53`	`d.peerCfg.Log.Errorf("failed to read from activity listener: %s", err)`
`54`	`54`	`}`
`@@ -59,9 +59,11 @@ func (d *Listener) ReadPackets() {`
`59`	`59`	`d.peerCfg.Log.Warnf("received %d bytes from %s, too short", n, remoteAddr)`
`60`	`60`	`continue`
`61`	`61`	`}`
	`62`	`+ d.peerCfg.Log.Infof("activity detected")`
`62`	`63`	`break`
`63`	`64`	`}`
`64`	`65`
	`66`	`+ d.peerCfg.Log.Debugf("removing lazy endpoint: %s", d.endpoint.String())`
`65`	`67`	`if err := d.removeEndpoint(); err != nil {`
`66`	`68`	`d.peerCfg.Log.Errorf("failed to remove endpoint: %s", err)`
`67`	`69`	`}`
`@@ -71,7 +73,7 @@ func (d *Listener) ReadPackets() {`
`71`	`73`	`}`
`72`	`74`
`73`	`75`	`func (d *Listener) Close() {`
`74`		`- d.peerCfg.Log.Infof("closing listener: %s", d.conn.LocalAddr().String())`
	`76`	`+ d.peerCfg.Log.Infof("closing activity listener: %s", d.conn.LocalAddr().String())`
`75`	`77`	`d.isClosed.Store(true)`
`76`	`78`
`77`	`79`	`if err := d.conn.Close(); err != nil {`
`@@ -81,7 +83,6 @@ func (d *Listener) Close() {`
`81`	`83`	`}`
`82`	`84`
`83`	`85`	`func (d *Listener) removeEndpoint() error {`
`84`		`- d.peerCfg.Log.Debugf("removing lazy endpoint: %s", d.endpoint.String())`
`85`	`86`	`return d.wgIface.RemovePeer(d.peerCfg.PublicKey)`
`86`	`87`	`}`
`87`	`88`