1 files changed, 15 insertions, 1 deletions

diff --git a/rsnix/src/tty.rs b/rsnix/src/tty.rs
index 918f6e0..c44dca8 100644
--- a/rsnix/src/tty.rs
+++ b/rsnix/src/tty.rs
@@ -139,7 +139,14 @@ pub fn read_line() -> LineInput {
 /// windowed shells).  Same semantics as `read_line` but keys arrive as
 /// `TaskMsg::Key` instead of from the global PS/2 queue.  Returns `None`
 /// on `TaskMsg::Close` (window was closed).
-pub fn read_line_from_queue() -> Option<LineInput> {
+/// Read one line in canonical mode from the task's message queue (for
+/// windowed shells).  Same semantics as `read_line` but keys arrive as
+/// `TaskMsg::Key` instead of from the global PS/2 queue.  Returns `None`
+/// on `TaskMsg::Close` (window was closed).
+///
+/// Handles `TaskMsg::Focus` to toggle the global `ACTIVE` redirect so
+/// gop_print! goes to the right terminal buffer.
+pub fn read_line_from_queue(term: &mut crate::vt::Terminal) -> Option<LineInput> {
     crate::vt::sync_scroll();
     let mut buf = strbuf::String::<LINE_BUF_SIZE>::new();
     loop {
@@ -191,6 +198,13 @@ pub fn read_line_from_queue() -> Option<LineInput> {
                 }
                 _ => {}
             },
+            crate::sched::TaskMsg::Focus(gained) => {
+                if gained {
+                    crate::vt::set_active(term as *mut crate::vt::Terminal);
+                } else {
+                    crate::vt::set_active(core::ptr::null_mut());
+                }
+            }
             crate::sched::TaskMsg::Close => return None,
             _ => {}
         }