diff --git a/vpn/serdes.go b/vpn/serdes.go index 0be9247150289..a058ee71e637e 100644 --- a/vpn/serdes.go +++ b/vpn/serdes.go @@ -103,12 +103,16 @@ func (s *serdes[_, _, _]) closeIdempotent() { }) } +// Close closes the serdes +// nolint: revive func (s *serdes[_, _, _]) Close() error { s.closeIdempotent() s.wg.Wait() return nil } +// start starts the goroutines that serialize and deserialize to the conn. +// nolint: revive func (s *serdes[_, _, _]) start() { s.wg.Add(2) go func() { diff --git a/vpn/speaker.go b/vpn/speaker.go index bb6fa9659b6c2..98a623df50e4d 100644 --- a/vpn/speaker.go +++ b/vpn/speaker.go @@ -186,6 +186,7 @@ func (s *speaker[S, R, _]) recvFromSerdes() { } } +// Close closes the speaker // nolint: revive func (s *speaker[_, _, _]) Close() error { s.cancel()