From da767360027270223ab58e7b376ba4affd2648b2 Mon Sep 17 00:00:00 2001 From: Joseph Hunkeler Date: Mon, 3 Nov 2025 08:24:53 -0500 Subject: Integrate semaphore --- src/lib/core/multiprocessing.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'src') diff --git a/src/lib/core/multiprocessing.c b/src/lib/core/multiprocessing.c index a3c341f..597f0e3 100644 --- a/src/lib/core/multiprocessing.c +++ b/src/lib/core/multiprocessing.c @@ -447,7 +447,9 @@ struct MultiProcessingPool *mp_pool_init(const char *ident, const char *log_root return NULL; } - if (semaphore_init(&pool->semaphore, "stasis_pool_lock", 2) != 0) { + char semaphore_name[255] = {0}; + snprintf(semaphore_name, sizeof(semaphore_name), "stasis_mp_semaphore_%s", ident); + if (semaphore_init(&pool->semaphore, semaphore_name, 2) != 0) { fprintf(stderr, "unable to initialize semaphore\n"); mp_pool_free(&pool); return NULL; -- cgit