diff --git a/pkg/netceptor/conn.go b/pkg/netceptor/conn.go index 1f2ec1397..be3e6d2e9 100644 --- a/pkg/netceptor/conn.go +++ b/pkg/netceptor/conn.go @@ -37,7 +37,7 @@ type acceptResult struct { type Listener struct { s *Netceptor pc *PacketConn - ql quic.Listener + ql quic.Listener //nolint:typecheck acceptChan chan *acceptResult doneChan chan struct{} doneOnce *sync.Once @@ -89,11 +89,11 @@ func (s *Netceptor) listen(ctx context.Context, service string, tlscfg *tls.Conf pc.startUnreachable() s.Logger.Debug("%s added service %s to listener registry", s.nodeID, service) s.listenerRegistry[service] = pc - cfg := &quic.Config{ + cfg := &quic.Config{ //nolint:typecheck MaxIdleTimeout: MaxIdleTimeoutForQuicConnections, } _ = os.Setenv("QUIC_GO_DISABLE_RECEIVE_BUFFER_WARNING", "1") - ql, err := quic.Listen(pc, tlscfg, cfg) + ql, err := quic.Listen(pc, tlscfg, cfg) //nolint:typecheck if err != nil { return nil, err } @@ -262,8 +262,8 @@ func (li *Listener) Addr() net.Addr { type Conn struct { s *Netceptor pc *PacketConn - qc quic.Connection - qs quic.Stream + qc quic.Connection //nolint:typecheck + qs quic.Stream //nolint:typecheck doneChan chan struct{} doneOnce *sync.Once ctx context.Context @@ -283,7 +283,7 @@ func (s *Netceptor) DialContext(ctx context.Context, node string, service string return nil, err } rAddr := s.NewAddr(node, service) - cfg := &quic.Config{ + cfg := &quic.Config{ //nolint:typecheck HandshakeIdleTimeout: 15 * time.Second, MaxIdleTimeout: MaxIdleTimeoutForQuicConnections, } @@ -319,7 +319,7 @@ func (s *Netceptor) DialContext(ctx context.Context, node string, service string doneChan := make(chan struct{}, 1) go monitorUnreachable(pc, doneChan, rAddr, ccancel) _ = os.Setenv("QUIC_GO_DISABLE_RECEIVE_BUFFER_WARNING", "1") - qc, err := quic.DialContext(cctx, pc, rAddr, s.nodeID, tlscfg, cfg) + qc, err := quic.DialContext(cctx, pc, rAddr, s.nodeID, tlscfg, cfg) //nolint:typecheck if err != nil { close(okChan) pcClose() diff --git a/tests/functional/mesh/lib.go b/tests/functional/mesh/lib.go index 45796f7a8..9bebf64b7 100644 --- a/tests/functional/mesh/lib.go +++ b/tests/functional/mesh/lib.go @@ -347,7 +347,7 @@ func (n *LibNode) StartListeners() error { for _, listenerCfg := range n.ListenerCfgs { switch lcfg := listenerCfg.(type) { - case *backends.TCPListenerCfg: + case *backends.TCPListenerCfg: //nolint:typecheck bi, err = n.TCPListen(listenerCfg) // Record what address we are listening on so we can reuse it if we restart this node