fix closing
This commit is contained in:
@@ -92,13 +92,14 @@ func (c Config) Close() {
|
|||||||
for i := range c.forwards {
|
for i := range c.forwards {
|
||||||
if c.forwards[i] != nil {
|
if c.forwards[i] != nil {
|
||||||
i := i
|
i := i
|
||||||
go func() {
|
func() {
|
||||||
c.forwards[i].New = nil
|
c.forwards[i].New = nil
|
||||||
for {
|
for {
|
||||||
got := c.forwards[i].Get()
|
got := c.forwards[i].Get()
|
||||||
if got != nil {
|
if got == nil {
|
||||||
go got.(net.Conn).Close()
|
break
|
||||||
}
|
}
|
||||||
|
got.(net.Conn).Close()
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user