aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJoseph Hunkeler <jhunkeler@gmail.com>2026-04-07 09:42:07 -0400
committerJoseph Hunkeler <jhunkeler@gmail.com>2026-04-07 09:42:07 -0400
commitf1ee2d8eeed62e948874e65989f3666178d9bc2f (patch)
tree1996188592a3876ca761ec2804c1431a9c9e2786
parent044a157a29e0e35652c4c7dd30b13cdd17d68b3f (diff)
downloadstasis-f1ee2d8eeed62e948874e65989f3666178d9bc2f.tar.gz
Debug: Only report hangcheck value on error.
* Too verbose
-rw-r--r--src/lib/core/multiprocessing.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/lib/core/multiprocessing.c b/src/lib/core/multiprocessing.c
index 298484a..7ae23c9 100644
--- a/src/lib/core/multiprocessing.c
+++ b/src/lib/core/multiprocessing.c
@@ -345,12 +345,12 @@ int mp_pool_join(struct MultiProcessingPool *pool, size_t jobs, size_t flags) {
if (slot->pid == MP_POOL_PID_UNUSED) {
// Child is already used up, skip it
hang_check++;
- SYSDEBUG("slot %zu: hang_check=%zu", i, hang_check);
if (hang_check >= pool->num_used) {
// If you join a pool that's already finished it will spin
// forever. This protects the program from entering an
// infinite loop.
- fprintf(stderr, "%s is deadlocked\n", pool->ident);
+ SYSDEBUG("slot %zu: hang_check=%zu >= pool->num_used=%zu", i, hang_check, pool->num_used);
+ SYSERROR("%s is deadlocked\n", pool->ident);
failures++;
goto pool_deadlocked;
}