fix: dht unit test

yxq · yxq · commit 1566a58369fe · 2021-07-19T17:06:18.000+08:00
diff --git a/system/p2p/dht/protocol/p2pstore/query.go b/system/p2p/dht/protocol/p2pstore/query.go
@@ -577,7 +577,7 @@ func (p *Protocol) getChunkRecordFromBlockchain(req *types.ReqChunkRecords) (*ty
 	if err != nil {
 		return nil, err
 	}
-	resp, err := p.QueueClient.Wait(msg)
+	resp, err := p.QueueClient.WaitTimeout(msg, time.Second)
 	if err != nil {
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -577,7 +577,7 @@ func (p Protocol) getChunkRecordFromBlockchain(req types.ReqChunkRecords) (*ty`
`577`	`577`	`if err != nil {`
`578`	`578`	`return nil, err`
`579`	`579`	`}`
`580`		`- resp, err := p.QueueClient.Wait(msg)`
	`580`	`+ resp, err := p.QueueClient.WaitTimeout(msg, time.Second)`
`581`	`581`	`if err != nil {`
`582`	`582`	`return nil, err`
`583`	`583`	`}`