From 0e940fb1fa546fad98b30d459636dd7b038377e9 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Tue, 10 Jan 2017 15:10:30 +0100 Subject: [PATCH] close both stream immediately after error --- app/dispatcher/impl/default.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/dispatcher/impl/default.go b/app/dispatcher/impl/default.go index 0f00f651d..1fc7763c4 100644 --- a/app/dispatcher/impl/default.go +++ b/app/dispatcher/impl/default.go @@ -72,7 +72,7 @@ func (v *DefaultDispatcher) waitAndDispatch(wait func() error, destination v2net if err := wait(); err != nil { log.Info("DefaultDispatcher: Failed precondition: ", err) link.OutboundInput().CloseError() - link.OutboundOutput().Close() + link.OutboundOutput().CloseError() return }