squiid/rust
1
0
Fork 0
Code Issues Pull requests Projects Activity

Revert "Downgrade notify and use RecommendedWatcher"

Browse source 
This reverts commit 5b0c86af7d.

The pre-5.0.12 release of notify fixed this issue.
This commit is contained in:
Alexander Sieg 2021-08-17 17:17:02 +02:00
parent 8d7eea9e3a
commit ca6a1d8c63
3 changed files with 28 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
Cargo.lock generated
View file

@ -765,6 +765,26 @@ version = "0.1.2"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8b23360e99b8717f20aaa4598f5a6541efbe30630039fbc7706cf954a87947ae" checksum = "8b23360e99b8717f20aaa4598f5a6541efbe30630039fbc7706cf954a87947ae"
[[package]]
name = "kqueue"
version = "1.0.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "512705bfcaeb3d46379771adc69deab978355fc68fdf960f9fb11abc8d678a96"
dependencies = [
"kqueue-sys",
"libc",
]
[[package]]
name = "kqueue-sys"
version = "1.0.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9803ae382091c10a5c7297ffb9fde284dbc9662b249f86eacef605d97ae92d99"
dependencies = [
"bitflags",
"libc",
]
[[package]] [[package]]
name = "la-arena" name = "la-arena"
version = "0.2.1" version = "0.2.1"
@ -945,15 +965,16 @@ dependencies = [
[[package]] [[package]]
name = "notify" name = "notify"
version = "5.0.0-pre.10" version = "5.0.0-pre.11"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "51f18203a26893ca1d3526cf58084025d5639f91c44f8b70ab3b724f60e819a0" checksum = "c614e7ed2b1cf82ec99aeffd8cf6225ef5021b9951148eb161393c394855032c"
dependencies = [ dependencies = [
"bitflags", "bitflags",
"crossbeam-channel", "crossbeam-channel",
"filetime", "filetime",
"fsevent-sys", "fsevent-sys",
"inotify", "inotify",
"kqueue",
"libc", "libc",
"mio", "mio",
"walkdir", "walkdir",

2
crates/vfs-notify/Cargo.toml
View file

@ -14,7 +14,7 @@ rustc-hash = "1.0"
jod-thread = "0.1.0" jod-thread = "0.1.0"
walkdir = "2.3.1" walkdir = "2.3.1"
crossbeam-channel = "0.5.0" crossbeam-channel = "0.5.0"
notify = "=5.0.0-pre.10" # check that it builds on NetBSD before upgrading notify = "=5.0.0-pre.11"
vfs = { path = "../vfs", version = "0.0.0" } vfs = { path = "../vfs", version = "0.0.0" }
paths = { path = "../paths", version = "0.0.0" } paths = { path = "../paths", version = "0.0.0" }

9
crates/vfs-notify/src/lib.rs
View file

@ -83,10 +83,9 @@ impl NotifyActor {
self.watcher = None; self.watcher = None;
if !config.watch.is_empty() { if !config.watch.is_empty() {
let (watcher_sender, watcher_receiver) = unbounded(); let (watcher_sender, watcher_receiver) = unbounded();
let watcher = let watcher = log_notify_error(RecommendedWatcher::new(move |event| {
log_notify_error(RecommendedWatcher::new_immediate(move |event| { watcher_sender.send(event).unwrap()
watcher_sender.send(event).unwrap() }));
}));
self.watcher = watcher.map(|it| (it, watcher_receiver)); self.watcher = watcher.map(|it| (it, watcher_receiver));
} }
@ -215,7 +214,7 @@ impl NotifyActor {
fn watch(&mut self, path: AbsPathBuf) { fn watch(&mut self, path: AbsPathBuf) {
if let Some((watcher, _)) = &mut self.watcher { if let Some((watcher, _)) = &mut self.watcher {
log_notify_error(watcher.watch(&path, RecursiveMode::NonRecursive)); log_notify_error(watcher.watch(path.as_ref(), RecursiveMode::NonRecursive));
} }
} }
fn send(&mut self, msg: loader::Message) { fn send(&mut self, msg: loader::Message) {