rpcclient: Fix ws-reader hang on sending a response #1
1 changed files with 7 additions and 1 deletions
|
@ -601,7 +601,13 @@ readloop:
|
||||||
connCloseErr = fmt.Errorf("unknown response channel for response %d", id)
|
connCloseErr = fmt.Errorf("unknown response channel for response %d", id)
|
||||||
break readloop // Unknown response (unexpected response ID).
|
break readloop // Unknown response (unexpected response ID).
|
||||||
}
|
}
|
||||||
ch <- &rr.Response
|
select {
|
||||||
|
case <-c.writerDone:
|
||||||
|
break readloop
|
||||||
|
case <-c.shutdown:
|
||||||
|
break readloop
|
||||||
|
case ch <- &rr.Response:
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
// Malformed response, neither valid request, nor valid response.
|
// Malformed response, neither valid request, nor valid response.
|
||||||
connCloseErr = fmt.Errorf("malformed response")
|
connCloseErr = fmt.Errorf("malformed response")
|
||||||
|
|
Loading…
Reference in a new issue