ex_thread_pool_wait.c

Go to the documentation of this file.

/*
 * Nilorea Library
 * Copyright (C) 2005-2026 Castagnier Mickael
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * SPDX-License-Identifier: Apache-2.0
 */

#include "nilorea/n_common.h"
#include "nilorea/n_log.h"
#include "nilorea/n_thread_pool.h"
 
#include <stdio.h>
#include <unistd.h>
 
static void* slow_proc(void* p) {
    (void)p;
    usleep(1500000); /* 1.5 s, as a real audit request against a remote host */
    return NULL;
}
 
int main(void) {
    set_log_level(LOG_ERR);
    /* one active thread, no waiting slots: exactly what the scanner builds for a
       single-endpoint audit (new_thread_pool(nthr, 0) with nthr == 1) */
    THREAD_POOL* pool = new_thread_pool(1, 0);
    if (!pool) {
        printf("FAIL: no pool\n");
        return 1;
    }
    if (add_threaded_process(pool, &slow_proc, NULL, NORMAL_PROC) == FALSE) {
        printf("FAIL: could not add proc\n");
        return 1;
    }
    wait_for_threaded_pool(pool); /* hung here before the fix */
    destroy_threaded_pool(&pool, 1000);
    printf("ex_thread_pool_wait: all checks passed\n");
    return 0;
}