From 4285830929ba3f922838fc8a1110bf7a38bfce3f Mon Sep 17 00:00:00 2001 From: Paul Lorenz Date: Fri, 10 Sep 2021 11:38:44 -0400 Subject: [PATCH] Close send buffer when unrouted, since sends will no longer work --- router/xgress/xgress.go | 1 + 1 file changed, 1 insertion(+) diff --git a/router/xgress/xgress.go b/router/xgress/xgress.go index aa3de332f..49f1bcd54 100644 --- a/router/xgress/xgress.go +++ b/router/xgress/xgress.go @@ -261,6 +261,7 @@ func (self *Xgress) Unrouted() { // When we're unrouted, if end of circuit hasn't already arrived, give incoming/queued data // a chance to outflow before closing if !self.flags.IsSet(closedFlag) { + self.payloadBuffer.Close() time.AfterFunc(self.Options.MaxCloseWait, self.Close) } }