GameCult/ModelConnector
Watch
9
0
Fork
You've already forked ModelConnector
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

serve wiring test: complete the wide record through the service, since serve holds the replay store (serve-frame-wiring-unpinned)

Browse source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-10-28 06:43:36 +01:00
commit 2dc8d070e0
1 changed files with 20 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

24
crates/model-connector/src/serve.rs
View file

@ -566,10 +566,26 @@ mod tests {
// record, which the narrow write then cannot carry.
let store = TestStore::new();
let invocation = fresh("request-narrowed");
let wide = SizedBackend::new(80_000);
let (client, _) = start_with(wide.clone(), &store, vec![caller(CALLER, KEY, 4)]);
let first = client.execute(&invocation).unwrap();
assert!(!failed_result_size(&first));
// The wide completion goes straight through the service: serve holds
// the replay store for as long as it runs, so a second serve cannot
// open it while the first lives.
let mut service =
TransportService::open(&store.path, vec![caller(CALLER, KEY, 4)], 300_000).unwrap();
let envelope =
crate::envelope::encrypt_invocation(&invocation, &crate::fixtures::security(KEY))
.unwrap();
let TransportAdmission::Execute(claim) = service.begin(&envelope, now_ms(), FRAME).unwrap()
else {
panic!("a fresh request must execute");
};
service
.complete(
*claim,
sized_result(&invocation, 80_000, "fixture-sse"),
FRAME,
)
.unwrap();
drop(service);
let narrow = 100_000;
let narrowed = ServeLimits {