|
func (c *UDPConn) Close() error { |
|
c.upnpPortMapping.close() |
|
close(c.closeChan) |
|
c.udpConnsMutex.RLock() |
|
for _, conn := range c.udpConns { |
|
conn.Close() |
|
} |
|
c.udpConnsMutex.RUnlock() |
|
c.closedWG.Wait() |
|
close(c.natEvents) |
|
close(c.datagrams) |
|
close(c.endpoints) |
|
close(c.errChan) |
|
return nil |
|
} |
|
select { |
|
case c.natEvents <- &info: |
|
default: |
|
} |
c.natEvents may be already closed, right?
For the dynamic added producer situation, I'm afraid WaitGroup is not enough.
