From 59958fed68a5bbacfd956d9da622c5be44d50c3a Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Thu, 1 Mar 2018 14:58:13 +0100 Subject: [PATCH] refactor udp worker --- app/proxyman/inbound/worker.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/app/proxyman/inbound/worker.go b/app/proxyman/inbound/worker.go index afa09aa4..e431c732 100644 --- a/app/proxyman/inbound/worker.go +++ b/app/proxyman/inbound/worker.go @@ -210,8 +210,10 @@ func (w *udpWorker) getConnection(id connID) (*udpConn, bool) { func (w *udpWorker) callback(b *buf.Buffer, source net.Destination, originalDest net.Destination) { id := connID{ - src: source, - dest: originalDest, + src: source, + } + if originalDest.IsValid() { + id.dest = originalDest } conn, existing := w.getConnection(id) select {