From ae395bbe1f8a576c2b9e9ae434b9af9010d5ced9 Mon Sep 17 00:00:00 2001
From: Darien Raymond <admin@v2ray.com>
Date: Mon, 12 Feb 2018 15:08:20 +0100
Subject: [PATCH] increase udp hub capacity

---
 app/proxyman/inbound/worker.go     | 2 +-
 transport/internet/kcp/listener.go | 2 +-
 transport/internet/udp/hub.go      | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/app/proxyman/inbound/worker.go b/app/proxyman/inbound/worker.go
index 296eb0f8..04467808 100644
--- a/app/proxyman/inbound/worker.go
+++ b/app/proxyman/inbound/worker.go
@@ -244,7 +244,7 @@ func (w *udpWorker) removeConn(id connID) {
 func (w *udpWorker) Start() error {
 	w.activeConn = make(map[connID]*udpConn, 16)
 	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 {
 		return err
 	}
diff --git a/transport/internet/kcp/listener.go b/transport/internet/kcp/listener.go
index f35f57ef..12786cc0 100644
--- a/transport/internet/kcp/listener.go
+++ b/transport/internet/kcp/listener.go
@@ -61,7 +61,7 @@ func NewListener(ctx context.Context, address net.Address, port net.Port, addCon
 		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 {
 		return nil, err
 	}
diff --git a/transport/internet/udp/hub.go b/transport/internet/udp/hub.go
index 52b2b510..d92df47d 100644
--- a/transport/internet/udp/hub.go
+++ b/transport/internet/udp/hub.go
@@ -47,7 +47,7 @@ func ListenUDP(address net.Address, port net.Port, callback PayloadHandler, opti
 	newError("listening UDP on ", address, ":", port).WriteToLog()
 	hub := &Hub{
 		conn:         udpConn,
-		capacity:     16,
+		capacity:     256,
 		callback:     callback,
 		recvOrigDest: false,
 	}