Merge pull request #734 from saschagrunert/send-closed

Send only streams data if channel is not closed
containers · Sep 20, 2022 · 8e4cec9 · 8e4cec9
2 parents 18857bb + cac2758
commit 8e4cec9
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/conmon-rs/server/src/container_io.rs b/conmon-rs/server/src/container_io.rs
@@ -267,9 +267,11 @@ impl ContainerIO {
                                 .await
                                 .context("write to attach endpoints")?;
 
-                            message_tx
-                                .send(Message::Data(data.into(), pipe))
-                                .context("send data message")?;
+                            if !message_tx.is_closed() {
+                                message_tx
+                                    .send(Message::Data(data.into(), pipe))
+                                    .context("send data message")?;
+                            }
                         }
                         Err(e) => match Errno::from_i32(e.raw_os_error().context("get OS error")?) {
                             Errno::EIO => {