prevent double close

pkg/clientutil/idreply.go

@@ -13,6 +13,7 @@ import (
 type IdReply struct {
 	id atomic.Int64
 
+	amClosed atomic.Bool
 	closed   chan struct{}
 
 	chs map[string]chan msgOrError
@@ -108,6 +109,9 @@ func (i *IdReply) Closed() <-chan struct{} {
 }
 
 func (i *IdReply) Close() error {
+	if i.amClosed.Swap(true) {
+		return net.ErrClosed
+	}
 	close(i.closed)
 	return nil
 }