diff options
| author | Joseph Hunkeler <jhunkeler@gmail.com> | 2024-09-26 09:58:57 -0400 |
|---|---|---|
| committer | Joseph Hunkeler <jhunkeler@gmail.com> | 2024-09-26 09:58:57 -0400 |
| commit | c645252886ce1ff63df9ebb252acca81ffa7b8bf (patch) | |
| tree | b9173a34ac239f3d452605a3ef5b9188f7f96dc4 | |
| parent | 25cb7df692786c0802dd67f5e32edf77fe344e5c (diff) | |
| download | stasis-c645252886ce1ff63df9ebb252acca81ffa7b8bf.tar.gz | |
Spacing
| -rw-r--r-- | src/multiprocessing.c | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/multiprocessing.c b/src/multiprocessing.c index 2b77059..3c3c5eb 100644 --- a/src/multiprocessing.c +++ b/src/multiprocessing.c @@ -246,6 +246,7 @@ int mp_pool_join(struct MultiProcessingPool *pool, size_t jobs, size_t flags) { size_t x = upper_i - pool->num_used; upper_i -= (size_t) x; } + for (size_t i = lower_i; i < upper_i; i++) { struct MultiProcessingTask *slot = &pool->task[i]; if (slot->status == -1) { |