mirror of https://github.com/v2ray/v2ray-core
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
98 lines
2.2 KiB
98 lines
2.2 KiB
package internet
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"errors"
|
|
"net"
|
|
"sync"
|
|
|
|
"github.com/v2ray/v2ray-core/common/log"
|
|
v2net "github.com/v2ray/v2ray-core/common/net"
|
|
v2tls "github.com/v2ray/v2ray-core/transport/internet/tls"
|
|
)
|
|
|
|
var (
|
|
ErrClosedConnection = errors.New("Connection already closed.")
|
|
|
|
KCPListenFunc ListenFunc
|
|
TCPListenFunc ListenFunc
|
|
RawTCPListenFunc ListenFunc
|
|
WSListenFunc ListenFunc
|
|
)
|
|
|
|
type ListenFunc func(address v2net.Address, port v2net.Port) (Listener, error)
|
|
type Listener interface {
|
|
Accept() (Connection, error)
|
|
Close() error
|
|
Addr() net.Addr
|
|
}
|
|
|
|
type TCPHub struct {
|
|
sync.Mutex
|
|
listener Listener
|
|
connCallback ConnectionHandler
|
|
accepting bool
|
|
tlsConfig *tls.Config
|
|
}
|
|
|
|
func ListenTCP(address v2net.Address, port v2net.Port, callback ConnectionHandler, settings *StreamSettings) (*TCPHub, error) {
|
|
var listener Listener
|
|
var err error
|
|
switch {
|
|
case settings.IsCapableOf(StreamConnectionTypeTCP):
|
|
listener, err = TCPListenFunc(address, port)
|
|
case settings.IsCapableOf(StreamConnectionTypeKCP):
|
|
listener, err = KCPListenFunc(address, port)
|
|
case settings.IsCapableOf(StreamConnectionTypeWebSocket):
|
|
listener, err = WSListenFunc(address, port)
|
|
case settings.IsCapableOf(StreamConnectionTypeRawTCP):
|
|
listener, err = RawTCPListenFunc(address, port)
|
|
default:
|
|
log.Error("Internet|Listener: Unknown stream type: ", settings.Type)
|
|
err = ErrUnsupportedStreamType
|
|
}
|
|
|
|
if err != nil {
|
|
log.Warning("Internet|Listener: Failed to listen on ", address, ":", port)
|
|
return nil, err
|
|
}
|
|
|
|
var tlsConfig *tls.Config
|
|
if settings.Security == StreamSecurityTypeTLS {
|
|
tlsConfig = settings.TLSSettings.GetTLSConfig()
|
|
}
|
|
|
|
hub := &TCPHub{
|
|
listener: listener,
|
|
connCallback: callback,
|
|
tlsConfig: tlsConfig,
|
|
}
|
|
|
|
go hub.start()
|
|
return hub, nil
|
|
}
|
|
|
|
func (this *TCPHub) Close() {
|
|
this.accepting = false
|
|
this.listener.Close()
|
|
}
|
|
|
|
func (this *TCPHub) start() {
|
|
this.accepting = true
|
|
for this.accepting {
|
|
conn, err := this.listener.Accept()
|
|
|
|
if err != nil {
|
|
if this.accepting {
|
|
log.Warning("Internet|Listener: Failed to accept new TCP connection: ", err)
|
|
}
|
|
continue
|
|
}
|
|
if this.tlsConfig != nil {
|
|
tlsConn := tls.Server(conn, this.tlsConfig)
|
|
conn = v2tls.NewConnection(tlsConn)
|
|
}
|
|
go this.connCallback(conn)
|
|
}
|
|
}
|