#include "abti.h"

Include dependency graph for pool.c:

Data Structures
struct	pool_print_thread_to_unit_arg_t

struct	pool_print_unit_to_thread_arg_t

Functions
static ABTU_ret_err int	pool_create (ABT_pool_access access, const ABTI_pool_required_def p_required_def, const ABTI_pool_optional_def p_optional_def, const ABTI_pool_deprecated_def p_deprecated_def, const ABTI_pool_old_def p_old_def, ABTI_pool_config p_config, ABT_bool def_automatic, ABT_bool is_builtin, ABTI_pool *pp_newpool)

static void	pool_create_def_from_old_def (const ABT_pool_def p_def, ABTI_pool_old_def p_old_def, ABTI_pool_required_def p_required_def, ABTI_pool_optional_def p_optional_def, ABTI_pool_deprecated_def *p_deprecated_def)

static int	pool_pop_thread_ex (ABT_pool pool, ABT_thread *thread, ABT_pool_context pool_ctx)

static int	pool_pop_threads_ex (ABT_pool pool, ABT_thread threads, size_t len, size_t num, ABT_pool_context pool_ctx)

static int	pool_push_thread_ex (ABT_pool pool, ABT_thread thread, ABT_pool_context pool_ctx)

static int	pool_push_threads_ex (ABT_pool pool, const ABT_thread *threads, size_t num, ABT_pool_context pool_ctx)

static int	pool_pop_wait_thread_ex (ABT_pool pool, ABT_thread *thread, double time_secs, ABT_pool_context pool_ctx)

static void	pool_print_thread_to_unit (void *arg, ABT_thread thread)

static void	pool_print_unit_to_thread (void *arg, ABT_unit unit)

int	ABT_pool_create (ABT_pool_user_def def, ABT_pool_config config, ABT_pool *newpool)
	Create a new pool. More...

int	ABT_pool_create_basic (ABT_pool_kind kind, ABT_pool_access access, ABT_bool automatic, ABT_pool *newpool)
	Create a new pool from a predefined type. More...

int	ABT_pool_free (ABT_pool *pool)
	Free a pool. More...

int	ABT_pool_get_access (ABT_pool pool, ABT_pool_access *access)
	Get an access type of a pool. More...

int	ABT_pool_is_empty (ABT_pool pool, ABT_bool *is_empty)
	Check if a pool is empty. More...

int	ABT_pool_get_total_size (ABT_pool pool, size_t *size)
	Get the total size of a pool. More...

int	ABT_pool_get_size (ABT_pool pool, size_t *size)
	Get the size of a pool. More...

int	ABT_pool_pop_thread (ABT_pool pool, ABT_thread *thread)
	Pop a work unit from a pool. More...

int	ABT_pool_pop_thread_ex (ABT_pool pool, ABT_thread *thread, ABT_pool_context pool_ctx)
	Pop a work unit from a pool. More...

int	ABT_pool_pop_threads (ABT_pool pool, ABT_thread threads, size_t len, size_t num)
	Pop work units from a pool. More...

int	ABT_pool_pop_threads_ex (ABT_pool pool, ABT_thread threads, size_t len, size_t num, ABT_pool_context pool_ctx)
	Pop work units from a pool. More...

int	ABT_pool_push_thread (ABT_pool pool, ABT_thread thread)
	Push a work unit to a pool. More...

int	ABT_pool_push_thread_ex (ABT_pool pool, ABT_thread thread, ABT_pool_context pool_ctx)
	Push a work unit to a pool. More...

int	ABT_pool_push_threads (ABT_pool pool, const ABT_thread *threads, size_t num)
	Push work units to a pool. More...

int	ABT_pool_push_threads_ex (ABT_pool pool, const ABT_thread *threads, size_t num, ABT_pool_context pool_ctx)
	Push work units to a pool. More...

int	ABT_pool_pop_wait_thread (ABT_pool pool, ABT_thread *thread, double time_secs)
	Pop a work unit from a pool. More...

int	ABT_pool_pop_wait_thread_ex (ABT_pool pool, ABT_thread *thread, double time_secs, ABT_pool_context pool_ctx)
	Pop a work unit from a pool. More...

int	ABT_pool_print_all_threads (ABT_pool pool, void arg, void(print_fn)(void *arg, ABT_thread))
	Apply a print function to every work unit in a pool. More...

int	ABT_pool_pop (ABT_pool pool, ABT_unit *p_unit)
	Pop a work unit from a pool. More...

int	ABT_pool_pop_wait (ABT_pool pool, ABT_unit *p_unit, double time_secs)
	Pop a unit from a pool with wait. More...

int	ABT_pool_pop_timedwait (ABT_pool pool, ABT_unit *p_unit, double abstime_secs)
	Pop a unit from a pool with timed wait. More...

