clean up a channel that was dangling

106dc400 · Will Scott · 7224e2a4 · 106dc400
Unverified Commit 106dc400 authored Apr 28, 2020 by Will Scott
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

dht_net.go dht_net.go +1 -0

No files found.
--- a/dht_net.go
+++ b/dht_net.go
@@ -461,6 +461,7 @@ func (ms *messageSender) writeMsg(pmes *pb.Message) error {
 func (ms *messageSender) ctxReadMsg(ctx context.Context, mes *pb.Message) error {
 	errc := make(chan error, 1)
 	go func(r msgio.ReadCloser) {
+		defer close(errc)
 		bytes, err := r.ReadMsg()
 		defer r.ReleaseMsg(bytes)
 		if err != nil {