mirror of https://github.com/v2ray/v2ray-core
refactor
parent
2b80d096ff
commit
e7aaba0c30
|
@ -79,7 +79,7 @@ func (w *tcpWorker) Start() error {
|
||||||
conns := make(chan internet.Connection, 16)
|
conns := make(chan internet.Connection, 16)
|
||||||
hub, err := internet.ListenTCP(ctx, w.address, w.port, conns)
|
hub, err := internet.ListenTCP(ctx, w.address, w.port, conns)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return newError("failed to listen TCP on ", w.port).Base(err)
|
||||||
}
|
}
|
||||||
go w.handleConnections(conns)
|
go w.handleConnections(conns)
|
||||||
w.hub = hub
|
w.hub = hub
|
||||||
|
|
|
@ -9,7 +9,7 @@ import (
|
||||||
func CreateInboundHandler(ctx context.Context, config interface{}) (Inbound, error) {
|
func CreateInboundHandler(ctx context.Context, config interface{}) (Inbound, error) {
|
||||||
handler, err := common.CreateObject(ctx, config)
|
handler, err := common.CreateObject(ctx, config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, newError("failed to create inbound handler").Base(err)
|
||||||
}
|
}
|
||||||
switch h := handler.(type) {
|
switch h := handler.(type) {
|
||||||
case Inbound:
|
case Inbound:
|
||||||
|
@ -22,7 +22,7 @@ func CreateInboundHandler(ctx context.Context, config interface{}) (Inbound, err
|
||||||
func CreateOutboundHandler(ctx context.Context, config interface{}) (Outbound, error) {
|
func CreateOutboundHandler(ctx context.Context, config interface{}) (Outbound, error) {
|
||||||
handler, err := common.CreateObject(ctx, config)
|
handler, err := common.CreateObject(ctx, config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, newError("failed to create outbound handler").Base(err)
|
||||||
}
|
}
|
||||||
switch h := handler.(type) {
|
switch h := handler.(type) {
|
||||||
case Outbound:
|
case Outbound:
|
||||||
|
|
Loading…
Reference in New Issue