From 61c258f2bea8c41239d4bc60953ad141bdb9efca Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Fri, 23 Feb 2018 23:42:33 +0100 Subject: [PATCH] input channel was being closed too quickly --- proxy/socks/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/proxy/socks/server.go b/proxy/socks/server.go index e80efbd1..77803ad2 100644 --- a/proxy/socks/server.go +++ b/proxy/socks/server.go @@ -140,7 +140,7 @@ func (s *Server) transport(ctx context.Context, reader io.Reader, writer io.Writ requestDone := signal.ExecuteAsync(func() error { defer timer.SetTimeout(s.policy().Timeouts.DownlinkOnly) - defer common.Must(input.Close()) + defer input.Close() v2reader := buf.NewReader(reader) if err := buf.Copy(v2reader, input, buf.UpdateActivity(timer)); err != nil {