fix(pty): paste freeze with large amounts of text (#1383)

add pty writer thread to avoid screen thread blocking on unistd::write

1 files changed, 34 insertions, 0 deletions

diff --git a/zellij-server/src/pty_writer.rs b/zellij-server/src/pty_writer.rs
new file mode 100644
index 000000000..9cdcd9769
--- /dev/null
+++ b/zellij-server/src/pty_writer.rs
@@ -0,0 +1,34 @@
+use zellij_utils::errors::{ContextType, PtyWriteContext};
+
+use crate::thread_bus::Bus;
+
+#[derive(Debug, Clone)]
+pub(crate) enum PtyWriteInstruction {
+    Write(Vec<u8>, i32),
+}
+
+impl From<&PtyWriteInstruction> for PtyWriteContext {
+    fn from(tty_write_instruction: &PtyWriteInstruction) -> Self {
+        match *tty_write_instruction {
+            PtyWriteInstruction::Write(..) => PtyWriteContext::Write,
+        }
+    }
+}
+
+pub(crate) fn pty_writer_main(bus: Bus<PtyWriteInstruction>) {
+    loop {
+        let (event, mut err_ctx) = bus.recv().expect("failed to receive event on channel");
+        err_ctx.add_call(ContextType::PtyWrite((&event).into()));
+        let os_input = bus.os_input.clone().unwrap();
+        match event {
+            PtyWriteInstruction::Write(bytes, terminal_id) => {
+                if let Err(e) = os_input.write_to_tty_stdin(terminal_id, &bytes) {
+                    log::error!("failed to write to terminal: {}", e);
+                }
+                if let Err(e) = os_input.tcdrain(terminal_id) {
+                    log::error!("failed to drain terminal: {}", e);
+                };
+            }
+        }
+    }
+}