qvm: compose stateful scoreboard broadcasts

docs/FINDINGS.md

@@ -1424,3 +1424,6 @@ RE-791–800 adds exact Rust source-sort/ranking parity, mixed count/prefix sema
 
 
 **RE-808:** Rust matches exact modeled scoreboard bytes, accepted/attempted counts, rejected-row cache mutations and output-ring wrap for18 source compositions. [Evidence](research/RUST_SCOREBOARD_PACKET.md).
+
+
+**RE-809:** 6328 now composes actual scoreboard bodies for successive recipients, preserving cache mutations, refreshed frame arguments and alternating output pointers. [Evidence](research/QVM_SCOREBOARD_STREAM.md).

docs/PROVISIONAL_TODO.md

@@ -1431,3 +1431,6 @@ RE-807: Rust reproduces every attempted source scoreboard row and cache update w
 
 
 RE-808: Rust matches exact modeled scoreboard bytes, accepted/attempted counts, rejected-row cache mutations and output-ring wrap for18 source compositions. Full runtime completion remains open. [Evidence](research/RUST_SCOREBOARD_PACKET.md).
+
+
+RE-809: 6328 now composes actual scoreboard bodies for successive recipients, preserving cache mutations, refreshed frame arguments and alternating output pointers. Full runtime completion remains open. [Evidence](research/QVM_SCOREBOARD_STREAM.md).

docs/RESEARCH_LEDGER.md

@@ -1706,3 +1706,8 @@ Rust reproduces every attempted source scoreboard row and cache update while pre
 ## 2026-10-26 — RE-808 Rust scoreboard packet admission cache and ring-buffer policy
 
 Rust matches exact modeled scoreboard bytes, accepted/attempted counts, rejected-row cache mutations and output-ring wrap for18 source compositions. Focused `cargo xtask test-group rust-scoreboard-packet` passes (9 Python tests); selected reports regenerate twice deterministically, with storage, documentation links and whitespace guards. Full suite deferred to task ten. Original assets unchanged; source fixtures do not establish complete native/runtime parity.
+
+
+## 2026-10-26 — RE-809 Source scoreboard broadcast with shared packet and cache state
+
+6328 now composes actual scoreboard bodies for successive recipients, preserving cache mutations, refreshed frame arguments and alternating output pointers. Focused `cargo xtask test-group scoreboard-stream` passes (5 Python tests); selected reports regenerate twice deterministically, with storage, documentation links and whitespace guards. Full suite deferred to task ten. Original assets unchanged; source fixtures do not establish complete native/runtime parity.

docs/REVERSE_ENGINEERING_TODO.md

@@ -1474,3 +1474,6 @@ Purpose: turn the supplied installation into an evidence-backed specification of
 
 
 - [x] RE-808 Rust scoreboard packet admission cache and ring-buffer policy ([evidence](research/RUST_SCOREBOARD_PACKET.md)).
+
+
+- [x] RE-809 Source scoreboard broadcast with shared packet and cache state ([evidence](research/QVM_SCOREBOARD_STREAM.md)).

docs/research/QVM_SCOREBOARD_STREAM.md

@@ -0,0 +1,7 @@
+# Source scoreboard broadcast with shared packet and cache state
+
+RE-809. Reproduce with `python3 scripts/analyze_qvm_scoreboard_stream.py`; focused validation: `cargo xtask test-group scoreboard-stream`. [Machine report](qvm-scoreboard-stream.json).
+
+Ten finite populations with zero..32 clients and at most two connected recipients exercise repeated bodies in original scan order. An independent sequential model carries cache state and ring wrap between packets, checks every C string and confirms capacity-prefix effects. Existing captured-body defaults remain available. Native format/copy/send behavior and exit-rule7805 effects remain explicit limits.
+
+Original executable/native runtime and complete Linux/macOS Rust/Bevy/Solari acceptance remain unverified.

docs/research/README.md

@@ -1014,3 +1014,6 @@ The extension collector adds five focused tests for native tail calls, command-r
 
 
 [RE-808: Rust scoreboard packet admission cache and ring-buffer policy](RUST_SCOREBOARD_PACKET.md).
+
+
+[RE-809: Source scoreboard broadcast with shared packet and cache state](QVM_SCOREBOARD_STREAM.md).

scripts/analyze_qvm_scoreboard_stream.py

@@ -0,0 +1,20 @@
+#!/usr/bin/env python3
+import itertools
+from pathlib import Path
+from qvm_research_support import source
+from qvm_scoreboard_body_support import seed,CPOOL,S,POOL
+from qvm_scoreboard_wire_support import wire
+from qvm_scoreboard_broadcast_support import broadcast
+from qvm_string_memory_support import frame_args
+from analyze_qvm import write_json
+
+def main():
+    q,raw,h,ins=source();rows=[]
+    for n,ring in itertools.product([0,1,3,8,32],[0,0xffffffff]):
+        clients=[{'468':2 if j in [0,n-1] else 1,'452':50+j,'6160':100+j,'4324':j%2,'12':1024 if j%2 else 0,'name_hex':([b'A',b'AB',b'long %s name',bytes([255,254])][j%4]).hex(),'696':21-j,'flags':8 if j%3==0 else 0} for j in range(n)];order=list(reversed(range(n)));m,b=seed(clients,order);m.update({34992524:n,23708:ring});packets=[]
+        def body(i,m,a,bs):
+            m,bs=frame_args(m,bs,{S+2588:a[8]});before=[m[CPOOL+6336*j+6160]&0xffffffff for j in range(n)];m,p=wire(i,m,bs,raw,h);p.update(cache_before=before,cache_after=[m[CPOOL+6336*j+6160]&0xffffffff for j in range(n)]);packets.append(p)
+            send=p['sends'][0];data=bytes.fromhex(send['cstring_hex']);return m,0,{'child_memory_bytes':{send['pointer']+j:v for j,v in enumerate(data)},'scoreboard_body_executed':True,'body_trace_sha256':p['execution']['trace_sha256']}
+        m,_,e=broadcast(ins,m,{},body_resolver=body,byte_inputs=b);rows.append({'clients':clients,'order':order,'now':121000,'scores':[2,1],'ring_before':ring,'ring_after':m[23708]&0xffffffff,'packets':packets,'final_cache':[m[CPOOL+6336*j+6160]&0xffffffff for j in range(n)],'broadcast_trace_sha256':e['execution']['trace_sha256']})
+    write_json(Path('docs/research/qvm-scoreboard-stream.json'),{'source':q['source'],'sha256':q['sha256'],'probes':rows,'limits':'Actual6328 executes actual179363/string/format wrappers for each selected state2 recipient with shared caches/ring across10 finite populations.37914/native strncpy modeled and send captured. At most two recipients per case bounds focused execution cost; large population admission includes rejected candidates.7805 effects and full ranking caller/native wire acceptance remain open.'})
+if __name__=='__main__':main()

