//! The main event loop which performs I/O on the pseudoterminal use std::borrow::Cow; use std::collections::VecDeque; use std::io::{self, ErrorKind, Write}; use std::fs::File; use std::os::unix::io::AsRawFd; use std::sync::Arc; use mio::{self, Events, PollOpt, Ready}; use mio::unix::EventedFd; use ansi; use display; use event; use term::Term; use util::thread; use sync::FairMutex; /// Messages that may be sent to the `EventLoop` #[derive(Debug)] pub enum Msg { /// Data that should be written to the pty Input(Cow<'static, [u8]>), /// Indicates that the `EventLoop` should shut down, as Alacritty is shutting down Shutdown } /// The main event!.. loop. /// /// Handles all the pty I/O and runs the pty parser which updates terminal /// state. pub struct EventLoop { poll: mio::Poll, pty: Io, rx: mio::channel::Receiver, tx: mio::channel::Sender, terminal: Arc>, display: display::Notifier, ref_test: bool, } /// Helper type which tracks how much of a buffer has been written. struct Writing { source: Cow<'static, [u8]>, written: usize, } /// All of the mutable state needed to run the event loop /// /// Contains list of items to write, current write state, etc. Anything that /// would otherwise be mutated on the `EventLoop` goes here. pub struct State { write_list: VecDeque>, writing: Option, parser: ansi::Processor, } pub struct Notifier(pub ::mio::channel::Sender); impl event::Notify for Notifier { fn notify(&mut self, bytes: B) where B: Into> { let bytes = bytes.into(); // terminal hangs if we send 0 bytes through. if bytes.len() == 0 { return } match self.0.send(Msg::Input(bytes)) { Ok(_) => (), Err(_) => panic!("expected send event loop msg"), } } } impl Default for State { fn default() -> State { State { write_list: VecDeque::new(), parser: ansi::Processor::new(), writing: None, } } } impl State { #[inline] fn ensure_next(&mut self) { if self.writing.is_none() { self.goto_next(); } } #[inline] fn goto_next(&mut self) { self.writing = self.write_list .pop_front() .map(Writing::new); } #[inline] fn take_current(&mut self) -> Option { self.writing.take() } #[inline] fn needs_write(&self) -> bool { self.writing.is_some() || !self.write_list.is_empty() } #[inline] fn set_current(&mut self, new: Option) { self.writing = new; } } impl Writing { #[inline] fn new(c: Cow<'static, [u8]>) -> Writing { Writing { source: c, written: 0 } } #[inline] fn advance(&mut self, n: usize) { self.written += n; } #[inline] fn remaining_bytes(&self) -> &[u8] { &self.source[self.written..] } #[inline] fn finished(&self) -> bool { self.written >= self.source.len() } } /// `mio::Token` for the event loop channel const CHANNEL: mio::Token = mio::Token(0); /// `mio::Token` for the pty file descriptor const PTY: mio::Token = mio::Token(1); impl EventLoop where Io: io::Read + io::Write + Send + AsRawFd + 'static { /// Create a new event loop pub fn new( terminal: Arc>, display: display::Notifier, pty: Io, ref_test: bool, ) -> EventLoop { let (tx, rx) = ::mio::channel::channel(); EventLoop { poll: mio::Poll::new().expect("create mio Poll"), pty: pty, tx: tx, rx: rx, terminal: terminal, display: display, ref_test: ref_test, } } pub fn channel(&self) -> mio::channel::Sender { self.tx.clone() } // Drain the channel // // Returns `Ok` if the `EventLoop` should continue running. // `Ok(true)`is returned if items were received // // An `Err` indicates that the event loop should shut down fn drain_recv_channel(&self, state: &mut State) -> Result { let mut received_item = false; while let Ok(msg) = self.rx.try_recv() { received_item = true; match msg { Msg::Input(input) => { state.write_list.push_back(input); }, Msg::Shutdown => { return Err(()) } } } Ok(received_item) } // Returns a `bool` indicating whether or not the event loop should continue running #[inline] fn channel_event(&mut self, state: &mut State) -> bool { if self.drain_recv_channel(state).is_err() { return false; } self.poll.reregister( &self.rx, CHANNEL, Ready::readable(), PollOpt::edge() | PollOpt::oneshot() ).expect("reregister channel"); if state.needs_write() { self.poll.reregister( &EventedFd(&self.pty.as_raw_fd()), PTY, Ready::readable() | Ready::writable(), PollOpt::edge() | PollOpt::oneshot() ).expect("reregister fd after channel recv"); } true } #[inline] fn pty_read( &mut self, state: &mut State, buf: &mut [u8], mut writer: Option<&mut W> ) -> io::Result<()> where W: Write { loop { match self.pty.read(&mut buf[..]) { Ok(0) => break, Ok(got) => { writer = writer.map(|w| { w.write_all(&buf[..got]).unwrap(); w }); let mut terminal = self.terminal.lock(); for byte in &buf[..got] { state.parser.advance(&mut *terminal, *byte, &mut self.pty); } // Only request a draw if one hasn't already been requested. // // This is a performance optimization even if only for X11 // which is very expensive to hammer on the even loop wakeup if !terminal.dirty { self.display.notify(); terminal.dirty = true; // Break for writing // // Want to prevent case where reading always returns // data and sequences like `C-c` cannot be sent. // // Doing this check in !terminal.dirty will prevent the // condition from being checked overzealously. // // We want to break if `drain_recv_channel` returns either `Ok(true)` // (new items came in for writing) or `Err` (we need to shut down) if state.writing.is_some() || !state.write_list.is_empty() || self.drain_recv_channel(state).unwrap_or_else(|_| true) { break; } } }, Err(err) => { match err.kind() { ErrorKind::Interrupted | ErrorKind::WouldBlock => break, _ => return Err(err), } } } } Ok(()) } #[inline] fn pty_write(&mut self, state: &mut State) -> io::Result<()> { state.ensure_next(); 'write_many: while let Some(mut current) = state.take_current() { 'write_one: loop { match self.pty.write(current.remaining_bytes()) { Ok(0) => { state.set_current(Some(current)); break 'write_many; }, Ok(n) => { current.advance(n); if current.finished() { state.goto_next(); break 'write_one; } }, Err(err) => { state.set_current(Some(current)); match err.kind() { ErrorKind::Interrupted | ErrorKind::WouldBlock => break 'write_many, _ => return Err(err), } } } } } Ok(()) } pub fn spawn( mut self, state: Option ) -> thread::JoinHandle<(EventLoop, State)> { thread::spawn_named("pty reader", move || { let mut state = state.unwrap_or_else(Default::default); let mut buf = [0u8; 4096]; let fd = self.pty.as_raw_fd(); let fd = EventedFd(&fd); let poll_opts = PollOpt::edge() | PollOpt::oneshot(); self.poll.register(&self.rx, CHANNEL, Ready::readable(), poll_opts).unwrap(); self.poll.register(&fd, PTY, Ready::readable(), poll_opts).unwrap(); let mut events = Events::with_capacity(1024); let mut pipe = if self.ref_test { let file = File::create("./alacritty.recording") .expect("create alacritty recording"); Some(file) } else { None }; 'event_loop: loop { if let Err(err) = self.poll.poll(&mut events, None) { match err.kind() { ErrorKind::Interrupted => continue, _ => panic!("EventLoop polling error: {:?}", err) } } for event in events.iter() { match event.token() { CHANNEL => { if !self.channel_event(&mut state) { break 'event_loop; } }, PTY => { let kind = event.kind(); if kind.is_hup() { break 'event_loop; } if kind.is_readable() { if let Err(err) = self.pty_read(&mut state, &mut buf, pipe.as_mut()) { error!("Event loop exitting due to error: {} [{}:{}]", err, file!(), line!()); break 'event_loop; } if ::tty::process_should_exit() { break 'event_loop; } } if kind.is_writable() { if let Err(err) = self.pty_write(&mut state) { error!("Event loop exitting due to error: {} [{}:{}]", err, file!(), line!()); break 'event_loop; } } // Figure out pty interest let mut interest = Ready::readable(); if state.needs_write() { interest.insert(Ready::writable()); } // Reregister pty self.poll .reregister(&fd, PTY, interest, poll_opts) .expect("register fd after read/write"); }, _ => (), } } } let _ = self.poll.deregister(&self.rx); let _ = self.poll.deregister(&fd); (self, state) }) } }