We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents d935620 + 106dc40 commit f006c07Copy full SHA for f006c07
dht_net.go
@@ -461,6 +461,7 @@ func (ms *messageSender) writeMsg(pmes *pb.Message) error {
461
func (ms *messageSender) ctxReadMsg(ctx context.Context, mes *pb.Message) error {
462
errc := make(chan error, 1)
463
go func(r msgio.ReadCloser) {
464
+ defer close(errc)
465
bytes, err := r.ReadMsg()
466
defer r.ReleaseMsg(bytes)
467
if err != nil {
0 commit comments