@@ -20,7 +20,7 @@ import (
 )
 
 var (
-	ErrDestinationClosed      = fmt.Errorf("destination closed: %w", errEndpointClosed)
+	ErrDestinationClosed      = fmt.Errorf("destination closed: %w: %w", errEndpointClosed, net.ErrClosed)
 	errDestinationConnUpdated = errors.New("destination connection updated")
 	errDestinationConnRemoved = errors.New("destination connection removed")
 )
@@ -71,7 +71,7 @@ func (d *Destination) AcceptContext(ctx context.Context) (net.Conn, error) {
 		return nil, ctx.Err()
 	case conn, ok := <-d.acceptCh:
 		if !ok {
-			return nil, fmt.Errorf("destination %s is closed: %w", d.cfg.Endpoint, net.ErrClosed)
+			return nil, fmt.Errorf("destination %s is closed: %w", d.cfg.Endpoint, ErrDestinationClosed)
 		}
 		return conn, nil
 	}
 
@@ -293,11 +293,11 @@ func TestE2E(t *testing.T) {
 		require.Empty(t, cl.Sources())
 
 		acceptConn, acceptErr := dst.Accept()
-		require.ErrorIs(t, acceptErr, net.ErrClosed)
+		require.ErrorIs(t, acceptErr, connet.ErrDestinationClosed)
 		require.Nil(t, acceptConn)
 
 		dialConn, dialErr := src.Dial("", "")
-		require.ErrorIs(t, dialErr, connet.ErrSourceNoActiveDestinations)
+		require.ErrorIs(t, dialErr, connet.ErrSourceClosed)
 		require.Nil(t, dialConn)
 	})
 	t.Run("cancel-client", func(t *testing.T) {
@@ -333,11 +333,11 @@ func TestE2E(t *testing.T) {
 		require.Empty(t, cl.Sources())
 
 		acceptConn, acceptErr := dst.Accept()
-		require.ErrorIs(t, acceptErr, net.ErrClosed)
+		require.ErrorIs(t, acceptErr, connet.ErrDestinationClosed)
 		require.Nil(t, acceptConn)
 
 		dialConn, dialErr := src.Dial("", "")
-		require.ErrorIs(t, dialErr, connet.ErrSourceNoActiveDestinations)
+		require.ErrorIs(t, dialErr, connet.ErrSourceClosed)
 		require.Nil(t, dialConn)
 	})
 	t.Run("close-dst", func(t *testing.T) {
 
@@ -27,7 +27,7 @@ import (
 )
 
 var (
-	ErrSourceClosed               = fmt.Errorf("source closed: %w", errEndpointClosed)
+	ErrSourceClosed               = fmt.Errorf("source closed: %w: %w", errEndpointClosed, net.ErrClosed)
 	ErrSourceConnect              = errors.New("cannot connect destination")
 	ErrSourceConnectDestinations  = fmt.Errorf("%w: all peer connections were unreachable", ErrSourceConnect)
 	ErrSourceNoActiveDestinations = fmt.Errorf("%w: no active peer connections", ErrSourceConnect)
@@ -88,6 +88,10 @@ func (s *Source) Dial(network, address string) (net.Conn, error) {
 // DialContext dials into any available destination. Both network and address are ignored.
 // Blocks until connection can be established.
 func (s *Source) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
+	if err := s.ep.ctx.Err(); err != nil {
+		return nil, fmt.Errorf("dial context: %w", context.Cause(s.ep.ctx))
+	}
+
 	if s.cfg.DestinationPolicy == NoPolicy {
 		conns, err := s.findActive()
 		if err != nil {
@@ -157,6 +161,20 @@ func (s *Source) runActive(ctx context.Context) {
 }
 
 func (s *Source) runActiveErr(ctx context.Context) error {
+	defer func() {
+		s.conns.Store(new([]sourceConn))
+	}()
+
+	isConnsTracking := s.cfg.DestinationPolicy == LeastConnsPolicy
+	if isConnsTracking {
+		defer func() {
+			s.connsTrackingMu.Lock()
+			defer s.connsTrackingMu.Unlock()
+
+			s.connsTracking = map[peerID]*atomic.Int32{}
+		}()
+	}
+
 	return s.ep.peer.activeConnsListen(ctx, func(active map[peerConnKey]*quic.Conn) error {
 		s.logger.Debug("active conns", "len", len(active))
 
@@ -166,7 +184,7 @@ func (s *Source) runActiveErr(ctx context.Context) error {
 		}
 		s.conns.Store(&conns)
 
-		if s.connsTracking != nil {
+		if isConnsTracking {
 			activePeers := map[peerID]struct{}{}
 			for peer := range active {
 				activePeers[peer.id] = struct{}{}
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ import (`
`20`	`20`	`)`
`21`	`21`
`22`	`22`	`var (`
`23`		`- ErrDestinationClosed = fmt.Errorf("destination closed: %w", errEndpointClosed)`
	`23`	`+ ErrDestinationClosed = fmt.Errorf("destination closed: %w: %w", errEndpointClosed, net.ErrClosed)`
`24`	`24`	`errDestinationConnUpdated = errors.New("destination connection updated")`
`25`	`25`	`errDestinationConnRemoved = errors.New("destination connection removed")`
`26`	`26`	`)`
`@@ -71,7 +71,7 @@ func (d *Destination) AcceptContext(ctx context.Context) (net.Conn, error) {`
`71`	`71`	`return nil, ctx.Err()`
`72`	`72`	`case conn, ok := <-d.acceptCh:`
`73`	`73`	`if !ok {`
`74`		`- return nil, fmt.Errorf("destination %s is closed: %w", d.cfg.Endpoint, net.ErrClosed)`
	`74`	`+ return nil, fmt.Errorf("destination %s is closed: %w", d.cfg.Endpoint, ErrDestinationClosed)`
`75`	`75`	`}`
`76`	`76`	`return conn, nil`
`77`	`77`	`}`