![]() |
kinetic-c
v0.12.0
Seagate Kinetic Protocol Client Library for C
|
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <assert.h>
#include <err.h>
#include <poll.h>
#include <sys/time.h>
#include "threadpool.h"
Go to the source code of this file.
Macros | |
#define | ATOMIC_BOOL_COMPARE_AND_SWAP(PTR, OLD, NEW) (__sync_bool_compare_and_swap(PTR, OLD, NEW)) |
#define | SPIN_ADJ(F, ADJ) |
Functions | |
static void | dump_stats (const char *prefix, struct threadpool_info *stats, size_t ticks) |
static size_t | fibs (size_t arg) |
static void | task_cb (void *udata) |
int | main (int argc, char **argv) |
Variables | |
static size_t | task_count = 0 |
static size_t | last_count = 0 |
#define ATOMIC_BOOL_COMPARE_AND_SWAP | ( | PTR, | |
OLD, | |||
NEW | |||
) | (__sync_bool_compare_and_swap(PTR, OLD, NEW)) |
Definition at line 44 of file test_threadpool_stress.c.
#define SPIN_ADJ | ( | F, | |
ADJ | |||
) |
Definition at line 48 of file test_threadpool_stress.c.
|
static |
Definition at line 35 of file test_threadpool_stress.c.
References threadpool_info::active_threads, threadpool_info::backlog_size, threadpool_info::dormant_threads, last_count, and task_count.
|
static |
Definition at line 58 of file test_threadpool_stress.c.
|
static |
Definition at line 63 of file test_threadpool_stress.c.
References fibs(), SPIN_ADJ, and task_count.
int main | ( | int | argc, |
char ** | argv | ||
) |
Definition at line 70 of file test_threadpool_stress.c.
References dump_stats(), threadpool_config::max_threads, threadpool_task::task, task_cb(), threadpool_config::task_ringbuf_size2, Threadpool_Init(), Threadpool_Schedule(), and Threadpool_Stats().
|
static |
Definition at line 32 of file test_threadpool_stress.c.
|
static |
Definition at line 33 of file test_threadpool_stress.c.