diff --git a/reload.go b/reload.go index eb5f383e..4e62b023 100644 --- a/reload.go +++ b/reload.go @@ -29,9 +29,12 @@ type conn struct { net.Conn wg *sync.WaitGroup isclose bool + lock sync.Mutex } func (c conn) Close() error { + c.lock.Lock() + defer c.lock.Unlock() err := c.Conn.Close() if !c.isclose { c.wg.Done()