diff options
Diffstat (limited to 'src/threadpool.c')
| -rw-r--r-- | src/threadpool.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/threadpool.c b/src/threadpool.c index bd52c75..681428e 100644 --- a/src/threadpool.c +++ b/src/threadpool.c | |||
| @@ -369,8 +369,10 @@ static int __CTQ_CONSUMER(void *ctq) { | |||
| 369 | task_free(ctask); | 369 | task_free(ctask); |
| 370 | } | 370 | } |
| 371 | 371 | ||
| 372 | thrd_exit(1); // non-zero indicates error, -1 indicates invalid argument | 372 | thrd_exit(1); |
| 373 | } | 373 | } |
| 374 | // TODO: Make this function return 0 or -1 depending on whether the overall ctq has been canceled or not. Canceling shouldn't | ||
| 375 | // be treated as an error | ||
| 374 | 376 | ||
| 375 | int ctqueue_start(ctqueue *ctq) { | 377 | int ctqueue_start(ctqueue *ctq) { |
| 376 | if(!ctq) ERRRET(EINVAL, -1); | 378 | if(!ctq) ERRRET(EINVAL, -1); |
