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: frames sized to the caller's payload bound, so serve starts (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:45:57 +01:00
commit ba1f7eb10b
1 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -574,20 +574,21 @@ mod tests {
let envelope = let envelope =
crate::envelope::encrypt_invocation(&invocation, &crate::fixtures::security(KEY)) crate::envelope::encrypt_invocation(&invocation, &crate::fixtures::security(KEY))
.unwrap(); .unwrap();
let TransportAdmission::Execute(claim) = service.begin(&envelope, now_ms(), FRAME).unwrap() let TransportAdmission::Execute(claim) =
service.begin(&envelope, now_ms(), 1 << 20).unwrap()
else { else {
panic!("a fresh request must execute"); panic!("a fresh request must execute");
}; };
service service
.complete( .complete(
*claim, *claim,
sized_result(&invocation, 80_000, "fixture-sse"), sized_result(&invocation, 150_000, "fixture-sse"),
FRAME, 1 << 20,
) )
.unwrap(); .unwrap();
drop(service); drop(service);
let narrow = 100_000; let narrow = 140_000;
let narrowed = ServeLimits { let narrowed = ServeLimits {
max_frame_bytes: narrow, max_frame_bytes: narrow,
..limits() ..limits()
@ -595,7 +596,7 @@ mod tests {
let listener = TcpListener::bind("127.0.0.1:0").unwrap(); let listener = TcpListener::bind("127.0.0.1:0").unwrap();
let endpoint = listener.local_addr().unwrap(); let endpoint = listener.local_addr().unwrap();
let path = store.path.clone(); let path = store.path.clone();
let backend = SizedBackend::new(80_000); let backend = SizedBackend::new(150_000);
let served = backend.clone(); let served = backend.clone();
thread::spawn(move || { thread::spawn(move || {
serve( serve(