From 7195c17af6e1272db4ea3f65dcb725474f065217 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Tue, 4 Apr 2017 11:20:07 +0200 Subject: [PATCH] close server down link --- app/proxyman/mux/mux.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/proxyman/mux/mux.go b/app/proxyman/mux/mux.go index f3cbf635f..23ac47074 100644 --- a/app/proxyman/mux/mux.go +++ b/app/proxyman/mux/mux.go @@ -321,11 +321,11 @@ func (w *ServerWorker) remove(id uint16) { func handle(ctx context.Context, s *session, output buf.Writer) { writer := NewResponseWriter(s.id, output) - defer writer.Close() - if err := buf.PipeUntilEOF(signal.BackgroundTimer(), s.input, writer); err != nil { log.Info("Proxyman|Mux|ServerWorker: Session ", s.id, " ends: ", err) } + writer.Close() + s.closeDownlink() } func (w *ServerWorker) run(ctx context.Context) {