diff options
| author | Joseph Hunkeler <jhunkeler@gmail.com> | 2024-09-17 09:38:18 -0400 |
|---|---|---|
| committer | Joseph Hunkeler <jhunkeler@gmail.com> | 2024-09-18 23:08:03 -0400 |
| commit | 16597bc90b810d3457296d99bd36510321a37f24 (patch) | |
| tree | a14f5fb8bc6bf8e32dffc69599f6f083c88c11d9 | |
| parent | db1a3056296ea3ed13c5a425cf1f11602b43a6c7 (diff) | |
| download | stasis-16597bc90b810d3457296d99bd36510321a37f24.tar.gz | |
Implement mp_pool_show_summary
| -rw-r--r-- | src/delivery.c | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/src/delivery.c b/src/delivery.c index 7759c3e..c31a4dd 100644 --- a/src/delivery.c +++ b/src/delivery.c @@ -1894,18 +1894,25 @@ void delivery_tests_run(struct Delivery *ctx) { opt_flags |= MP_POOL_FAIL_FAST; } + int pool_status = -1; if (pool_setup->num_used) { - COE_CHECK_ABORT(mp_pool_join(pool_setup, 1, opt_flags) != 0, "Failure in setup task pool"); + pool_status = mp_pool_join(pool_setup, 1, opt_flags); + mp_pool_show_summary(pool_setup); + COE_CHECK_ABORT(pool_status != 0, "Failure in setup task pool"); mp_pool_free(&pool_setup); } if (pool_parallel->num_used) { - COE_CHECK_ABORT(mp_pool_join(pool_parallel, globals.cpu_limit, opt_flags) != 0, "Failure in parallel task pool"); + pool_status = mp_pool_join(pool_parallel, globals.cpu_limit, opt_flags); + mp_pool_show_summary(pool_parallel); + COE_CHECK_ABORT(pool_status != 0, "Failure in parallel task pool"); mp_pool_free(&pool_parallel); } if (pool_serial->num_used) { - COE_CHECK_ABORT(mp_pool_join(pool_serial, 1, opt_flags) != 0, "Failure in serial task pool"); + pool_status = mp_pool_join(pool_serial, 1, opt_flags); + mp_pool_show_summary(pool_serial); + COE_CHECK_ABORT(pool_serial != 0, "Failure in serial task pool"); mp_pool_free(&pool_serial); } } |