github
/
v2ray-core
mirror of https://github.com/v2ray/v2ray-core
1
0
Fork 0
Code Issues Releases Wiki Activity

increase udp hub capacity

pull/865/head v3.8.1
Darien Raymond 2018-02-12 15:08:20 +01:00
parent ae4dece6b0
commit ae395bbe1f
No known key found for this signature in database
GPG Key ID: 7251FFA14BB18169
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/proxyman/inbound/worker.go
View File

@ -244,7 +244,7 @@ func (w *udpWorker) removeConn(id connID) {
func (w *udpWorker) Start() error { func (w *udpWorker) Start() error {
w.activeConn = make(map[connID]*udpConn, 16) w.activeConn = make(map[connID]*udpConn, 16)
w.done = signal.NewDone() w.done = signal.NewDone()
h, err := udp.ListenUDP(w.address, w.port, w.callback, udp.HubReceiveOriginalDestination(w.recvOrigDest)) h, err := udp.ListenUDP(w.address, w.port, w.callback, udp.HubReceiveOriginalDestination(w.recvOrigDest), udp.HubCapacity(256))
if err != nil { if err != nil {
return err return err
} }

2
transport/internet/kcp/listener.go
View File

@ -61,7 +61,7 @@ func NewListener(ctx context.Context, address net.Address, port net.Port, addCon
l.tlsConfig = config.GetTLSConfig() l.tlsConfig = config.GetTLSConfig()
} }
hub, err := udp.ListenUDP(address, port, l.OnReceive, udp.HubCapacity(64)) hub, err := udp.ListenUDP(address, port, l.OnReceive, udp.HubCapacity(1024))
if err != nil { if err != nil {
return nil, err return nil, err
} }

2
transport/internet/udp/hub.go
View File

@ -47,7 +47,7 @@ func ListenUDP(address net.Address, port net.Port, callback PayloadHandler, opti
newError("listening UDP on ", address, ":", port).WriteToLog() newError("listening UDP on ", address, ":", port).WriteToLog()
hub := &Hub{ hub := &Hub{
conn: udpConn, conn: udpConn,
capacity: 16, capacity: 256,
callback: callback, callback: callback,
recvOrigDest: false, recvOrigDest: false,
} }