mirror of
https://github.com/netbirdio/netbird.git
synced 2026-04-17 15:56:39 +00:00
33 lines
467 B
Go
33 lines
467 B
Go
package keepalive
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
|
|
"google.golang.org/grpc"
|
|
)
|
|
|
|
type ioMonitor struct {
|
|
mu sync.Mutex
|
|
grpc.ServerStream
|
|
lastSeen time.Time
|
|
}
|
|
|
|
func (l *ioMonitor) sendMsg(m interface{}) error {
|
|
l.updateLastSeen()
|
|
return l.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
func (l *ioMonitor) updateLastSeen() {
|
|
l.mu.Lock()
|
|
defer l.mu.Unlock()
|
|
l.lastSeen = time.Now()
|
|
}
|
|
|
|
func (l *ioMonitor) getLastSeen() time.Time {
|
|
l.mu.Lock()
|
|
t := l.lastSeen
|
|
l.mu.Unlock()
|
|
return t
|
|
}
|