(binary, work)
| 354 | |
| 355 | |
| 356 | def section_cold_storm(binary, work): |
| 357 | cache = os.path.join(work, "cache-storm") |
| 358 | os.makedirs(cache, exist_ok=True) |
| 359 | results = _parallel_one_shots(binary, cache, 6) |
| 360 | for index, result in enumerate(results): |
| 361 | if result is None or result.returncode != 0: |
| 362 | print("RED: cold-storm client %d failed (racing daemon spawn):\n%s" |
| 363 | % (index, out_text(result)[:300] if result else "(no result)")) |
| 364 | return False |
| 365 | if not wait_status_not_running(binary, cache, 90): |
| 366 | print("RED: the ephemeral daemon shared by the cold storm never retired") |
| 367 | return False |
| 368 | print("PASS: 6 racing cold clients all succeeded and the shared ephemeral daemon retired") |
| 369 | return True |
| 370 | |
| 371 | |
| 372 | def main(): |
nothing calls this directly
no test coverage detected