{"header":{"message":"elpe-sched: CapPolicy becomes a sum type (Uncapped | Fixed(n) | Adaptive{yield_at_pct}) with PSI back-pressure. ELPE_DEFAULT_CORES gains psi:/pressure:: an undeclared action waits (polling /proc/pressure/cpu 'some avg10') while CPU pressure >= threshold, so a desktop-cum-CI-runner yields to interactive use and refills when idle. Fixed(n) unchanged, Uncapped still the non-breaking default. Pure tests: parse grammar, adaptive slice (quarter machine), PSI parse, resolve declared-wins","description":null,"timestamp":"2026-08-04T21:39:25.775142112Z","authors":[{}]},"hash":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC","elpe-sched: CapPolicy becomes a sum type (Uncapped | Fixed(n) | Adaptive{yield_at_pct}) with PSI back-pressure. ELPE_DEFAULT_CORES gains psi:/pressure:: an undeclared action waits (polling /proc/pressure/cpu 'some avg10') while CPU pressure >= threshold, so a desktop-cum-CI-runner yields to interactive use and refills when idle. Fixed(n) unchanged, Uncapped still the non-breaking default. Pure tests: parse grammar, adaptive slice (quarter machine), PSI parse, resolve declared-wins"],["AA",null],["AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC","backend: extract elpe-sched crate (NUMA-aware CPU placement); container/extract ELF-patch idempotence, arch-aware deb mirror, server error mapping"],["WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC","elpe-sched: privileged cgroup-v2 validation tests (ignored) — prove ELPE_DEFAULT_CORES caps+pins an undeclared action (cpu.max=quota, cpuset pinned to N cores) and that no default leaves it uncapped (cpu.max=max); finishes task A validation"]],"deps":["AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC","WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC"],"known":[]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":362,"ins":{"up_context":[{"change":2,"pos":13811}],"down_context":[{"change":2,"pos":13871}],"flag":"BLOCK","start":0,"end":315,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":13811},"to":{"change":2,"start":13811,"end":13871},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":"/// Policy deciding what an action that *declares no allocation* gets. A declared","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:81"}},{"Add":{"text":"/// allocation (REAPI Platform property, or a future native-derivation field)","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:159"}},{"Add":{"text":"/// always wins; this only governs undeclared work — the knob that keeps a shared","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:243"}},{"Add":{"text":"/// machine from overcommitting or from drowning its interactive user.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:314"}}],"del_contents":[{"Del":{"text":"/// Policy deciding an action's *effective* CPU allocation.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:13870"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":367,"ins":{"up_context":[{"change":2,"pos":13875}],"down_context":[{"change":2,"pos":14482}],"flag":"BLOCK","start":316,"end":1505,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":13875},"to":{"change":2,"start":13875,"end":14482},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":"/// Set via `ELPE_DEFAULT_CORES`:","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:349"}},{"Add":{"text":"/// - unset / empty / `0` → [`Uncapped`](CapPolicy::Uncapped) (historical).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:427"}},{"Add":{"text":"/// - `` → [`Fixed`](CapPolicy::Fixed): every undeclared action capped+pinned","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:510"}},{"Add":{"text":"/// to `n` cores.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:530"}},{"Add":{"text":"/// - `psi:` (or `pressure:`) → [`Adaptive`](CapPolicy::Adaptive): an","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:612"}},{"Add":{"text":"/// undeclared action is *held out* while live CPU pressure (`cpu.pressure some","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:694"}},{"Add":{"text":"/// avg10`) is at/above `pct` percent, then admitted with a modest slice. On a","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:775"}},{"Add":{"text":"/// desktop that doubles as a CI runner, CI evaporates the moment you touch the","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:857"}},{"Add":{"text":"/// machine and refills when it goes idle — no cron, no `nproc` guesswork.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:936"}},{"Add":{"text":"#[derive(Debug, Clone, Copy, PartialEq, Default)]","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:986"}},{"Add":{"text":"pub enum CapPolicy {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1007"}},{"Add":{"text":" /// Undeclared actions run uncapped — the historical, non-breaking default.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1089"}},{"Add":{"text":" #[default]","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1104"}},{"Add":{"text":" Uncapped,","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1118"}},{"Add":{"text":" /// Cap+pin every undeclared action to a fixed core count.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1181"}},{"Add":{"text":" Fixed(u32),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1197"}},{"Add":{"text":" /// Pressure-gated admission: hold undeclared work while `cpu.pressure some","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1277"}},{"Add":{"text":" /// avg10 >= yield_at_pct`, so interactive use always wins. The operator's one","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1360"}},{"Add":{"text":" /// integer knob is this threshold; the admitted slice size is a constant","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1438"}},{"Add":{"text":" /// ([`adaptive_cores`]).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1468"}},{"Add":{"text":" Adaptive { yield_at_pct: u32 },","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1504"}}],"del_contents":[{"Del":{"text":"/// An action may declare how many cores it wants (REAPI Platform property, or a","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:13955"}},{"Del":{"text":"/// future native-derivation field). When it declares nothing, [`default_cores`]","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14036"}},{"Del":{"text":"/// decides whether to cap anyway — the knob that makes overcommit impossible","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14116"}},{"Del":{"text":"/// even for undeclared work.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14146"}},{"Del":{"text":"///","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14150"}},{"Del":{"text":"/// [`default_cores`]: CapPolicy::default_cores","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14198"}},{"Del":{"text":"#[derive(Debug, Clone, Copy, Default)]","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14237"}},{"Del":{"text":"pub struct CapPolicy {","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14260"}},{"Del":{"text":" /// Cores to cap+pin when the action declares no allocation. `None` leaves","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14339"}},{"Del":{"text":" /// undeclared actions uncapped (the historical behaviour); `Some(n)` caps","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14418"}},{"Del":{"text":" /// them to `n` cores.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14445"}},{"Del":{"text":" pub default_cores: Option,","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14481"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":391,"ins":{"up_context":[{"change":2,"pos":14502}],"down_context":[{"change":2,"pos":14689}],"flag":"BLOCK","start":1506,"end":1653,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":14502},"to":{"change":2,"start":14502,"end":14689},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" /// Read the policy from `ELPE_DEFAULT_CORES` (see the type docs). Anything","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1585"}},{"Add":{"text":" /// unparseable degrades to [`Uncapped`](CapPolicy::Uncapped).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1652"}}],"del_contents":[{"Del":{"text":" /// Read the policy from the environment. `ELPE_DEFAULT_CORES=` sets the","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14581"}},{"Del":{"text":" /// default cap for undeclared actions; unset, empty, `0` or unparseable","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14658"}},{"Del":{"text":" /// leaves them uncapped.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14688"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":394,"ins":{"up_context":[{"change":2,"pos":14726}],"down_context":[{"change":2,"pos":14933}],"flag":"BLOCK","start":1654,"end":2502,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":14726},"to":{"change":2,"start":14726,"end":14933},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" match std::env::var(\"ELPE_DEFAULT_CORES\") {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1705"}},{"Add":{"text":" Ok(v) => CapPolicy::parse(v.trim()),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1754"}},{"Add":{"text":" Err(_) => CapPolicy::Uncapped,","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1797"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1807"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1813"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1814"}},{"Add":{"text":" /// Parse the `ELPE_DEFAULT_CORES` grammar; unparseable / empty / `0` →","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1892"}},{"Add":{"text":" /// [`Uncapped`](CapPolicy::Uncapped).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1935"}},{"Add":{"text":" pub fn parse(s: &str) -> CapPolicy {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:1976"}},{"Add":{"text":" let s = s.trim();","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2002"}},{"Add":{"text":" if let Some(pct) = s","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2031"}},{"Add":{"text":" .strip_prefix(\"psi:\")","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2065"}},{"Add":{"text":" .or_else(|| s.strip_prefix(\"pressure:\"))","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2118"}},{"Add":{"text":" {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2128"}},{"Add":{"text":" return match pct.trim().parse::() {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2181"}},{"Add":{"text":" Ok(p) if p > 0 => CapPolicy::Adaptive {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2237"}},{"Add":{"text":" yield_at_pct: p.min(100),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2283"}},{"Add":{"text":" },","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2302"}},{"Add":{"text":" _ => CapPolicy::Uncapped,","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2344"}},{"Add":{"text":" };","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2359"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2369"}},{"Add":{"text":" match s.parse::() {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2402"}},{"Add":{"text":" Ok(n) if n > 0 => CapPolicy::Fixed(n),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2453"}},{"Add":{"text":" _ => CapPolicy::Uncapped,","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2491"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2501"}}],"del_contents":[{"Del":{"text":" let default_cores = std::env::var(\"ELPE_DEFAULT_CORES\")","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14789"}},{"Del":{"text":" .ok()","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14807"}},{"Del":{"text":" .and_then(|v| v.trim().parse::().ok())","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14863"}},{"Del":{"text":" .filter(|n| *n > 0);","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14896"}},{"Del":{"text":" CapPolicy { default_cores }","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:14932"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":421,"ins":{"up_context":[{"change":2,"pos":14940}],"down_context":[{"change":2,"pos":15191}],"flag":"BLOCK","start":2503,"end":4849,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":14940},"to":{"change":2,"start":14940,"end":15191},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" /// The effective core count for an action given its `declared` allocation and","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2585"}},{"Add":{"text":" /// the machine's `total` CPUs: the declaration always wins; otherwise the","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2664"}},{"Add":{"text":" /// policy decides. Adaptive returns its constant slice — the pressure *gate*","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2748"}},{"Add":{"text":" /// lives in [`ResourceGrant::acquire`], not here, so this stays pure.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2823"}},{"Add":{"text":" pub fn resolve(&self, declared: Option, total: u32) -> Option {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2901"}},{"Add":{"text":" if let Some(d) = declared {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2937"}},{"Add":{"text":" return Some(d);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2965"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2975"}},{"Add":{"text":" match *self {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:2997"}},{"Add":{"text":" CapPolicy::Uncapped => None,","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3038"}},{"Add":{"text":" CapPolicy::Fixed(n) => Some(n),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3082"}},{"Add":{"text":" CapPolicy::Adaptive { .. } => Some(adaptive_cores(total)),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3153"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3163"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3169"}},{"Add":{"text":"}","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3171"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3172"}},{"Add":{"text":"/// Per-action slice for [`CapPolicy::Adaptive`]: a quarter of the machine (min","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3252"}},{"Add":{"text":"/// one core), so a few undeclared actions pack while each stays NUMA-pinned. Held","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3335"}},{"Add":{"text":"/// a constant on purpose — the operator's only adaptive knob is the pressure","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3415"}},{"Add":{"text":"/// threshold, keeping the policy \"one integer\".","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3464"}},{"Add":{"text":"fn adaptive_cores(total: u32) -> u32 {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3503"}},{"Add":{"text":" (total / 4).max(1)","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3526"}},{"Add":{"text":"}","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3528"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3529"}},{"Add":{"text":"/// Live CPU pressure: the `some avg10` figure from PSI — the percent of the last","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3613"}},{"Add":{"text":"/// ~10s during which at least one task stalled waiting for CPU. Reads the machine","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3696"}},{"Add":{"text":"/// root `/proc/pressure/cpu`. `None` when PSI is unavailable (older kernel or","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3775"}},{"Add":{"text":"/// `CONFIG_PSI` off); callers then treat pressure as zero (adaptive admits","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3851"}},{"Add":{"text":"/// immediately, i.e. degrades to \"always run\").","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3900"}},{"Add":{"text":"pub fn cpu_pressure_some_avg10() -> Option {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:3950"}},{"Add":{"text":" parse_psi_some_avg10(&std::fs::read_to_string(\"/proc/pressure/cpu\").ok()?)","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4029"}},{"Add":{"text":"}","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4031"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4032"}},{"Add":{"text":"/// Extract `some ... avg10=` from a PSI blob (`/proc/pressure/cpu`).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4105"}},{"Add":{"text":"fn parse_psi_some_avg10(s: &str) -> Option {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4155"}},{"Add":{"text":" let line = s.lines().find(|l| l.starts_with(\"some \"))?;","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4215"}},{"Add":{"text":" line.split_whitespace()","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4243"}},{"Add":{"text":" .find_map(|f| f.strip_prefix(\"avg10=\"))","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4291"}},{"Add":{"text":" .and_then(|v| v.parse::().ok())","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4336"}},{"Add":{"text":"}","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4338"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4339"}},{"Add":{"text":"/// Block until CPU pressure falls below `yield_at_pct` percent, polling PSI once","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4421"}},{"Add":{"text":"/// a second. Returns immediately when pressure is already low or PSI is","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4494"}},{"Add":{"text":"/// unavailable. This is the adaptive policy's back-pressure: an undeclared action","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4577"}},{"Add":{"text":"/// waits here while the machine's interactive user keeps it busy.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4644"}},{"Add":{"text":"fn wait_for_pressure_below(yield_at_pct: u32) {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4692"}},{"Add":{"text":" let thr = yield_at_pct as f64;","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4727"}},{"Add":{"text":" while matches!(cpu_pressure_some_avg10(), Some(p) if p >= thr) {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4796"}},{"Add":{"text":" std::thread::sleep(Duration::from_secs(1));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4848"}}],"del_contents":[{"Del":{"text":" /// The effective core count for an action that `declared` (or didn't) an","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:15017"}},{"Del":{"text":" /// allocation: the declaration wins, else the policy default.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:15084"}},{"Del":{"text":" pub fn resolve(&self, declared: Option) -> Option {","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:15150"}},{"Del":{"text":" declared.or(self.default_cores)","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:15190"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":495,"ins":{"up_context":[{"change":2,"pos":16338}],"down_context":[{"change":2,"pos":16384}],"flag":"BLOCK","start":4850,"end":5357,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":16338},"to":{"change":2,"start":16338,"end":16384},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" let total = core_allocator().total() as u32;","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4902"}},{"Add":{"text":" // Adaptive back-pressure: an action that declares nothing waits out","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:4979"}},{"Add":{"text":" // interactive CPU pressure before it even reserves cores. Declared work","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5060"}},{"Add":{"text":" // is never gated (it asked for a specific allocation).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5124"}},{"Add":{"text":" if declared.is_none() {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5156"}},{"Add":{"text":" if let CapPolicy::Adaptive { yield_at_pct } = *policy {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5224"}},{"Add":{"text":" wait_for_pressure_below(yield_at_pct);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5279"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5293"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5303"}},{"Add":{"text":" let cores = policy.resolve(declared, total);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5356"}}],"del_contents":[{"Del":{"text":" let cores = policy.resolve(declared);","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:16383"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":610,"ins":{"up_context":[{"change":2,"pos":19921}],"down_context":[{"change":2,"pos":20160}],"flag":"BLOCK","start":5358,"end":7050,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":19921},"to":{"change":2,"start":19921,"end":20160},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" let total = 16;","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5381"}},{"Add":{"text":" // Uncapped: undeclared stays uncapped, declared passes through.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5454"}},{"Add":{"text":" assert_eq!(CapPolicy::Uncapped.resolve(None, total), None);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5522"}},{"Add":{"text":" assert_eq!(CapPolicy::Uncapped.resolve(Some(3), total), Some(3));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5596"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5597"}},{"Add":{"text":" // Fixed: undeclared gets the fixed count, declared still wins.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5669"}},{"Add":{"text":" let p = CapPolicy::Fixed(4);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5706"}},{"Add":{"text":" assert_eq!(p.resolve(None, total), Some(4));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5759"}},{"Add":{"text":" assert_eq!(p.resolve(Some(2), total), Some(2));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5815"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5816"}},{"Add":{"text":" // Adaptive: undeclared gets the constant slice (quarter machine),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5891"}},{"Add":{"text":" // declared still wins outright (and is never gated).","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:5953"}},{"Add":{"text":" let p = CapPolicy::Adaptive { yield_at_pct: 10 };","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6011"}},{"Add":{"text":" assert_eq!(p.resolve(None, total), Some(4));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6064"}},{"Add":{"text":" assert_eq!(p.resolve(Some(7), total), Some(7));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6120"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6126"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6127"}},{"Add":{"text":" #[test]","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6139"}},{"Add":{"text":" fn cap_policy_parses_the_env_grammar() {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6184"}},{"Add":{"text":" assert_eq!(CapPolicy::parse(\"\"), CapPolicy::Uncapped);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6247"}},{"Add":{"text":" assert_eq!(CapPolicy::parse(\"0\"), CapPolicy::Uncapped);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6311"}},{"Add":{"text":" assert_eq!(CapPolicy::parse(\"garbage\"), CapPolicy::Uncapped);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6381"}},{"Add":{"text":" assert_eq!(CapPolicy::parse(\" 6 \"), CapPolicy::Fixed(6));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6448"}},{"Add":{"text":" assert_eq!(","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6468"}},{"Add":{"text":" CapPolicy::parse(\"psi:12\"),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6508"}},{"Add":{"text":" CapPolicy::Adaptive { yield_at_pct: 12 }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6561"}},{"Add":{"text":" );","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6572"}},{"Add":{"text":" assert_eq!(","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6592"}},{"Add":{"text":" CapPolicy::parse(\"pressure:5\"),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6636"}},{"Add":{"text":" CapPolicy::Adaptive { yield_at_pct: 5 }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6688"}},{"Add":{"text":" );","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6699"}},{"Add":{"text":" // Percentages clamp to 100; psi:0 and non-numeric fall back to uncapped.","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6781"}},{"Add":{"text":" assert_eq!(","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6801"}},{"Add":{"text":" CapPolicy::parse(\"psi:250\"),","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6842"}},{"Add":{"text":" CapPolicy::Adaptive { yield_at_pct: 100 }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6896"}},{"Add":{"text":" );","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6907"}},{"Add":{"text":" assert_eq!(CapPolicy::parse(\"psi:0\"), CapPolicy::Uncapped);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:6975"}},{"Add":{"text":" assert_eq!(CapPolicy::parse(\"psi:x\"), CapPolicy::Uncapped);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7043"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7049"}}],"del_contents":[{"Del":{"text":" // No default: undeclared stays uncapped, declared passes through.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:19995"}},{"Del":{"text":" let p = CapPolicy {","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20023"}},{"Del":{"text":" default_cores: None,","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20056"}},{"Del":{"text":" };","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20067"}},{"Del":{"text":" assert_eq!(p.resolve(None), None);","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20110"}},{"Del":{"text":" assert_eq!(p.resolve(Some(3)), Some(3));","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20159"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":650,"ins":{"up_context":[{"change":2,"pos":20161}],"down_context":[{"change":2,"pos":20408}],"flag":"BLOCK","start":7051,"end":7668,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":20161},"to":{"change":2,"start":20161,"end":20408},"introduced_by":2}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" #[test]","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7062"}},{"Add":{"text":" fn adaptive_slice_is_a_quarter_machine_min_one() {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7117"}},{"Add":{"text":" assert_eq!(adaptive_cores(32), 8);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7160"}},{"Add":{"text":" assert_eq!(adaptive_cores(4), 1);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7202"}},{"Add":{"text":" assert_eq!(adaptive_cores(1), 1);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7244"}},{"Add":{"text":" assert_eq!(adaptive_cores(0), 1);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7286"}},{"Add":{"text":" }","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7292"}},{"Add":{"text":"","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7293"}},{"Add":{"text":" #[test]","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7305"}},{"Add":{"text":" fn parses_psi_some_avg10() {","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7338"}},{"Add":{"text":" let blob = \"some avg10=1.23 avg60=0.45 avg300=0.00 total=339588147\\n\\","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7416"}},{"Add":{"text":" full avg10=0.00 avg60=0.00 avg300=0.00 total=0\\n\";","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7487"}},{"Add":{"text":" assert_eq!(parse_psi_some_avg10(blob), Some(1.23));","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7547"}},{"Add":{"text":" assert_eq!(parse_psi_some_avg10(\"full avg10=9.9\\n\"), None);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7615"}},{"Add":{"text":" assert_eq!(parse_psi_some_avg10(\"\"), None);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7667"}}],"del_contents":[{"Del":{"text":" // With a default: undeclared gets the default, declared still wins.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20237"}},{"Del":{"text":" let p = CapPolicy {","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20265"}},{"Del":{"text":" default_cores: Some(4),","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20301"}},{"Del":{"text":" };","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20312"}},{"Del":{"text":" assert_eq!(p.resolve(None), Some(4));","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20358"}},{"Del":{"text":" assert_eq!(p.resolve(Some(2)), Some(2));","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:20407"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":690,"ins":{"up_context":[{"change":3,"pos":1203}],"down_context":[{"change":3,"pos":1283}],"flag":"BLOCK","start":7669,"end":7711,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1203},"to":{"change":3,"start":1203,"end":1283},"introduced_by":3}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" let policy = CapPolicy::Fixed(2);","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7710"}}],"del_contents":[{"Del":{"text":" let policy = CapPolicy {","pos":"WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC:1235"}},{"Del":{"text":" default_cores: Some(2),","pos":"WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC:1271"}},{"Del":{"text":" };","pos":"WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC:1282"}}]}},{"Replacement":{"inode":{"change":2,"pos":42},"path":"elpe-sched/src/lib.rs","line":743,"ins":{"up_context":[{"change":3,"pos":3524}],"down_context":[{"change":3,"pos":3601}],"flag":"BLOCK","start":7712,"end":7754,"inode":{"change":2,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3524},"to":{"change":3,"start":3524,"end":3601},"introduced_by":3}],"inode":{"change":2,"pos":42}},"ins_contents":[{"Add":{"text":" let policy = CapPolicy::Uncapped;","pos":"FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC:7753"}}],"del_contents":[{"Del":{"text":" let policy = CapPolicy {","pos":"WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC:3556"}},{"Del":{"text":" default_cores: None,","pos":"WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC:3589"}},{"Del":{"text":" };","pos":"WWVOLJQXBKOYWUEY7SINFBAWEUYDRKDDOE3OVNT6QEEEA4A5HY3QC:3600"}}]}}],"owner":"pmeunier","repo":"elpe","token":"0Otm88nB3uB0xnAv96BBsosYyuiNzAn1eQ539tJ6Co0=","login":null}

…

Dependencies

Change contents

Review