From 347256e966b597bf580212407dd21a8f7baab487 Mon Sep 17 00:00:00 2001 From: Ferdinand Schober Date: Tue, 16 Jan 2024 16:03:33 +0100 Subject: [PATCH] fix frontend channel buffer size --- src/frontend/gtk.rs | 7 ++++++- src/server.rs | 2 +- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/frontend/gtk.rs b/src/frontend/gtk.rs index dff916a..6b7e03f 100644 --- a/src/frontend/gtk.rs +++ b/src/frontend/gtk.rs @@ -34,7 +34,12 @@ pub fn run() -> glib::ExitCode { #[cfg(not(windows))] let ret = gtk_main(); - log::debug!("frontend exited"); + if ret == glib::ExitCode::FAILURE { + log::error!("frontend exited with failure"); + } else { + log::info!("frontend exited successfully"); + } + ret } diff --git a/src/server.rs b/src/server.rs index 1a9ba38..530cfac 100644 --- a/src/server.rs +++ b/src/server.rs @@ -110,7 +110,7 @@ impl Server { }; let (mut consumer, mut producer) = tokio::join!(consumer::create(), producer::create()); - let (frontend_tx, mut frontend_rx) = tokio::sync::mpsc::channel(1); + let (frontend_tx, mut frontend_rx) = tokio::sync::mpsc::channel(32); let (producer_notify_tx, mut producer_notify_rx) = tokio::sync::mpsc::channel(32); let (consumer_notify_tx, mut consumer_notify_rx) = tokio::sync::mpsc::channel(32); let (resolve_tx, mut resolve_rx) = tokio::sync::mpsc::channel(32);