scripts/qvm_scoreboard_broadcast_support.py

@@ -4,8 +4,8 @@ from qvm_notification_support import CPOOL,POOL
 from qvm_trace_support import resume,captured
 B=H+0x170000
 
-def broadcast(ins,m,args):
+def broadcast(ins,m,args,body_resolver=None,byte_inputs=None):
     if not -1<=m[34992524]<=64:raise ValueError('unsupported scoreboard broadcast count')
-    before=dict(m);requests=[];m,e=resume(ins,6329,6367,m,B,handlers={179363:captured(179363,requests)},repeated_calls=True,sync_child_words=True)
+    before=dict(m);requests=[];m,e=resume(ins,6329,6367,m,B,handlers={179363:body_resolver or captured(179363,requests)},repeated_calls=True,sync_child_words=True,byte_inputs=byte_inputs,coherent_memory=body_resolver is not None,byte_handlers=body_resolver is not None)
     writes=[{'address':a,'before':before.get(a),'after':v} for a,v in sorted(m.items()) if before.get(a)!=v and not B<=a<B+32]
     return m,0,{'requests':requests,'external_writes':writes,'execution':e}

scripts/test_qvm_scoreboard_stream.py

@@ -0,0 +1,22 @@
+import json,unittest
+from pathlib import Path
+from test_qvm_scoreboard_rows import project
+from analyze_qvm_recipient_wire import copy_model
+class ScoreboardStreamTests(unittest.TestCase):
+    def test_stateful_recipient_order_payloads_cache_and_ring(self):
+        ps=json.loads(Path('docs/research/qvm-scoreboard-stream.json').read_text())['probes'];self.assertEqual(len(ps),10)
+        for p in ps:
+            recipients=[j for j,c in enumerate(p['clients']) if c['468']==2];self.assertEqual([s['sends'][0]['recipient'] for s in p['packets']],recipients);cache=[c['6160'] for c in p['clients']];ring=p['ring_before']
+            for packet in p['packets']:
+                self.assertEqual(packet['cache_before'],cache);payload=b'';accepted=0
+                for id in p['order']:
+                    c={**p['clients'][id],'6160':cache[id]};cache[id],nums=project(c,id,p['now']);name=copy_model(bytes.fromhex(c['name_hex'])).split(b'\0')[0];row=b''.join(b' '+str(v).encode() for v in nums)+b' '+name
+                    if len(payload)+len(row)>1024:break
+                    payload+=row;accepted+=1
+                self.assertEqual(packet['cache_after'],cache);self.assertEqual(packet['sends'][0]['cstring_hex'],(f'scores {accepted} 2 1'.encode()+payload+b'\0').hex());self.assertEqual(packet['sends'][0]['pointer'],35032232+(ring&1)*32000);ring=(ring+1)&0xffffffff;self.assertEqual(packet['ring_counter'],ring)
+            self.assertEqual(p['ring_after'],ring);self.assertEqual(p['final_cache'],cache)
+    def test_scratch_arguments_and_output_pointers_refresh_per_recipient(self):
+        ps=json.loads(Path('docs/research/qvm-scoreboard-stream.json').read_text())['probes'];self.assertTrue(any(len(p['packets'])==2 for p in ps))
+        for p in ps:
+            if len(p['packets'])==2:self.assertNotEqual(p['packets'][0]['sends'][0]['pointer'],p['packets'][1]['sends'][0]['pointer'])
+if __name__=='__main__':unittest.main()

xtask/checks.tsv

@@ -1944,3 +1944,7 @@ report	scripts/analyze_rust_scoreboard_packet.py	docs/research/rust-scoreboard-p
 edge	docs/research/rust-scoreboard-packet.json	scripts/test_rust_scoreboard_packet.py
 group	rust-scoreboard-packet	scripts/analyze_rust_scoreboard_packet.py
 edge	scripts/analyze_rust_scoreboard_packet.py	scripts/analyze_qvm_resumer_audit.py
+report	scripts/analyze_qvm_scoreboard_stream.py	docs/research/qvm-scoreboard-stream.json
+edge	docs/research/qvm-scoreboard-stream.json	scripts/test_qvm_scoreboard_stream.py
+group	scoreboard-stream	scripts/analyze_qvm_scoreboard_stream.py
+edge	scripts/analyze_qvm_scoreboard_stream.py	scripts/analyze_qvm_resumer_audit.py