diff options
| author | Joseph Hunkeler <jhunkeler@gmail.com> | 2025-11-03 08:24:53 -0500 |
|---|---|---|
| committer | Joseph Hunkeler <jhunkeler@gmail.com> | 2025-11-14 10:30:57 -0500 |
| commit | 0771a8593fea16e089c50f2ce853423b1450da7c (patch) | |
| tree | be8f6c0790c21eff9c5379b009fea7d77ea47f93 | |
| parent | 0230268fb96f100e6747206364fdae35c451f7cf (diff) | |
| download | stasis-0771a8593fea16e089c50f2ce853423b1450da7c.tar.gz | |
Integrate semaphore
| -rw-r--r-- | src/lib/core/multiprocessing.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/lib/core/multiprocessing.c b/src/lib/core/multiprocessing.c index 74eb95e..b475111 100644 --- a/src/lib/core/multiprocessing.c +++ b/src/lib/core/multiprocessing.c @@ -448,7 +448,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; |