remove multistream test

The type ErrNotSupported introduced in
multiformats/go-multistream#114 handles the
lazy handshake fail correctly.

p2p/host/basic/basic_host.go

@@ -717,7 +717,7 @@ func (h *BasicHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.I
 	}
 	defer func() {
 		if strErr != nil && s != nil {
-			s.Reset()
+			s.ResetWithError(network.StreamProtocolNegotiationFailed)
 		}
 	}()
 
@@ -768,6 +768,7 @@ func (h *BasicHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.I
 	}
 
 	if err := s.SetProtocol(selected); err != nil {
+		s.ResetWithError(network.StreamResourceLimitExceeded)
 		return nil, err
 	}
 	_ = h.Peerstore().AddProtocols(p, selected) // adding the protocol to the peerstore isn't critical

p2p/host/basic/basic_host_test.go

@@ -995,35 +995,3 @@ func TestHostTimeoutNewStream(t *testing.T) {
 	require.Error(t, err)
 	require.ErrorContains(t, err, "context deadline exceeded")
 }
-
-func TestMultistreamFailure(t *testing.T) {
-	h1, err := NewHost(swarmt.GenSwarm(t), nil)
-	require.NoError(t, err)
-	h1.Start()
-	defer h1.Close()
-
-	h2, err := NewHost(swarmt.GenSwarm(t), nil)
-	require.NoError(t, err)
-	h2.Start()
-	defer h2.Close()
-
-	h2.Peerstore().AddProtocols(h1.ID(), "/test")
-
-	err = h2.Connect(context.Background(), h1.Peerstore().PeerInfo(h1.ID()))
-	require.NoError(t, err)
-	h2.Peerstore().AddProtocols(h1.ID(), "/test")
-	s, err := h2.NewStream(context.Background(), h1.ID(), "/test")
-	require.NoError(t, err)
-	// Special string to make the other side fail multistream and reset
-	buf := make([]byte, 1024)
-	for i := 0; i < len(buf); i++ {
-		buf[i] = 0xff
-	}
-	_, err = s.Write(buf)
-	require.NoError(t, err)
-	_, err = s.Read(buf)
-	var se *network.StreamError
-	require.ErrorAs(t, err, &se)
-	require.True(t, se.Remote)
-	require.Equal(t, network.StreamProtocolNegotiationFailed, se.ErrorCode)
-}

p2p/net/connmgr/connmgr_test.go

@@ -1024,7 +1024,7 @@ func TestErrorCode(t *testing.T) {
 		}
 		c21 = conns[0]
 		return true
-	}, 5*time.Second, 100*time.Millisecond)
+	}, 10*time.Second, 100*time.Millisecond)
 
 	c13, err := sw1.DialPeer(context.Background(), sw3.LocalPeer())
 	require.NoError(t, err)
@@ -1037,7 +1037,7 @@ func TestErrorCode(t *testing.T) {
 		}
 		c31 = conns[0]
 		return true
-	}, 5*time.Second, 100*time.Millisecond)
+	}, 10*time.Second, 100*time.Millisecond)
 
 	cm.TrimOpenConns(context.Background())