{"header":{"message":"cap policy travels frontend->backend over gRPC. New SetCapPolicy RPC + CapPolicy{CapMode mode, uint32 value} proto message; backend installs a process-global policy override (elpe_sched::set_default_policy) that container.rs reads via default_policy() at both acquire sites, taking precedence over ELPE_DEFAULT_CORES. OCaml gains a cap_policy sum type (Uncapped|Fixed n|Adaptive pct), elpe build -cores SPEC (N or psi:N) parses+pushes it before building; absent flag pushes nothing (non-breaking). Rust+OCaml green","description":null,"timestamp":"2026-08-04T21:46:01.682656428Z","authors":[{}]},"hash":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC","cap policy travels frontend->backend over gRPC. New SetCapPolicy RPC + CapPolicy{CapMode mode, uint32 value} proto message; backend installs a process-global policy override (elpe_sched::set_default_policy) that container.rs reads via default_policy() at both acquire sites, taking precedence over ELPE_DEFAULT_CORES. OCaml gains a cap_policy sum type (Uncapped|Fixed n|Adaptive pct), elpe build -cores SPEC (N or psi:N) parses+pushes it before building; absent flag pushes nothing (non-breaking). Rust+OCaml green"],["AA",null],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"],["ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","Adding the OCaml interface"],["P27ILID2JNRMIXJNW47AWFYDU37BXQETA63W742HWVWGAXEET4QQC","Frontend: starting the connection before linking"],["LIMIMBOUN3DCIKKTHOK4TAXAWQXNVQXBTMNZYN22DJX4L4FZQH4AC","Bootstrapping the Rust part"],["HGUKDMNSU2QXIJ3ZR3GTZY467BYNCU2DLH4HR2ALWGHNZDFSYKLQC","Formatting + OPAM files"],["AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC","backend: extract elpe-sched crate (NUMA-aware CPU placement); container/extract ELF-patch idempotence, arch-aware deb mirror, server error mapping"],["WLGN2XYIIDGFB2RUD7WX6J5RFK2DS37HLV2WIGS64P5G4L6BNIQQC","elpe frontend: SBOM (SPDX 2.3 / CycloneDX 1.5) from lockfile; Darwin/Homebrew source & Mach-O target + lock; mccs solver wiring"],["5YEQMBVCGIBAJA66B6XSUMHQVXU2MVPDXVJJ7S6QEAJQOI2PN2MAC","B.3 backend core: enforce output pins from in-memory output lock (SetOutputLock RPC, shared derivation_input_hash, DerivationResult.input_hash)"],["RQCTKMTOLLSGTRF2LTCUG4S5N22MAPDPIBFSH3CM5WWJ2MQYUB6QC","B.3 frontend: elpe update writes output pins, elpe build pushes+enforces them"],["JBUPSWE3FK4J6KOFZVURAIHX4BHLFR5C5UX36QXLBW4CUPLUB2MAC","sbom: U2(b) full lean — CycloneDX only; drop SPDX serialisers, elpe sbom cmd, lock -sbom"],["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"],["HX4TXY2DTPEEQPU6CMHSD3X4VX7A4OKV7N3HT3QZKSNHNAZOK7GQC","Fixed-output derivations enable the network"],["INFPGWOJOI7K5HT2VNENSCWKHVCKTX22WTQ44KY3T3ZYVTRXO62QC","Task B parts 1-2: split output_hash into network capability + enforced content pin. New DerivationRequest.network bool grants build-time network (deny-by-default namespace); opam/pypi resolve derivations set it instead of a bogus output_hash string. output_hash is now a real pin: run_in_container re-hashes fresh and cached output and returns Error::WrongHash on mismatch (check_output_pin), rejecting the build; no-op when unset (non-breaking). Remaining part 3: output lockfile to feed pins at scale."]],"deps":["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","P27ILID2JNRMIXJNW47AWFYDU37BXQETA63W742HWVWGAXEET4QQC","LIMIMBOUN3DCIKKTHOK4TAXAWQXNVQXBTMNZYN22DJX4L4FZQH4AC","HGUKDMNSU2QXIJ3ZR3GTZY467BYNCU2DLH4HR2ALWGHNZDFSYKLQC","AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC","WLGN2XYIIDGFB2RUD7WX6J5RFK2DS37HLV2WIGS64P5G4L6BNIQQC","5YEQMBVCGIBAJA66B6XSUMHQVXU2MVPDXVJJ7S6QEAJQOI2PN2MAC","RQCTKMTOLLSGTRF2LTCUG4S5N22MAPDPIBFSH3CM5WWJ2MQYUB6QC","JBUPSWE3FK4J6KOFZVURAIHX4BHLFR5C5UX36QXLBW4CUPLUB2MAC","FUJZ2MGRHBZB4T2REPRUNMQCHUO2T5M4BAUD57N3X5PKW7PLFW5QC"],"known":["HX4TXY2DTPEEQPU6CMHSD3X4VX7A4OKV7N3HT3QZKSNHNAZOK7GQC","INFPGWOJOI7K5HT2VNENSCWKHVCKTX22WTQ44KY3T3ZYVTRXO62QC"]},"hunks":[{"Edit":{"inode":{"change":2,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":249,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":7014}],"down_context":[{"change":9,"pos":7014}],"flag":"BLOCK","start":0,"end":766,"inode":{"change":2,"pos":55490}}},"contents":[{"Add":{"text":"}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2"}},{"Add":{"text":"// Default CPU policy for actions that declare no allocation, mirroring","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:74"}},{"Add":{"text":"// elpe-sched::CapPolicy. Lets the frontend ship a policy that travels with it","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:153"}},{"Add":{"text":"// (the \"config that follows the artifact\"), overriding the backend's","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:223"}},{"Add":{"text":"// ELPE_DEFAULT_CORES env until cleared. A declared allocation always wins; this","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:304"}},{"Add":{"text":"// only governs undeclared work.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:337"}},{"Add":{"text":"enum CapMode {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:352"}},{"Add":{"text":" // Undeclared actions run uncapped — the historical, non-breaking default.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:431"}},{"Add":{"text":" CAP_UNCAPPED = 0;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:451"}},{"Add":{"text":" // Cap+pin every undeclared action to `value` cores.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:506"}},{"Add":{"text":" CAP_FIXED = 1;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:523"}},{"Add":{"text":" // PSI back-pressure: hold an undeclared action while CPU pressure","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:592"}},{"Add":{"text":" // (`cpu.pressure some avg10`) is at/above `value` percent, then admit it with","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:673"}},{"Add":{"text":" // a modest slice. A desktop-cum-CI-runner yields to interactive use.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:745"}},{"Add":{"text":" CAP_ADAPTIVE = 2;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:765"}}]}},{"Edit":{"inode":{"change":2,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":267,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":7017}],"down_context":[{"change":2,"pos":55906}],"flag":"BLOCK","start":767,"end":1023,"inode":{"change":2,"pos":55490}}},"contents":[{"Add":{"text":"message CapPolicy {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:786"}},{"Add":{"text":" CapMode mode = 1;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:806"}},{"Add":{"text":" // Cores for CAP_FIXED; PSI pressure-threshold percent for CAP_ADAPTIVE;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:881"}},{"Add":{"text":" // ignored for CAP_UNCAPPED.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:912"}},{"Add":{"text":" uint32 value = 2;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:932"}},{"Add":{"text":"}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:934"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:935"}},{"Add":{"text":"message SetCapPolicyRequest {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:965"}},{"Add":{"text":" CapPolicy policy = 1;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:989"}},{"Add":{"text":"}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:991"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:992"}},{"Add":{"text":"message SetCapPolicyReply {}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1021"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1022"}}]}},{"Edit":{"inode":{"change":2,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":285,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":7172}],"down_context":[{"change":3,"pos":63895}],"flag":"BLOCK","start":1024,"end":1170,"inode":{"change":2,"pos":55490}}},"contents":[{"Add":{"text":" // Install the default CPU policy for undeclared actions (overrides env).","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1099"}},{"Add":{"text":" rpc SetCapPolicy (SetCapPolicyRequest) returns (SetCapPolicyReply);","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1169"}}]}},{"Replacement":{"inode":{"change":7,"pos":42},"path":"elpe-sched/src/lib.rs","line":27,"ins":{"up_context":[{"change":7,"pos":1563}],"down_context":[{"change":7,"pos":1606}],"flag":"BLOCK","start":1171,"end":1222,"inode":{"change":7,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1563},"to":{"change":7,"start":1563,"end":1606},"introduced_by":7}],"inode":{"change":7,"pos":42}},"ins_contents":[{"Add":{"text":"use std::sync::{Condvar, Mutex, OnceLock, RwLock};","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1221"}}],"del_contents":[{"Del":{"text":"use std::sync::{Condvar, Mutex, OnceLock};","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:1605"}}]}},{"Edit":{"inode":{"change":7,"pos":42},"path":"elpe-sched/src/lib.rs","line":443,"atom":{"NewVertex":{"up_context":[{"change":12,"pos":3527}],"down_context":[{"change":12,"pos":3527}],"flag":"BLOCK","start":1223,"end":1913,"inode":{"change":7,"pos":42}}},"contents":[{"Add":{"text":"}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1224"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1225"}},{"Add":{"text":"/// Process-global override for the default policy, installed out-of-band (e.g. a","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1307"}},{"Add":{"text":"/// frontend `SetCapPolicy` RPC — the \"config that travels with the artifact\") to","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1391"}},{"Add":{"text":"/// take precedence over `ELPE_DEFAULT_CORES`. `None` means \"fall back to the env\".","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1475"}},{"Add":{"text":"fn policy_override() -> &'static RwLock> {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1536"}},{"Add":{"text":" static OVERRIDE: OnceLock>> = OnceLock::new();","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1612"}},{"Add":{"text":" OVERRIDE.get_or_init(|| RwLock::new(None))","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1659"}},{"Add":{"text":"}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1661"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1662"}},{"Add":{"text":"/// Install a default policy that overrides `ELPE_DEFAULT_CORES` for subsequent","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1742"}},{"Add":{"text":"/// [`ResourceGrant::acquire`] calls. Idempotent; last write wins.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1809"}},{"Add":{"text":"pub fn set_default_policy(policy: CapPolicy) {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1856"}},{"Add":{"text":" *policy_override().write().unwrap() = Some(policy);","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1912"}}]}},{"Edit":{"inode":{"change":7,"pos":42},"path":"elpe-sched/src/lib.rs","line":459,"atom":{"NewVertex":{"up_context":[{"change":12,"pos":3530}],"down_context":[{"change":12,"pos":3530}],"flag":"BLOCK","start":1914,"end":2300,"inode":{"change":7,"pos":42}}},"contents":[{"Add":{"text":"/// The effective default policy for undeclared actions: the pushed override if","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:1993"}},{"Add":{"text":"/// one was installed, else [`CapPolicy::from_env`]. Call this — not `from_env`","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2075"}},{"Add":{"text":"/// directly — at the acquire sites, so a frontend-pushed policy takes effect.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2156"}},{"Add":{"text":"pub fn default_policy() -> CapPolicy {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2195"}},{"Add":{"text":" policy_override()","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2217"}},{"Add":{"text":" .read()","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2233"}},{"Add":{"text":" .unwrap()","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2251"}},{"Add":{"text":" .unwrap_or_else(CapPolicy::from_env)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2296"}},{"Add":{"text":"}","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2298"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2299"}}]}},{"Replacement":{"inode":{"change":3,"pos":44692},"path":"src/container.rs","line":2,"ins":{"up_context":[{"change":6,"pos":42}],"down_context":[{"change":3,"pos":44735}],"flag":"BLOCK","start":2301,"end":2353,"inode":{"change":3,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":42},"to":{"change":7,"start":139519,"end":139582},"introduced_by":7}],"inode":{"change":3,"pos":44692}},"ins_contents":[{"Add":{"text":"use elpe_sched::{ResourceGrant, CLONE_INTO_CGROUP};","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2352"}}],"del_contents":[{"Del":{"text":"use elpe_sched::{CapPolicy, ResourceGrant, CLONE_INTO_CGROUP};","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:139581"}}]}},{"Replacement":{"inode":{"change":3,"pos":44692},"path":"src/container.rs","line":652,"ins":{"up_context":[{"change":7,"pos":153031}],"down_context":[{"change":7,"pos":153263}],"flag":"BLOCK","start":2354,"end":2631,"inode":{"change":3,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":153031},"to":{"change":7,"start":153031,"end":153263},"introduced_by":7}],"inode":{"change":3,"pos":44692}},"ins_contents":[{"Add":{"text":" // only the default policy (frontend-pushed override, else ELPE_DEFAULT_CORES)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2436"}},{"Add":{"text":" // decides whether to cap+pin; with none set this is a no-op and the build","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2515"}},{"Add":{"text":" // runs exactly as before.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2546"}},{"Add":{"text":" let grant = ResourceGrant::acquire(&name, &elpe_sched::default_policy(), None);","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2630"}}],"del_contents":[{"Del":{"text":" // only the default policy (ELPE_DEFAULT_CORES) decides whether to cap+pin;","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:153110"}},{"Del":{"text":" // with none set this is a no-op and the build runs exactly as before.","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:153185"}},{"Del":{"text":" let grant = ResourceGrant::acquire(&name, &CapPolicy::from_env(), None);","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:153262"}}]}},{"Replacement":{"inode":{"change":3,"pos":44692},"path":"src/container.rs","line":1348,"ins":{"up_context":[{"change":7,"pos":172281}],"down_context":[{"change":7,"pos":172370}],"flag":"BLOCK","start":2632,"end":2728,"inode":{"change":3,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":172281},"to":{"change":7,"start":172281,"end":172370},"introduced_by":7}],"inode":{"change":3,"pos":44692}},"ins_contents":[{"Add":{"text":" let grant = ResourceGrant::acquire(&cg_name, &elpe_sched::default_policy(), req.cpu_cores);","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2727"}}],"del_contents":[{"Del":{"text":" let grant = ResourceGrant::acquire(&cg_name, &CapPolicy::from_env(), req.cpu_cores);","pos":"AULXG4IEPL6RBH4A7SLHQXILHWWSWBJSSWDPOZXESKD7VBM3GOHQC:172369"}}]}},{"Edit":{"inode":{"change":5,"pos":34},"path":"src/server.rs","line":287,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":1544}],"down_context":[{"change":5,"pos":1651}],"flag":"BLOCK","start":2729,"end":3612,"inode":{"change":5,"pos":34}}},"contents":[{"Add":{"text":" async fn set_cap_policy(","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2757"}},{"Add":{"text":" &self,","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2772"}},{"Add":{"text":" request: tonic::Request,","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2833"}},{"Add":{"text":" ) -> Result, tonic::Status> {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2909"}},{"Add":{"text":" let policy = request.into_inner().policy.unwrap_or_default();","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:2979"}},{"Add":{"text":" let value = policy.value;","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3013"}},{"Add":{"text":" // FIXED/ADAPTIVE with a zero value is meaningless → treat as uncapped.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3095"}},{"Add":{"text":" let resolved = match policy.mode() {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3140"}},{"Add":{"text":" proto::CapMode::CapFixed if value > 0 => elpe_sched::CapPolicy::Fixed(value),","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3230"}},{"Add":{"text":" proto::CapMode::CapAdaptive if value > 0 => elpe_sched::CapPolicy::Adaptive {","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3320"}},{"Add":{"text":" yield_at_pct: value.min(100),","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3366"}},{"Add":{"text":" },","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3381"}},{"Add":{"text":" _ => elpe_sched::CapPolicy::Uncapped,","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3431"}},{"Add":{"text":" };","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3442"}},{"Add":{"text":" elpe_sched::set_default_policy(resolved);","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3492"}},{"Add":{"text":" debug!(\"set_cap_policy: {:?}\", resolved);","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3542"}},{"Add":{"text":" Ok(tonic::Response::new(proto::SetCapPolicyReply {}))","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3604"}},{"Add":{"text":" }","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3610"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3611"}}]}},{"Edit":{"inode":{"change":8,"pos":353955},"path":"elpe/lib/lock.ml","line":701,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":4770}],"down_context":[{"change":10,"pos":4770}],"flag":"BLOCK","start":3613,"end":5827,"inode":{"change":8,"pos":353955}}},"contents":[{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3613"}},{"Add":{"text":"(* --- Default CPU policy for undeclared actions (mirrors elpe-sched::CapPolicy).","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3695"}},{"Add":{"text":" The frontend can push a policy that overrides the backend's ELPE_DEFAULT_CORES","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3777"}},{"Add":{"text":" — the \"config that travels with the artifact\". *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3832"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3833"}},{"Add":{"text":"(** Default core policy for actions that declare no allocation. *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3900"}},{"Add":{"text":"type cap_policy =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3918"}},{"Add":{"text":" | Cap_uncapped (** run undeclared work uncapped (backend default) *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:3990"}},{"Add":{"text":" | Cap_fixed of int (** cap+pin every undeclared action to N cores *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4062"}},{"Add":{"text":" | Cap_adaptive of int","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4086"}},{"Add":{"text":" (** PSI back-pressure: hold undeclared work while CPU pressure (some avg10)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4168"}},{"Add":{"text":" is at/above N percent, so an interactive machine is never drowned *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4247"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4248"}},{"Add":{"text":"(** Parse the [ELPE_DEFAULT_CORES] grammar ([\"N\"] / [\"psi:N\"]) into a policy.","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4326"}},{"Add":{"text":" [None] on empty/unparseable, so an absent [-cores] flag pushes nothing and","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4405"}},{"Add":{"text":" the backend keeps its own default. *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4447"}},{"Add":{"text":"let cap_policy_of_spec (s : string) : cap_policy option =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4505"}},{"Add":{"text":" let s = String.trim s in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4532"}},{"Add":{"text":" if s = \"\" then None","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4554"}},{"Add":{"text":" else if String.length s > 4 && String.sub s 0 4 = \"psi:\" then","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4618"}},{"Add":{"text":" match int_of_string_opt (String.trim (String.sub s 4 (String.length s - 4))) with","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4704"}},{"Add":{"text":" | Some n when n > 0 -> Some (Cap_adaptive n)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4753"}},{"Add":{"text":" | _ -> None","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4769"}},{"Add":{"text":" else","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4776"}},{"Add":{"text":" match int_of_string_opt s with Some n when n > 0 -> Some (Cap_fixed n) | _ -> None","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4863"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4864"}},{"Add":{"text":"(** Push a default CPU policy to the backend so subsequent builds apply it. *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:4943"}},{"Add":{"text":"let push_cap_policy connection (p : cap_policy) : unit Lwt.t =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5006"}},{"Add":{"text":" let mode, value =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5026"}},{"Add":{"text":" match p with","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5043"}},{"Add":{"text":" | Cap_uncapped -> (Elpegrpc.Elpe.CapMode.CAP_UNCAPPED, 0)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5105"}},{"Add":{"text":" | Cap_fixed n -> (Elpegrpc.Elpe.CapMode.CAP_FIXED, n)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5163"}},{"Add":{"text":" | Cap_adaptive t -> (Elpegrpc.Elpe.CapMode.CAP_ADAPTIVE, t)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5227"}},{"Add":{"text":" in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5232"}},{"Add":{"text":" let policy = Elpegrpc.Elpe.CapPolicy.make ~mode ~value () in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5295"}},{"Add":{"text":" let req = Elpegrpc.Elpe.SetCapPolicyRequest.make ~policy () in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5360"}},{"Add":{"text":" let* res =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5373"}},{"Add":{"text":" grpc_call_unary connection ~rpc:\"SetCapPolicy\" Elpegrpc.Elpe.Elpe.setCapPolicy req","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5460"}},{"Add":{"text":" in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5465"}},{"Add":{"text":" let _ = Result.get_ok res in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5496"}},{"Add":{"text":" Lwt.return ()","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5512"}},{"Add":{"text":"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5513"}},{"Add":{"text":"(** Push [policy] on the global backend connection if one is set and a policy was","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5595"}},{"Add":{"text":" given. Called after connecting, before building. *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5652"}},{"Add":{"text":"let push_project_cap_policy (policy : cap_policy option) : unit Lwt.t =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5724"}},{"Add":{"text":" match (!backend_conn, policy) with","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5761"}},{"Add":{"text":" | Some c, Some p -> push_cap_policy c p","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5803"}},{"Add":{"text":" | _ -> Lwt.return ()","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5826"}}]}},{"Edit":{"inode":{"change":2,"pos":63278},"path":"elpe/bin/elpe_bin.ml","line":172,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":1453}],"down_context":[{"change":8,"pos":661542}],"flag":"BLOCK","start":5828,"end":6127,"inode":{"change":2,"pos":63278}}},"contents":[{"Add":{"text":" and cores =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5844"}},{"Add":{"text":" flag \"-cores\" (optional string)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5883"}},{"Add":{"text":" ~doc:","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5898"}},{"Add":{"text":" \"SPEC default CPU policy for actions that declare no cores: N \\","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:5973"}},{"Add":{"text":" (cap+pin to N cores) or psi:N (yield to interactive use while CPU \\","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6053"}},{"Add":{"text":" pressure >= N%); overrides the backend's ELPE_DEFAULT_CORES\"","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6126"}}]}},{"Edit":{"inode":{"change":2,"pos":63278},"path":"elpe/bin/elpe_bin.ml","line":190,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":6910}],"down_context":[{"change":4,"pos":1426}],"flag":"BLOCK","start":6128,"end":6460,"inode":{"change":2,"pos":63278}}},"contents":[{"Add":{"text":" (* Push the default CPU policy (if -cores was given) before building. *)","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6210"}},{"Add":{"text":" let* () =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6230"}},{"Add":{"text":" let policy =","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6255"}},{"Add":{"text":" match cores with","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6286"}},{"Add":{"text":" | None -> None","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6315"}},{"Add":{"text":" | Some spec -> Elpe.Lock.cap_policy_of_spec spec","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6378"}},{"Add":{"text":" in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6393"}},{"Add":{"text":" Elpe.Lock.push_project_cap_policy policy","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6446"}},{"Add":{"text":" in","pos":"KNTDFRHZJSR5SPTPUATZLZLYVPAMI35ME43P6V2TELVIQBH7IWKQC:6459"}}]}}],"owner":"pmeunier","repo":"elpe","token":"dnntarvgKR5V4usQsx3li03vp+1zQ0JSaBFm1OdCdrg=","login":null}

…

Dependencies

Change contents

Review