add ftcp listener
This commit is contained in:
@ -72,7 +72,12 @@ func (l *Listener) Accept() (conn net.Conn, err error) {
|
||||
}
|
||||
|
||||
func (l *Listener) Close() error {
|
||||
return l.conn.Close()
|
||||
err := l.conn.Close()
|
||||
l.connPool.Range(func(k interface{}, v *serverConn) bool {
|
||||
v.Close()
|
||||
return true
|
||||
})
|
||||
return err
|
||||
}
|
||||
|
||||
func (l *Listener) Addr() net.Addr {
|
||||
|
Reference in New Issue
Block a user