int	ABT_pool_push (ABT_pool pool, ABT_unit unit)
	Push a unit to a pool. More...

int	ABT_pool_remove (ABT_pool pool, ABT_unit unit)
	Remove a specified work unit from a pool. More...

int	ABT_pool_print_all (ABT_pool pool, void arg, void(print_fn)(void *, ABT_unit))
	Apply a print function to every work unit in a pool using a user-defined function. More...

int	ABT_pool_set_data (ABT_pool pool, void *data)
	Set user data in a pool. More...

int	ABT_pool_get_data (ABT_pool pool, void **data)
	Retrieve user data from a pool. More...

int	ABT_pool_add_sched (ABT_pool pool, ABT_sched sched)
	Create a new work unit associated with a scheduler and push it to a pool. More...

int	ABT_pool_get_id (ABT_pool pool, int *id)
	Get ID of a pool. More...

ABTU_ret_err int	ABTI_pool_create_basic (ABT_pool_kind kind, ABT_pool_access access, ABT_bool automatic, ABTI_pool **pp_newpool)

void	ABTI_pool_free (ABTI_pool *p_pool)

ABT_thread	ABTI_pool_pop_timedwait (ABTI_pool *p_pool, double abstime_secs)

void	ABTI_pool_print (ABTI_pool p_pool, FILE p_os, int indent)

void	ABTI_pool_reset_id (void)

static ABT_unit	pool_create_unit_wrapper (ABT_pool pool, ABT_thread thread)

static void	pool_free_unit_wrapper (ABT_pool pool, ABT_unit unit)

static ABT_bool	pool_is_empty_wrapper (ABT_pool pool)

static ABT_thread	pool_pop_wrapper (ABT_pool pool, ABT_pool_context context)

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

static int	pool_init_wrapper (ABT_pool pool, ABT_pool_config config)

static void	pool_free_wrapper (ABT_pool pool)

static size_t	pool_get_size_wrapper (ABT_pool pool)

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

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

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

static void	pool_print_all_wrapper (ABT_pool pool, void arg, void(print_f)(void *, ABT_thread))

static uint64_t	pool_get_new_id (void)

Variables
static ABTD_atomic_uint64	g_pool_id = ABTD_ATOMIC_UINT64_STATIC_INITIALIZER(0)

Function Documentation

◆ ABTI_pool_create_basic()

ABTU_ret_err int ABTI_pool_create_basic	(	ABT_pool_kind	kind,
		ABT_pool_access	access,
		ABT_bool	automatic,
		ABTI_pool **	pp_newpool
	)

Definition at line 1389 of file pool.c.

Referenced by ABT_pool_create_basic(), ABTI_sched_create_basic(), sched_create(), and xstream_create().

◆ ABTI_pool_free()

void ABTI_pool_free ( ABTI_pool * p_pool )

Definition at line 1433 of file pool.c.

Referenced by ABT_pool_free(), ABTI_sched_create_basic(), ABTI_sched_free(), sched_create(), and xstream_create().

◆ ABTI_pool_pop_timedwait()

ABT_thread ABTI_pool_pop_timedwait	(	ABTI_pool *	p_pool,
		double	abstime_secs
	)

Definition at line 1442 of file pool.c.

Referenced by ABT_pool_pop_timedwait(), and sched_run().

◆ ABTI_pool_print()

void ABTI_pool_print	(	ABTI_pool *	p_pool,
		FILE *	p_os,
		int	indent
	)

Definition at line 1459 of file pool.c.

Referenced by ABT_info_print_pool(), and ABTI_sched_print().

◆ ABTI_pool_reset_id()

void ABTI_pool_reset_id ( void )

Definition at line 1512 of file pool.c.

Referenced by init_library().

◆ pool_create()

static ABTU_ret_err int pool_create	(	ABT_pool_access	access,
		const ABTI_pool_required_def *	p_required_def,
		const ABTI_pool_optional_def *	p_optional_def,
		const ABTI_pool_deprecated_def *	p_deprecated_def,
		const ABTI_pool_old_def *	p_old_def,
		ABTI_pool_config *	p_config,
		ABT_bool	def_automatic,
		ABT_bool	is_builtin,
		ABTI_pool **	pp_newpool
	)

static

Definition at line 1685 of file pool.c.

Referenced by ABT_pool_create(), and ABTI_pool_create_basic().

◆ pool_create_def_from_old_def()

static void pool_create_def_from_old_def	(	const ABT_pool_def *	p_def,
		ABTI_pool_old_def *	p_old_def,
		ABTI_pool_required_def *	p_required_def,
		ABTI_pool_optional_def *	p_optional_def,
		ABTI_pool_deprecated_def *	p_deprecated_def
	)