diff options
| author | Joseph Hunkeler <jhunkeler@gmail.com> | 2024-10-02 15:00:57 -0400 |
|---|---|---|
| committer | Joseph Hunkeler <jhunkeler@gmail.com> | 2024-10-02 15:00:57 -0400 |
| commit | b041e8216c05940f5b3676ef5c7e0ce2b4441bc8 (patch) | |
| tree | 55b6d4e8caa96e502e518fe465f418127f38d8f3 | |
| parent | 6fe8c2572fbf73cee3936ab241fcbfbdd54fe633 (diff) | |
| download | stasis-b041e8216c05940f5b3676ef5c7e0ce2b4441bc8.tar.gz | |
"Task started" is more accurate than "queued" when this is printed
| -rw-r--r-- | src/multiprocessing.c | 4 | ||||
| -rw-r--r-- | src/stasis_main.c | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/multiprocessing.c b/src/multiprocessing.c index baa6df7..2a1b350 100644 --- a/src/multiprocessing.c +++ b/src/multiprocessing.c @@ -1,6 +1,6 @@ #include "core.h" -/// The sum of all tasks queued by mp_task() +/// The sum of all tasks started by mp_task() size_t mp_global_task_count = 0; static struct MultiProcessingTask *mp_pool_next_available(struct MultiProcessingPool *pool) { @@ -59,7 +59,7 @@ int child(struct MultiProcessingPool *pool, struct MultiProcessingTask *task) { } int parent(struct MultiProcessingPool *pool, struct MultiProcessingTask *task, pid_t pid, int *child_status) { - printf("[%s:%s] Task queued (pid: %d)\n", pool->ident, task->ident, pid); + printf("[%s:%s] Task started (pid: %d)\n", pool->ident, task->ident, pid); // Give the child process access to our PID value task->pid = pid; diff --git a/src/stasis_main.c b/src/stasis_main.c index 2fcfcaf..47579a9 100644 --- a/src/stasis_main.c +++ b/src/stasis_main.c @@ -12,7 +12,7 @@ #define OPT_NO_TESTING 1004 #define OPT_OVERWRITE 1005 #define OPT_NO_REWRITE_SPEC_STAGE_2 1006 -#define OPT_PARALLEL_FAIL_FAST 1007 +#define OPT_FAIL_FAST 1007 #define OPT_NO_PARALLEL 1008 #define OPT_POOL_STATUS_INTERVAL 1009 |