{"header":{"message":"Per-event delay","description":null,"timestamp":"2021-10-10T22:58:19.317612171Z","authors":[{}]},"hash":"SOYST6CC3OMFUTXYZ7ZBJR2U42ZLNDCN6SNB4AQ7YC7Q4J46H7IAC","authors":[{"login":"isagalaev","key":"GGyJA92mZf4oyvR5S2XWq6i2USZKkrxmabqwBcQpBwSe"}],"deps":{"hashes":[["SOYST6CC3OMFUTXYZ7ZBJR2U42ZLNDCN6SNB4AQ7YC7Q4J46H7IAC","Per-event delay"],["AA",null],["TNIQTVDKZBL34VRO3FGRD3AFAGOCJAAKFNMOLYBUHLHYLRMTUE3AC","Remove Debug constraint from Debouncer impl"],["MPE26QJ2WFCD3OKXZJ6C2VSF6E6UVLUNB6ORODFZOASMZLGQSUUQC","Define file info as a struct instead of using ad-hoc tuples"],["EPIHKWJDBRZLGVI5AA7OGNJXIIAO5JPXCG55NCBYY4YNKY6EERLAC","Implement passive debouncer"],["3PGX7SVOAB5DOZFA7OGREPZZEWSD4LXNTA6AQYYPTQO6AXVQHKMQC","Shuffle some code"],["SY4Q66QFFEQ2BPMJ5G7MSZPX52HM6QTHZXJWL2VVFB2JMWZQLJBQC","First draft"],["V2GAFFJH2YQJSG3CDQL2K6GWG7N73F33C3KXDFNYM3YNK4TZ3XLQC","Use debouncer in main.rs"],["TYK5XDMD7PSITQFFPHNLD3462EODC3FQIV5DCW5KA527FXIW7CTQC","Move config logic into a module"],["5GJRHBKCSWISBPJOAXWMXY3LMMD5GFOEHM3AEUKI5J7D4M3XM5GQC","Read processors from config"],["EHKSDEXADHIK2PFXJFBFQTAUAXBUIY57CKSDNLCQJH3WKPNHG6RAC","Extract parse_config()"],["FVJQ6OJYLCXGPDNHCP56JXZ44VQKFIOC7NC3S42D3JPQSZ2F7R4AC","Support multiple processors"]],"deps":["TNIQTVDKZBL34VRO3FGRD3AFAGOCJAAKFNMOLYBUHLHYLRMTUE3AC","MPE26QJ2WFCD3OKXZJ6C2VSF6E6UVLUNB6ORODFZOASMZLGQSUUQC"],"known":["SY4Q66QFFEQ2BPMJ5G7MSZPX52HM6QTHZXJWL2VVFB2JMWZQLJBQC","FVJQ6OJYLCXGPDNHCP56JXZ44VQKFIOC7NC3S42D3JPQSZ2F7R4AC","5GJRHBKCSWISBPJOAXWMXY3LMMD5GFOEHM3AEUKI5J7D4M3XM5GQC","EHKSDEXADHIK2PFXJFBFQTAUAXBUIY57CKSDNLCQJH3WKPNHG6RAC","3PGX7SVOAB5DOZFA7OGREPZZEWSD4LXNTA6AQYYPTQO6AXVQHKMQC","EPIHKWJDBRZLGVI5AA7OGNJXIIAO5JPXCG55NCBYY4YNKY6EERLAC","V2GAFFJH2YQJSG3CDQL2K6GWG7N73F33C3KXDFNYM3YNK4TZ3XLQC","TYK5XDMD7PSITQFFPHNLD3462EODC3FQIV5DCW5KA527FXIW7CTQC"]},"hunks":[{"Replacement":{"inode":{"change":4,"pos":48},"path":"src/main.rs","line":1,"ins":{"up_context":[{"change":4,"pos":48}],"down_context":[{"change":4,"pos":0}],"flag":"BLOCK","start":0,"end":51,"inode":{"change":4,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":48},"to":{"change":4,"start":49,"end":80},"introduced_by":4}],"inode":{"change":4,"pos":48}},"ins_contents":[{"Add":"#![feature(exit_status_error, binary_heap_retain)]"}],"del_contents":[{"Del":"#![feature(exit_status_error)]\n"}]}},{"Replacement":{"inode":{"change":4,"pos":48},"path":"src/main.rs","line":18,"ins":{"up_context":[{"change":3,"pos":95}],"down_context":[{"change":3,"pos":116}],"flag":"BLOCK","start":52,"end":130,"inode":{"change":4,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":95},"to":{"change":3,"start":95,"end":116},"introduced_by":3}],"inode":{"change":4,"pos":48}},"ins_contents":[{"Add":"const DELAY: Duration = Duration::from_millis(500);"},{"Add":""},{"Add":"#[derive(PartialEq, Eq)]"}],"del_contents":[{"Del":"#[derive(PartialEq)]\n"}]}},{"Replacement":{"inode":{"change":4,"pos":48},"path":"src/main.rs","line":80,"ins":{"up_context":[{"change":4,"pos":221}],"down_context":[{"change":4,"pos":959}],"flag":"BLOCK","start":131,"end":173,"inode":{"change":4,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":221},"to":{"change":4,"start":101,"end":169},"introduced_by":4}],"inode":{"change":4,"pos":48}},"ins_contents":[{"Add":" let mut debouncer = Debouncer::new();"}],"del_contents":[{"Del":" let mut debouncer = Debouncer::new(Duration::from_millis(500));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":48},"path":"src/main.rs","line":83,"ins":{"up_context":[{"change":4,"pos":925}],"down_context":[{"change":4,"pos":345}],"flag":"BLOCK","start":174,"end":302,"inode":{"change":4,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":925},"to":{"change":3,"start":368,"end":458},"introduced_by":3}],"inode":{"change":4,"pos":48}},"ins_contents":[{"Add":" for event in inotify.read_events_blocking(&mut buffer)? {"},{"Add":" debouncer.put(File::from(event), DELAY)"},{"Add":" }"}],"del_contents":[{"Del":" debouncer.new_events(inotify.read_events_blocking(&mut buffer)?.map(File::from));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":48},"path":"src/main.rs","line":102,"ins":{"up_context":[{"change":4,"pos":1047}],"down_context":[{"change":4,"pos":1286}],"flag":"BLOCK","start":303,"end":434,"inode":{"change":4,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1047},"to":{"change":3,"start":627,"end":712},"introduced_by":3}],"inode":{"change":4,"pos":48}},"ins_contents":[{"Add":" for event in inotify.read_events(&mut buffer)? {"},{"Add":" debouncer.put(File::from(event), DELAY)"},{"Add":" }"}],"del_contents":[{"Del":" debouncer.new_events(inotify.read_events(&mut buffer)?.map(File::from));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":1,"ins":{"up_context":[{"change":4,"pos":36}],"down_context":[{"change":4,"pos":62}],"flag":"BLOCK","start":435,"end":493,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":36},"to":{"change":4,"start":37,"end":62},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":"use std::cmp::Ordering;"},{"Add":"use std::collections::BinaryHeap;"}],"del_contents":[{"Del":"use std::cmp::PartialEq;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":5,"ins":{"up_context":[{"change":4,"pos":99}],"down_context":[{"change":4,"pos":116}],"flag":"BLOCK","start":494,"end":526,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":99},"to":{"change":4,"start":99,"end":116},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":"#[derive(Debug, PartialEq, Eq)]"}],"del_contents":[{"Del":"#[derive(Debug)]\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":8,"ins":{"up_context":[{"change":4,"pos":147}],"down_context":[{"change":4,"pos":166}],"flag":"BLOCK","start":527,"end":824,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":147},"to":{"change":4,"start":147,"end":166},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" release_at: Instant,"},{"Add":"}"},{"Add":""},{"Add":"impl Ord for Event {"},{"Add":" fn cmp(&self, other: &Self) -> Ordering {"},{"Add":" other.release_at.cmp(&self.release_at)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl PartialOrd for Event {"},{"Add":" fn partial_cmp(&self, other: &Self) -> Option {"},{"Add":" Some(self.cmp(other))"},{"Add":" }"}],"del_contents":[{"Del":" time: Instant,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":31,"ins":{"up_context":[{"change":4,"pos":263}],"down_context":[{"change":4,"pos":311}],"flag":"BLOCK","start":825,"end":859,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":263},"to":{"change":4,"start":263,"end":311},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" events: BinaryHeap>,"}],"del_contents":[{"Del":" delay: Duration,\n events: Vec>,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":34,"ins":{"up_context":[{"change":4,"pos":314}],"down_context":[{"change":4,"pos":416}],"flag":"BLOCK","start":860,"end":922,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":314},"to":{"change":2,"start":18,"end":52},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":52},"to":{"change":4,"start":366,"end":416},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":366},"to":{"change":4,"start":366,"end":416},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":"impl Debouncer {"},{"Add":" pub fn new() -> Debouncer {"}],"del_contents":[{"Del":"impl Debouncer {\n"},{"Del":" pub fn new(delay: Duration) -> Debouncer {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":37,"ins":{"up_context":[{"change":4,"pos":436}],"down_context":[{"change":4,"pos":483}],"flag":"BLOCK","start":923,"end":962,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":436},"to":{"change":4,"start":436,"end":483},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" events: BinaryHeap::new(),"}],"del_contents":[{"Del":" delay,\n events: vec![],\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":41,"ins":{"up_context":[{"change":4,"pos":500}],"down_context":[{"change":4,"pos":572}],"flag":"BLOCK","start":963,"end":1017,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":500},"to":{"change":4,"start":500,"end":572},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" pub fn put(&mut self, item: T, delay: Duration) {"}],"del_contents":[{"Del":" pub fn new_events>(&mut self, mut items: I) {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":43,"ins":{"up_context":[{"change":4,"pos":607}],"down_context":[{"change":4,"pos":826}],"flag":"BLOCK","start":1018,"end":1204,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":607},"to":{"change":4,"start":607,"end":826},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" self.events"},{"Add":" .retain(|e| e.release_at <= time || e.item != item);"},{"Add":" self.events.push(Event {"},{"Add":" item,"},{"Add":" release_at: time + delay,"},{"Add":" });"}],"del_contents":[{"Del":" let cutoff = time - self.delay;\n while let Some(item) = items.next() {\n self.events.retain(|e| e.time < cutoff || e.item != item);\n self.events.push(Event { item, time });\n }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":53,"ins":{"up_context":[{"change":4,"pos":908}],"down_context":[{"change":4,"pos":983}],"flag":"BLOCK","start":1205,"end":1240,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":908},"to":{"change":4,"start":908,"end":983},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" match self.events.peek() {"}],"del_contents":[{"Del":" let cutoff = time - self.delay;\n match self.events.get(0) {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":36},"path":"src/debounce.rs","line":55,"ins":{"up_context":[{"change":4,"pos":1017}],"down_context":[{"change":4,"pos":1154}],"flag":"BLOCK","start":1241,"end":1391,"inode":{"change":4,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1017},"to":{"change":4,"start":1017,"end":1154},"introduced_by":4}],"inode":{"change":4,"pos":36}},"ins_contents":[{"Add":" Some(e) if e.release_at > time => State::Wait(e.release_at - time),"},{"Add":" Some(_) => State::Ready(self.events.pop().unwrap().item),"}],"del_contents":[{"Del":" Some(e) if e.time > cutoff => State::Wait(e.time - cutoff),\n Some(_) => State::Ready(self.events.remove(0).item),\n"}]}}],"owner":"isagalaev","repo":"nfp","token":"c4SpLz8G2NlD89vnZLGtXjWCsqJjSE6/5mDYxLl2byg=","login":null}

…

Dependencies

Change contents