lab/distribution
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

tests: pin pooled-dispatch concurrency; sqlite pins follow THREADSAFE=1

Browse Source 
server_http gains the case that caught the live crash: 1000 keep-alive
requests at c=10 against /api/apps (full SQLite load per request, on
the 4-worker pool) must complete with 0 failures and leave the server
answering. sqlite_api's threadsafe pins flip to guard the NEW invariant
— a regression to THREADSAFE=0 reintroduces heap corruption under the
pool (free-of-unallocated inside yy_reduce, caught under ab -c20).
This commit is contained in:
agra
2026-06-12 22:46:12 +03:00
parent 74b41f5c83
commit c734f47952
2 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tests/server_http.sx
View File

@@ -206,6 +206,18 @@ main :: () -> i32 {
"two requests on one connection both answer"); "two requests on one connection both answer");
print(" keep-alive reuse ok\n"); print(" keep-alive reuse ok\n");
// ── concurrent load must not corrupt anything (PLAN-HTTPZ A2) ────
// distd handlers run on a 4-worker pool; /api/apps does a full
// SQLite load per request. 1000 keep-alive requests at c=10 caught
// the SQLITE_THREADSAFE=0 heap corruption live — this pins the
// threadsafe build and the pooled dispatch path end to end.
abr := process.run(concat(concat("ab -q -n 1000 -c 10 -k ", BASE), "/api/apps 2>/dev/null | grep -c 'Failed requests: 0'"));
process.assert(abr != null and abr!.exit_code == 0, "ab spawn failed (concurrency case)");
process.assert(contains(abr!.stdout, "1"), "1000 concurrent requests complete with 0 failures");
alive := process.run(concat(concat("curl -s -m 2 -o /dev/null -w '%{http_code}' ", BASE), "/healthz"));
process.assert(alive != null and alive!.stdout == "200", "server alive after concurrent load");
print(" pooled handlers: 1000 concurrent requests, 0 failures, server alive\n");
// ── freshness: publish B while the server runs ──────────────────── // ── freshness: publish B while the server runs ────────────────────
rb := process.run(publish_cmd(path_join(MDIR, "b.json"))); rb := process.run(publish_cmd(path_join(MDIR, "b.json")));
process.assert(rb != null and rb!.exit_code == 0, "publish B must exit 0"); process.assert(rb != null and rb!.exit_code == 0, "publish B must exit 0");

9
tests/sqlite_api.sx
View File

@@ -2,8 +2,9 @@
// every wrapper family beyond the P5.1 smoke (which keeps owning the // every wrapper family beyond the P5.1 smoke (which keeps owning the
// vendored-version pin): // vendored-version pin):
// //
// * library: version_number, sourceid, threadsafe=false (built // * library: version_number, sourceid, threadsafe=true (built
// THREADSAFE=0), compileoption_used, complete, errstr, strglob/ // THREADSAFE=1 since std.thread pools share the library),
// compileoption_used, complete, errstr, strglob/
// strlike/stricmp, randomness. // strlike/stricmp, randomness.
// * connections: open_v2 flag behavior (READONLY on a missing file // * connections: open_v2 flag behavior (READONLY on a missing file
// refuses; CREATE works; db_readonly reflects the mode), // refuses; CREATE works; db_readonly reflects the mode),
@@ -37,8 +38,8 @@ run_case :: (label: string, ok: bool) -> i32 {
check_library_info :: () -> bool { check_library_info :: () -> bool {
if sq.sqlite_version_number() < 3053000 { return false; } if sq.sqlite_version_number() < 3053000 { return false; }
if sq.sqlite_sourceid().len < 10 { return false; } if sq.sqlite_sourceid().len < 10 { return false; }
if sq.sqlite_threadsafe() { return false; } // THREADSAFE=0 build if !sq.sqlite_threadsafe() { return false; } // THREADSAFE=1: std.thread-era pools share the library (PLAN-HTTPZ A2)
if !sq.sqlite_compileoption_used("THREADSAFE=0") { return false; } if !sq.sqlite_compileoption_used("THREADSAFE=1") { return false; }
if sq.sqlite_compileoption_get(0).len == 0 { return false; } if sq.sqlite_compileoption_get(0).len == 0 { return false; }
return true; return true;
} }