xmengnet/mihomo
1
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Chore: Listener should not expose original net.Listener

Browse source
This commit is contained in:
gVisor bot 2021-06-13 23:05:22 +08:00
parent 894e2843d5
commit b495157bec
7 changed files with 33 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
listener/http/server.go
View file

@ -17,7 +17,7 @@ import (
)
type Listener struct {
net.Listener
listener net.Listener
address string
closed bool
cache *cache.Cache
@ -31,7 +31,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
hl := &Listener{l, addr, false, cache.New(30 * time.Second)}
go func() {
for {
c, err := hl.Accept()
c, err := hl.listener.Accept()
if err != nil {
if hl.closed {
break
@ -47,7 +47,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
func (l *Listener) Close() {
l.closed = true
l.Listener.Close()
l.listener.Close()
}
func (l *Listener) Address() string {

6
listener/mixed/mixed.go
View file

@ -12,7 +12,7 @@ import (
)
type Listener struct {
net.Listener
listener net.Listener
address string
closed bool
cache *cache.Cache
@ -27,7 +27,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
ml := &Listener{l, addr, false, cache.New(30 * time.Second)}
go func() {
for {
c, err := ml.Accept()
c, err := ml.listener.Accept()
if err != nil {
if ml.closed {
break
@ -43,7 +43,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
func (l *Listener) Close() {
l.closed = true
l.Listener.Close()
l.listener.Close()
}
func (l *Listener) Address() string {

4
listener/redir/tcp.go
View file

@ -8,7 +8,7 @@ import (
)
type Listener struct {
net.Listener
listener net.Listener
address string
closed bool
}
@ -38,7 +38,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
func (l *Listener) Close() {
l.closed = true
l.Listener.Close()
l.listener.Close()
}
func (l *Listener) Address() string {

4
listener/socks/tcp.go
View file

@ -12,7 +12,7 @@ import (
)
type Listener struct {
net.Listener
listener net.Listener
address string
closed bool
}
@ -42,7 +42,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
func (l *Listener) Close() {
l.closed = true
l.Listener.Close()
l.listener.Close()
}
func (l *Listener) Address() string {

4
listener/socks/udp.go
View file

@ -12,7 +12,7 @@ import (
)
type UDPListener struct {
net.PacketConn
packetConn net.PacketConn
address string
closed bool
}
@ -48,7 +48,7 @@ func NewUDP(addr string, in chan<- *inbound.PacketAdapter) (*UDPListener, error)
func (l *UDPListener) Close() error {
l.closed = true
return l.PacketConn.Close()
return l.packetConn.Close()
}
func (l *UDPListener) Address() string {

6
listener/tproxy/tproxy.go
View file

@ -9,7 +9,7 @@ import (
)
type Listener struct {
net.Listener
listener net.Listener
address string
closed bool
}
@ -32,7 +32,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
}
rl := &Listener{
Listener: l,
listener: l,
address: addr,
}
@ -54,7 +54,7 @@ func New(addr string, in chan<- C.ConnContext) (*Listener, error) {
func (l *Listener) Close() {
l.closed = true
l.Listener.Close()
l.listener.Close()
}
func (l *Listener) Address() string {

4
listener/tproxy/udp.go
View file

@ -10,7 +10,7 @@ import (
)
type UDPListener struct {
net.PacketConn
packetConn net.PacketConn
address string
closed bool
}
@ -61,7 +61,7 @@ func NewUDP(addr string, in chan<- *inbound.PacketAdapter) (*UDPListener, error)
func (l *UDPListener) Close() error {
l.closed = true
return l.PacketConn.Close()
return l.packetConn.Close()
}
func (l *UDPListener) Address() string {