[fix] Fixed a crash caused by a connection failure StreamEnd happenin…

…g after a pipeline reset
pajama-coder · Dec 6, 2023 · a3b9d47 · a3b9d47
1 parent 775f0a2
commit a3b9d47
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/outbound.cpp b/src/outbound.cpp
@@ -103,8 +103,10 @@ auto Outbound::address() -> pjs::Str* {
 
 void Outbound::close(StreamEnd *eos) {
   InputContext ic;
-  close();
+  retain();
   input(eos);
+  close();
+  release();
 }
 
 void Outbound::state(State state) {
@@ -117,7 +119,9 @@ void Outbound::state(State state) {
 }
 
 void Outbound::input(Event *evt) {
-  m_input->input(evt);
+  if (m_state != State::closed) {
+    m_input->input(evt);
+  }
 }
 
 void Outbound::error(StreamEnd::Error err) {