fix: libp2p stream leak

Author: yxq

system/p2p/dht/protocol/p2pstore/store.go

@@ -120,7 +120,7 @@ func (p *Protocol) initLocalChunkInfoMap() {
 	start := time.Now()
 	records, err := p.getChunkRecordFromBlockchain(&types.ReqChunkRecords{Start: 0, End: 0})
 	if err != nil {
-		panic(err)
+		return
 	}
 	if records == nil || len(records.Infos) != 1 {
 		panic("invalid record")

system/p2p/dht/protocol/wrapper.go

@@ -52,6 +52,7 @@ func CloseStream(stream network.Stream) {
 		return
 	}
 	_ = stream.CloseWrite()
+	_ = stream.CloseRead()
 	go func() {
 		err := AwaitEOF(stream)
 		if err != nil {
@@ -349,5 +350,5 @@ func AwaitEOF(s network.Stream) error {
 		_ = s.Reset()
 		return err
 	}
-	return nil
+	return s.Close()
 }