Skip to content

Commit 106dc40

Browse files
committed
clean up a channel that was dangling
1 parent 7224e2a commit 106dc40

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

dht_net.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -461,6 +461,7 @@ func (ms *messageSender) writeMsg(pmes *pb.Message) error {
461461
func (ms *messageSender) ctxReadMsg(ctx context.Context, mes *pb.Message) error {
462462
errc := make(chan error, 1)
463463
go func(r msgio.ReadCloser) {
464+
defer close(errc)
464465
bytes, err := r.ReadMsg()
465466
defer r.ReleaseMsg(bytes)
466467
if err != nil {

0 commit comments

Comments
 (0)