From 7651fb5586fd4028d4a90a747af896f00795ffdd Mon Sep 17 00:00:00 2001 From: FH0 <32861476+FH0@users.noreply.github.com> Date: Wed, 18 Mar 2020 19:28:24 +0800 Subject: [PATCH] fix udp broken --- app/proxyman/inbound/worker.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/app/proxyman/inbound/worker.go b/app/proxyman/inbound/worker.go index 2a2793eb..13ef405f 100644 --- a/app/proxyman/inbound/worker.go +++ b/app/proxyman/inbound/worker.go @@ -187,6 +187,15 @@ func (c *udpConn) Write(buf []byte) (int, error) { return n, err } +// Implements buf.ActivityNotifiable +func (c *udpConn) NotifyActivity() error { + if c.done.Done() { + return newError("connection is already closed") + } + c.updateActivity() + return nil +} + func (c *udpConn) Close() error { common.Must(c.done.Close()) common.Must(common.Close(c.writer))