add stream timeout

network/libp2p_impl.go

@@ -226,16 +226,18 @@ func (gsnet *libp2pGraphSyncNetwork) handleNewStream(s network.Stream) {
 	reader := msgio.NewVarintReaderSize(s, network.MessageSizeMax)
 	for {
 		p = s.Conn().RemotePeer()
+		_ = s.SetReadDeadline(time.Now().Add(time.Second * 10))
 		received, err := gsnet.messageHandlerSelector.Select(s.Protocol()).FromMsgReader(s.Conn().RemotePeer(), reader)
-
 		if err != nil {
 			if err != io.EOF {
 				_ = s.Reset()
 				go gsnet.receiver.ReceiveError(p, err)
 				log.Debugf("graphsync net handleNewStream from %s error: %s", s.Conn().RemotePeer(), err)
 			}
+			_ = s.SetReadDeadline(time.Time{})
 			return
 		}
+		_ = s.SetReadDeadline(time.Time{})
 
 		ctx := context.Background()
 		log.Debugf("graphsync net handleNewStream from %s", s.Conn().RemotePeer())