perf: do not listen for file changes in inactive tabs (#2958)

This commit is contained in:
三咲雅 misaki masa 2025-07-06 22:27:56 +08:00 committed by GitHub
parent 52ecb31f5a
commit 917e1f54a1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
15 changed files with 35 additions and 102 deletions

View file

@ -1,4 +1,4 @@
use std::collections::HashSet;
use std::iter;
use yazi_parser::mgr::WatchOpt;
@ -7,16 +7,10 @@ use crate::mgr::Mgr;
impl Mgr {
#[yazi_codegen::command]
pub fn watch(&mut self, _: WatchOpt) {
let mut to_watch = HashSet::with_capacity(3 * self.tabs.len());
for tab in self.tabs.iter() {
to_watch.insert(tab.cwd());
if let Some(ref p) = tab.parent {
to_watch.insert(&p.url);
}
if let Some(h) = tab.hovered().filter(|&h| h.is_dir()) {
to_watch.insert(&h.url);
}
}
self.watcher.watch(to_watch);
let it = iter::once(self.tabs.active().cwd())
.chain(self.tabs.parent().map(|p| &p.url))
.chain(self.tabs.hovered().filter(|h| h.is_dir()).map(|h| &h.url));
self.watcher.watch(it);
}
}

View file

@ -51,6 +51,9 @@ impl Tabs {
#[inline]
pub(super) fn active_mut(&mut self) -> &mut Tab { &mut self.items[self.cursor] }
#[inline]
pub fn parent(&self) -> Option<&Folder> { self.active().parent.as_ref() }
#[inline]
pub fn current(&self) -> &Folder { &self.active().current }

View file

@ -51,9 +51,8 @@ impl Watcher {
Self { in_tx, out_tx }
}
pub(super) fn watch(&mut self, mut new: HashSet<&Url>) {
new.retain(|&u| u.is_regular());
self.in_tx.send(new.into_iter().cloned().collect()).ok();
pub(super) fn watch<'a>(&mut self, it: impl Iterator<Item = &'a Url>) {
self.in_tx.send(it.filter(|u| u.is_regular()).cloned().collect()).ok();
}
pub(super) fn push_files(&self, urls: Vec<Url>) {

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct EscapeOpt;
impl From<CmdCow> for EscapeOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for EscapeOpt {
fn from(_: ()) -> Self { Self }
}
pub type EscapeOpt = crate::VoidOpt;

View file

@ -1 +1,3 @@
yazi_macro::mod_pub!(cmp confirm help input mgr notify pick spot tab tasks which);
yazi_macro::mod_flat!(void);

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct UnyankOpt;
impl From<CmdCow> for UnyankOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for UnyankOpt {
fn from(_: ()) -> Self { Self }
}
pub type UnyankOpt = crate::VoidOpt;

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct WatchOpt;
impl From<CmdCow> for WatchOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for WatchOpt {
fn from((): ()) -> Self { Self }
}
pub type WatchOpt = crate::VoidOpt;

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct CloseOpt;
impl From<CmdCow> for CloseOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for CloseOpt {
fn from(_: ()) -> Self { Self }
}
pub type CloseOpt = crate::VoidOpt;

View file

@ -1,7 +1 @@
use yazi_shared::event::CmdCow;
pub struct FollowOpt;
impl From<CmdCow> for FollowOpt {
fn from(_: CmdCow) -> Self { Self }
}
pub type FollowOpt = crate::VoidOpt;

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct LeaveOpt;
impl From<()> for LeaveOpt {
fn from(_: ()) -> Self { Self }
}
impl From<CmdCow> for LeaveOpt {
fn from(_: CmdCow) -> Self { Self }
}
pub type LeaveOpt = crate::VoidOpt;

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct CloseOpt;
impl From<CmdCow> for CloseOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for CloseOpt {
fn from(_: ()) -> Self { Self }
}
pub type CloseOpt = crate::VoidOpt;

View file

@ -1,11 +1 @@
use yazi_shared::event::CmdCow;
pub struct ShowOpt;
impl From<CmdCow> for ShowOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for ShowOpt {
fn from(_: ()) -> Self { Self }
}
pub type ShowOpt = crate::VoidOpt;

11
yazi-parser/src/void.rs Normal file
View file

@ -0,0 +1,11 @@
use yazi_shared::event::CmdCow;
pub struct VoidOpt;
impl From<CmdCow> for VoidOpt {
fn from(_: CmdCow) -> Self { Self }
}
impl From<()> for VoidOpt {
fn from(_: ()) -> Self { Self }
}

View file

@ -8,7 +8,7 @@ function M:peek(job)
return require("empty").msg(
job,
code == 2 and "File list in this archive is encrypted"
or "Failed to start both `7zz` and `7z`. Do you have 7-zip installed?"
or "Failed to start either `7zz` or `7z`. Do you have 7-zip installed?"
)
end
@ -65,7 +65,7 @@ function M.spawn_7z(args)
local child = try("7zz") or try("7z")
if not child then
return ya.err("Failed to start both `7zz` and `7z`, error: " .. last_err)
return ya.err("Failed to start either `7zz` or `7z`, error: " .. last_err)
end
return child, last_err
end

View file

@ -53,7 +53,7 @@ function M:try_with(from, pwd, to)
local archive = require("archive")
local child, err = archive.spawn_7z { "x", "-aou", "-sccUTF-8", "-p" .. pwd, "-o" .. tostring(tmp), tostring(from) }
if not child then
fail("Failed to start both `7zz` and `7z`, error: " .. err)
fail("Failed to start either `7zz` or `7z`, error: " .. err)
end
local output, err = child:wait_with_output()