From 35cb8cf039e3bab81d15d586ea8bb6f571d841fd Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Tue, 25 Feb 2020 01:41:54 +0300 Subject: [server/tunnel] check EOF TODO: replace queue.IoCopy with WriteTo/ReadFrom --- pkg/server/tunnel.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'pkg/server/tunnel.go') diff --git a/pkg/server/tunnel.go b/pkg/server/tunnel.go index f29a2f3..49f684e 100644 --- a/pkg/server/tunnel.go +++ b/pkg/server/tunnel.go @@ -1,7 +1,9 @@ package server import ( + "errors" "fmt" + "io" "log" "sort" "strings" @@ -161,7 +163,7 @@ func (s *stream) channel(c socket.Channel, rq, wq queue.Q) { watch := func(q queue.Q, f func(q queue.Q) error) { defer s.wg.Done() - if err := f(q); err != nil { + if err := f(q); err != nil && !errors.Is(err, io.EOF) { log.Println(s.t, s, err) } } @@ -185,7 +187,7 @@ func (s *stream) pipe(m module.M, p module.Pipe, rq, wq queue.Q) { go func() { defer s.wg.Done() - if err := p(rq, wq); err != nil { + if err := p(rq, wq); err != nil && !errors.Is(err, io.EOF) { log.Println(s.t, s, m, err) } -- cgit v1.2.3-70-g09d2