Fixed a bug that mux.Session could not be properly closed when receiving an End status.

2022-12-09 03:51:38 +00:00 · 2022-12-09 03:51:38 +00:00 · 3e4e050313
parent b8e8229242
commit 3e4e050313
2 changed files with 2 additions and 0 deletions
--- a/common/mux/client.go
+++ b/common/mux/client.go
@ -355,6 +355,7 @@ func (m *ClientWorker) handleStatusEnd(meta *FrameMetadata, reader *buf.Buffered
 			common.Interrupt(s.input)
 			common.Interrupt(s.output)
 		}
+		common.Interrupt(s.input)
 		s.Close()
 	}
 	if meta.Option.Has(OptionData) {
--- a/common/mux/server.go
+++ b/common/mux/server.go
@ -202,6 +202,7 @@ func (w *ServerWorker) handleStatusEnd(meta *FrameMetadata, reader *buf.Buffered
 			common.Interrupt(s.input)
 			common.Interrupt(s.output)
 		}
+		common.Interrupt(s.input)
 		s.Close()
 	}
 	if meta.Option.Has(OptionData) {