fix a bug

chain/exchange/client.go

@@ -437,9 +437,12 @@ func (c *client) sendRequestToPeer(ctx context.Context, peer peer.ID, req *Reque
 
 	connectionStart := build.Clock.Now()
 
+	sctx, cancel := context.WithTimeout(ctx, streamOpenTimeout)
+	defer cancel()
+
 	// Open stream to peer.
 	stream, err := c.host.NewStream(
-		network.WithNoDial(ctx, "should already have connection"),
+		network.WithNoDial(sctx, "should already have connection"),
 		peer,
 		ChainExchangeProtocolID)
 	if err != nil {

chain/exchange/protocol.go

@@ -39,6 +39,7 @@ const (
 	ShufflePeersPrefix  = 16
 	WriteResDeadline    = 60 * time.Second
 	streamReadDeadline  = 10 * time.Second
+	streamOpenTimeout   = 1 * time.Minute
 )
 
 type Request struct { // FIXME: Rename. Make private.

node/hello/hello.go

@@ -31,6 +31,7 @@ const ProtocolID = "/fil/hello/1.0.0"
 
 var log = logging.Logger("hello")
 var streamDeadline = 10 * time.Second
+var streamOpenTimeout = 1 * time.Minute
 
 type HelloMessage struct {
 	HeaviestTipSet       []cid.Cid
@@ -141,7 +142,9 @@ func (hs *Service) HandleStream(s inet.Stream) {
 }
 
 func (hs *Service) SayHello(ctx context.Context, pid peer.ID) error {
-	s, err := hs.h.NewStream(ctx, pid, ProtocolID)
+	sctx, cancel := context.WithTimeout(ctx, streamOpenTimeout)
+	defer cancel()
+	s, err := hs.h.NewStream(sctx, pid, ProtocolID)
 	if err != nil {
 		return xerrors.Errorf("error opening stream: %w", err)
 	}