mw_procs: the victim of a kill is killed after it has inserted, not after a fixed time

[marcobambini]

Il problema

Su main (run 38150066532, tentativo 2) il job linux-arm64 build + test è fallito su mw_procs:

rebase 1: one process killed after 0 of 1000000 inserts; the others 4800 of 4800; a new one 50 of 50; integrity ok
rebase 1: the killed process had -1 inserts acknowledged and 0 rows are there
FAIL test/mw_procs.c:126: killed > 0 && killed < 1000000

Il test uccide un processo 400 ms dopo averlo avviato (fase 2) e tutti e quattro dopo 600 ms (fase 3). Su un runner lento il processo non aveva ancora inserito nulla: i dati erano integri, non reggeva solo il tempo.

Correzione

wait_acked(path, id, n, limit_ms) attende che il processo abbia confermato almeno n inserimenti (un byte nel suo file .ack per ciascuno; limite 60 s) e solo dopo lo uccide:

fase	prima	dopo
2: un processo ucciso	pause_ms(400)	200 inserimenti confermati
3: tutti e quattro uccisi	pause_ms(600)	100 inserimenti confermati ciascuno

La dimensione del file è letta da un handle aperto (open + lseek), non con stat(): su Windows la dimensione di un file che un altro processo tiene aperto risulta in ritardo. I controlli finali sono invariati (nessuna riga confermata persa, al più una in più, database integro).

Verifica

• Riproduzione del fallimento: con i figli avviati 700 ms in ritardo, il test vecchio fallisce come in CI (killed after 0 of 1000000 inserts, FAIL ... killed > 0) in entrambi i giri; quello nuovo passa (uccide dopo 258 e 201 inserimenti).
• Esecuzione normale: passa (macOS arm64); la kill avviene dopo ~240 inserimenti.
• Sotto carico: 72 esecuzioni a 24 in parallelo e 128 a 64 in parallelo senza fallimenti.

Da sapere

• Non provato su Windows e Linux: la CI è la prova. La parte Windows usa open/lseek/close, già disponibili nel test per .ack e unlink.
• Solo test: nessuna modifica al motore.
• Resta fuori mw_syncwindow (fallito nella stessa run al tentativo 1): è un altro test temporizzato (mw_mp=1, ritardi di 15 e 30 ms) e non l'ho riprodotto né prima né dopo, quindi non lo tocco qui.

🤖 Generated with Claude Code