remove sync_channel, re-fixes large pastes under glium

The sync_channel was originally added as a brake to avoid swamping
the event loop, but we've subsequently grown a more formal rate
limiting config for this.

The rate limiter is superior because it allows making forward
progress over time, whereas the bounded channel is a hard blocking
limit.

When making a large paste the app on the other end will typically
emit a lot of output.  If our reader is blocked on the sync channel
the output of the pty can be blocked, and that in turn will block
our attempt to write to the pty.

We cannot simply set the pty to non-blocking mode because non-blocking
ptys are not a thing on windows, and in the interest of not silently
breaking windows, I prefer to make the unix side of things match
that architecture.

anyway: TL;DR is that we don't need the bounded channel now that
we have rate control to manage swamping the event loop, so we
can simplify this code.

src/frontend/glium/glutinloop.rs

@@ -14,61 +14,38 @@ use log::{debug, error};
 use promise::{Executor, Future, SpawnFunc};
 use std::cell::RefCell;
 use std::collections::HashMap;
-use std::collections::VecDeque;
 use std::rc::Rc;
-use std::sync::mpsc::{self, Receiver, SyncSender, TryRecvError};
+use std::sync::mpsc::{self, Receiver, Sender, TryRecvError};
 use std::sync::Arc;
 use std::thread;
 use std::time::{Duration, SystemTime};
 
 /// The GuiSender is used as a handle that allows sending SpawnFunc
 /// instances to be executed on the gui thread.
-/// When `send` is called from a non-gui thread the funcs are queued
+#[derive(Clone)]
-/// via the bounded `tx` member.  The bounding is desirable to act
-/// as a brake in the case that eg: a pty is spewing a lot of output
-/// and where we want to allow the gui thread time to process other
-/// events.
-/// When `send` is called from the gui thread, we assume that the
-/// activity is something that is high priority and thus directly
-/// queue up the events into the `gui_thread_sends` in the
-/// executor itself.
 struct GuiSender {
-    tx: SyncSender<SpawnFunc>,
+    tx: Sender<SpawnFunc>,
     proxy: EventsLoopProxy,
 }
 
 impl GuiSender {
     pub fn send(&self, what: SpawnFunc) -> Result<(), Error> {
-        match front_end() {
+        if let Err(err) = self.tx.send(what) {
-            // If we can get a handle on the GuiEventLoop then we
+            bail!("send failed: {:?}", err);
-            // are in the gui thread and can queue up func directly.
+        }
-            Some(front_end) => match front_end.downcast_ref::<GlutinFrontEnd>() {
-                Some(f) => f.event_loop.spawn_func(what),
-                None => bail!("front_end was not a GlutinFrontEnd!?"),
-            },
-            // Otherwise, send it through the bounded channel,
-            // which may block us
-            None => match self.tx.send(what) {
-                Ok(_) => {}
-                Err(err) => bail!("send failed: {:?}", err),
-            },
-        };
         self.proxy.wakeup()?;
         Ok(())
     }
 
     fn new(proxy: EventsLoopProxy) -> (GuiSender, Receiver<SpawnFunc>) {
-        // Set an upper bound on the number of items in the queue, so that
+        let (tx, rx) = mpsc::channel();
-        // we don't swamp the gui loop; this puts back pressure on the
-        // producer side so that we have a chance for eg: processing CTRL-C
-        let (tx, rx) = mpsc::sync_channel(12);
         (GuiSender { tx, proxy }, rx)
     }
 }
 
 #[derive(Clone)]
 pub struct GlutinGuiExecutor {
-    tx: Arc<GuiSender>,
+    tx: GuiSender,
 }
 
 impl Executor for GlutinGuiExecutor {
@@ -77,7 +54,7 @@ impl Executor for GlutinGuiExecutor {
     }
     fn clone_executor(&self) -> Box<dyn Executor> {
         Box::new(GlutinGuiExecutor {
-            tx: Arc::clone(&self.tx),
+            tx: self.tx.clone(),
         })
     }
 }
@@ -95,9 +72,8 @@ struct Windows {
 pub struct GuiEventLoop {
     pub event_loop: RefCell<glium::glutin::EventsLoop>,
     windows: Rc<RefCell<Windows>>,
-    gui_tx: Arc<GuiSender>,
+    gui_tx: GuiSender,
     gui_rx: Receiver<SpawnFunc>,
-    gui_thread_sends: RefCell<VecDeque<SpawnFunc>>,
     tick_rx: Receiver<()>,
 }
 
@@ -176,18 +152,13 @@ impl GuiEventLoop {
 
         Ok(Self {
             gui_rx,
-            gui_tx: Arc::new(gui_tx),
+            gui_tx,
-            gui_thread_sends: RefCell::new(VecDeque::new()),
             tick_rx,
             event_loop: RefCell::new(event_loop),
             windows: Rc::new(RefCell::new(Default::default())),
         })
     }
 
-    fn spawn_func(&self, func: SpawnFunc) {
-        self.gui_thread_sends.borrow_mut().push_back(func);
-    }
-
     fn gui_executor(&self) -> Box<dyn Executor> {
         Box::new(GlutinGuiExecutor {
             tx: self.gui_tx.clone(),
@@ -288,15 +259,7 @@ impl GuiEventLoop {
         }
     }
 
-    fn pop_gui_thread_send(&self) -> Option<SpawnFunc> {
-        self.gui_thread_sends.borrow_mut().pop_front()
-    }
-
     fn process_gui_exec(&self) -> Result<(), Error> {
-        while let Some(func) = self.pop_gui_thread_send() {
-            func();
-        }
-
         let start = SystemTime::now();
         loop {
             match start.elapsed() {