Commit 44e13806 authored by Jeromy's avatar Jeromy

Buffer response channel to prevent deadlock

License: MIT
Signed-off-by: default avatarJeromy <jeromyj@gmail.com>
parent fc37b2f6
...@@ -119,7 +119,7 @@ type interestReq struct { ...@@ -119,7 +119,7 @@ type interestReq struct {
// block we received) this function will not be called, as the cid will likely // block we received) this function will not be called, as the cid will likely
// still be in the interest cache. // still be in the interest cache.
func (s *Session) isLiveWant(c *cid.Cid) bool { func (s *Session) isLiveWant(c *cid.Cid) bool {
resp := make(chan bool) resp := make(chan bool, 1)
s.interestReqs <- interestReq{ s.interestReqs <- interestReq{
c: c, c: c,
resp: resp, resp: resp,
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment