ARGOBOTS  36a41b57298ad4e16b5ada8c95c81f00dfed4d3c
Macros | Typedefs | Functions
randws.c File Reference
#include "abti.h"
#include "thread_queue.h"
#include <time.h>
Include dependency graph for randws.c:

Go to the source code of this file.

Macros

#define POOL_CONTEXT_PUSH_HEAD
 
#define POOL_CONTEXT_POP_TAIL   (ABT_POOL_CONTEXT_OWNER_SECONDARY)
 

Typedefs

typedef struct data data_t
 

Functions

static int pool_init (ABT_pool pool, ABT_pool_config config)
 
static void pool_free (ABT_pool pool)
 
static ABT_bool pool_is_empty (ABT_pool pool)
 
static size_t pool_get_size (ABT_pool pool)
 
static void pool_push_shared (ABT_pool pool, ABT_unit unit, ABT_pool_context context)
 
static void pool_push_private (ABT_pool pool, ABT_unit unit, ABT_pool_context context)
 
static ABT_thread pool_pop_shared (ABT_pool pool, ABT_pool_context context)
 
static ABT_thread pool_pop_private (ABT_pool pool, ABT_pool_context context)
 
static ABT_thread pool_pop_wait (ABT_pool pool, double time_secs, ABT_pool_context context)
 
static void pool_push_many_shared (ABT_pool pool, const ABT_unit *units, size_t num_units, ABT_pool_context context)
 
static void pool_push_many_private (ABT_pool pool, const ABT_unit *units, size_t num_units, ABT_pool_context context)
 
static void pool_pop_many_shared (ABT_pool pool, ABT_thread *threads, size_t max_threads, size_t *num_popped, ABT_pool_context context)
 
static void pool_pop_many_private (ABT_pool pool, ABT_thread *threads, size_t max_threads, size_t *num_popped, ABT_pool_context context)
 
static void pool_print_all (ABT_pool pool, void *arg, void(*print_fn)(void *, ABT_thread))
 
static ABT_unit pool_create_unit (ABT_pool pool, ABT_thread thread)
 
static void pool_free_unit (ABT_pool pool, ABT_unit unit)
 
static int pool_remove_shared (ABT_pool pool, ABT_unit unit)
 
static int pool_remove_private (ABT_pool pool, ABT_unit unit)
 
static ABT_unit pool_pop_timedwait (ABT_pool pool, double abstime_secs)
 
static ABT_bool pool_unit_is_in_pool (ABT_unit unit)
 
static data_tpool_get_data_ptr (void *p_data)
 

Macro Definition Documentation

◆ POOL_CONTEXT_POP_TAIL

#define POOL_CONTEXT_POP_TAIL   (ABT_POOL_CONTEXT_OWNER_SECONDARY)

Definition at line 49 of file randws.c.

◆ POOL_CONTEXT_PUSH_HEAD

#define POOL_CONTEXT_PUSH_HEAD
Value:
ABT_POOL_CONTEXT_OP_THREAD_CREATE_TO | \
ABT_POOL_CONTEXT_OP_THREAD_REVIVE | ABT_POOL_CONTEXT_OP_THREAD_REVIVE_TO)

Definition at line 45 of file randws.c.

Typedef Documentation

◆ data_t

typedef struct data data_t

Definition at line 55 of file randws.c.

Function Documentation

◆ pool_create_unit()

static ABT_unit pool_create_unit ( ABT_pool  pool,
ABT_thread  thread 
)
static

Definition at line 403 of file randws.c.

◆ pool_free()

static void pool_free ( ABT_pool  pool)
static

Definition at line 134 of file randws.c.

◆ pool_free_unit()

static void pool_free_unit ( ABT_pool  pool,
ABT_unit  unit 
)
static

Definition at line 410 of file randws.c.

◆ pool_get_data_ptr()

static data_t* pool_get_data_ptr ( void *  p_data)
inlinestatic

Definition at line 57 of file randws.c.

◆ pool_get_size()

static size_t pool_get_size ( ABT_pool  pool)
static

Definition at line 149 of file randws.c.

◆ pool_init()

static int pool_init ( ABT_pool  pool,
ABT_pool_config  config 
)
static

Definition at line 112 of file randws.c.

◆ pool_is_empty()

static ABT_bool pool_is_empty ( ABT_pool  pool)
static

Definition at line 142 of file randws.c.

◆ pool_pop_many_private()

static void pool_pop_many_private ( ABT_pool  pool,
ABT_thread threads,
size_t  max_threads,
size_t *  num_popped,
ABT_pool_context  context 
)
static

Definition at line 337 of file randws.c.

◆ pool_pop_many_shared()

static void pool_pop_many_shared ( ABT_pool  pool,
ABT_thread threads,
size_t  max_threads,
size_t *  num_popped,
ABT_pool_context  context 
)
static

Definition at line 309 of file randws.c.

◆ pool_pop_private()

static ABT_thread pool_pop_private ( ABT_pool  pool,
ABT_pool_context  context 
)
static

Definition at line 296 of file randws.c.

◆ pool_pop_shared()

static ABT_thread pool_pop_shared ( ABT_pool  pool,
ABT_pool_context  context 
)
static

Definition at line 277 of file randws.c.

◆ pool_pop_timedwait()

static ABT_unit pool_pop_timedwait ( ABT_pool  pool,
double  abstime_secs 
)
static

Definition at line 255 of file randws.c.

◆ pool_pop_wait()

static ABT_thread pool_pop_wait ( ABT_pool  pool,
double  time_secs,
ABT_pool_context  context 
)
static

Definition at line 222 of file randws.c.

◆ pool_print_all()

static void pool_print_all ( ABT_pool  pool,
void *  arg,
void(*)(void *, ABT_thread print_fn 
)
static

Definition at line 377 of file randws.c.

◆ pool_push_many_private()

static void pool_push_many_private ( ABT_pool  pool,
const ABT_unit units,
size_t  num_units,
ABT_pool_context  context 
)
static

Definition at line 205 of file randws.c.

◆ pool_push_many_shared()

static void pool_push_many_shared ( ABT_pool  pool,
const ABT_unit units,
size_t  num_units,
ABT_pool_context  context 
)
static

Definition at line 184 of file randws.c.

◆ pool_push_private()

static void pool_push_private ( ABT_pool  pool,
ABT_unit  unit,
ABT_pool_context  context 
)
static

Definition at line 171 of file randws.c.

◆ pool_push_shared()

static void pool_push_shared ( ABT_pool  pool,
ABT_unit  unit,
ABT_pool_context  context 
)
static

Definition at line 156 of file randws.c.

◆ pool_remove_private()

static int pool_remove_private ( ABT_pool  pool,
ABT_unit  unit 
)
static

Definition at line 369 of file randws.c.

◆ pool_remove_shared()

static int pool_remove_shared ( ABT_pool  pool,
ABT_unit  unit 
)
static

Definition at line 358 of file randws.c.

◆ pool_unit_is_in_pool()

static ABT_bool pool_unit_is_in_pool ( ABT_unit  unit)
static

Definition at line 396 of file randws.c.

ABT_POOL_CONTEXT_OP_THREAD_CREATE
#define ABT_POOL_CONTEXT_OP_THREAD_CREATE
A flag that hints a push operation in a thread creation routine without a yield operation.
Definition: abt.h:1673
ABT_POOL_CONTEXT_OP_THREAD_REVIVE_TO
#define ABT_POOL_CONTEXT_OP_THREAD_REVIVE_TO
A flag that hints a push operation in a thread revival routine with a yield operation.
Definition: abt.h:1711