wez/wezterm
1
1
Fork 0
mirror of https://github.com/wez/wezterm.git synced 2024-11-23 15:04:36 +03:00
Code Issues Projects Releases Wiki Activity

make mux server frontend channel unbounded

Browse Source 
This avoids the possibility of deadlock if you connect to a remote
host and quickly dump a lot of output to the terminal.
This commit is contained in:
Wez Furlong 2019-06-20 08:59:26 -07:00
parent 4171ad3aa3
commit 6c9e851ffa
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/frontend/muxserver/mod.rs
View File

@ -11,12 +11,12 @@ use log::info;
use promise::Executor;
use promise::SpawnFunc;
use std::rc::Rc;
use std::sync::mpsc::{self, Receiver, SyncSender};
use std::sync::mpsc::{self, Receiver, Sender};
use std::sync::Arc;
#[derive(Clone)]
struct MuxExecutor {
tx: SyncSender<SpawnFunc>,
tx: Sender<SpawnFunc>,
}
impl Executor for MuxExecutor {
@ -31,14 +31,14 @@ impl Executor for MuxExecutor {
}
pub struct MuxServerFrontEnd {
tx: SyncSender<SpawnFunc>,
tx: Sender<SpawnFunc>,
rx: Receiver<SpawnFunc>,
}
impl MuxServerFrontEnd {
#[cfg_attr(feature = "cargo-clippy", allow(clippy::new_ret_no_self))]
fn new(mux: &Rc<Mux>, start_listener: bool) -> Result<Rc<dyn FrontEnd>, Error> {
let (tx, rx) = mpsc::sync_channel(4);
let (tx, rx) = mpsc::channel();
if start_listener {
spawn_listener(mux.config(), Box::new(MuxExecutor { tx: tx.clone() }))?;