impl(sprint-11/wave-D): D-CSV-7 MailboxSoA + D-CSV-6a WitnessCorpus core (parallel workers)

[AdaWorldAPI]

Summary

Sprint-11 Wave D — Phase B substrate primitives, two parallel Sonnet workers branched from main (PR #383 D-CSV-1 + D-CSV-4 already on main).

D-CSV-7 (W-D1) — MailboxSoA<N> core in cognitive-shader-driver

NEW crates/cognitive-shader-driver/src/mailbox_soa.rs (~431 LOC, source + 9 tests).

• pub struct MailboxSoA<const N: usize> with mailbox_id: MailboxId, per-row energy: [f32; N], plasticity_counter: [u8; N], last_emission_cycle: [u32; N], current_cycle: u32, w_slot: u8 (panics if ≥ 64 per L-6), threshold: f32
• apply_edges(batons) — baton receipt with W-slot filter (mismatched edges silently dropped); energy accumulated as mantissa/8.0 × confidence; plasticity_counter saturating-add
• emit(source) -> CollapseGateEmission — single-shot per cycle (last_emission_cycle guard); above-threshold rows produce batons via with_inference_mantissa(...).with_w_slot(...); emitted rows reset to 0
• tick() advances cycle; reset_row(row) clears one row; pending_count() + inspectors
• pub type DefaultMailboxSoA = MailboxSoA<1024>;

9 tests: zeros init, w_slot panic >63, accumulation, wrong-w-slot reject, out-of-range target reject, emit-above-thresh, emit-below-thresh-no-baton, double-emit-same-cycle-idempotent, tick-then-re-emit.

D-CSV-6a (W-D2) — WitnessCorpus core in lance-graph arigraph

NEW crates/lance-graph/src/graph/arigraph/witness_corpus.rs (~398 LOC, source + 8 tests).

• WitnessEntry { spo: u64, timestamp_ns: u64, source_url: Option<String>, evidence_blob: Bytes } with tie_break_hash() (DefaultHasher of source_url; None → 0) and ord_key() = (timestamp_ns, tie_break_hash)
• WitnessId(pub u64) opaque handle; CamPqIndexPlaceholder (D-CSV-6b replaces with real ndarray CAM-PQ wiring)
• WitnessCorpus { entries: Arc<Vec<WitnessEntry>>, cam_pq_index } — copy-on-write via Arc::make_mut
• insert(entry) -> WitnessId — binary-search position to maintain W5-INV-CHAIN-ORDER (timestamp_ns ASC + hash tie-break)
• query(spo) -> impl Iterator — linear scan placeholder; D-CSV-6b swaps for CAM-PQ-backed lookup
• iter(), len(), is_empty(), evict_stale_before(cutoff_ns) -> usize

8 tests: empty init, ord_key correctness, insert chain-order with reverse insertion, tie-break ordering, query SPO filter, unbounded 100-entry insert (W5-INV-WITNESS-UNBOUNDED), evict_stale_before threshold semantics, Arc CoW (clone shares; mutate splits).

crates/lance-graph/Cargo.toml adds bytes = "1" for WitnessEntry.evidence_blob.

Out of scope (follow-up PRs)

D-CSV-6b (next iteration): real CAM-PQ index integration via ndarray; cam_pq_search method; benches; WitnessCorpusStore 64-slot W-slot keyed array.

D-CSV-7 follow-ups: AttentionMask SoA / AttentionMaskActor (W6 §2-§3), ractor actor wrap (sprint-12 D-CSV-10), LRU eviction (sprint-12+), cross-cycle plasticity rollup (Zone 2; outside MailboxSoA scope per W6 §4.4).

Test plan

• CI: cargo test --manifest-path crates/cognitive-shader-driver/Cargo.toml mailbox_soa — 9 tests
• CI: cargo test -p lance-graph witness_corpus — 8 tests
• CI: clippy + fmt clean

Local validation blocked by the same env constraints documented in PR #385 (cognitive-shader-driver workspace members/exclude conflict; lance-graph protoc dep). Worker reports clean; CI is the authoritative validator.

Process note (for the next loop iteration's hygiene write-up)

Wave D's branch carried two parallel-worker outputs from background Sonnet agents that wrote files into the shared workspace while main thread was rebasing #384/#385 for the merged-#383 conflict. Stashing across branches recovered all worker output cleanly. Worth a hygiene-process EPIPHANY entry next loop (the parallel-worker + background-rebase + stash-dance pattern is now confirmed-working but fragile; the failure mode is silent worker-write-loss between stash points).

https://claude.ai/code/session_01UwJuKqP828qyX1VkLgGJFS

---

Generated by Claude Code

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: 19a650e5a0

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

Expose MailboxSoA from the crate

This new MailboxSoA implementation is never declared from crates/cognitive-shader-driver/src/lib.rs (I checked repo-wide for mailbox_soa/MailboxSoA, and only this file plus docs references exist), so Cargo will not compile it, export it, or run the unit tests in this file. As a result the D-CSV-7 surface added by this commit is unreachable to downstream users until the module is wired into the crate root.

Useful? React with 👍 / 👎.

[chatgpt-codex-connector]

Allow first-cycle emissions

On a freshly constructed mailbox, current_cycle is 0 and every last_emission_cycle[row] is also initialized to 0, so this guard suppresses all rows on the first call to emit() even when their energy is already above threshold. Any caller that accumulates batons and emits before calling tick() will get an empty emission and stale energy until the next cycle; initialize the stamps to a sentinel or special-case rows that have not emitted yet.

Useful? React with 👍 / 👎.