ARGOBOTS  66b1c39742507d8df30e8d28c54839b961a14814
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Groups
Functions
stream.c File Reference
#include "abti.h"
Include dependency graph for stream.c:

Go to the source code of this file.

Functions

static ABTU_ret_err int xstream_create (ABTI_sched *p_sched, ABTI_xstream_type xstream_type, int rank, ABTI_xstream **pp_xstream)
 
static ABTU_ret_err int xstream_start (ABTI_xstream *p_xstream)
 
static ABTU_ret_err int xstream_join (ABTI_local **pp_local, ABTI_xstream *p_xstream)
 
static ABT_bool xstream_set_new_rank (ABTI_xstream *p_newxstream, int rank)
 
static void xstream_return_rank (ABTI_xstream *p_xstream)
 
static void xstream_schedule_ythread (ABTI_xstream **pp_local_xstream, ABTI_ythread *p_ythread)
 
static void xstream_schedule_task (ABTI_xstream *p_local_xstream, ABTI_thread *p_task)
 
static void xstream_init_main_sched (ABTI_xstream *p_xstream, ABTI_sched *p_sched)
 
static ABTU_ret_err int xstream_update_main_sched (ABTI_xstream **pp_local_xstream, ABTI_xstream *p_xstream, ABTI_sched *p_sched)
 
static void * xstream_launch_root_ythread (void *p_xstream)
 
static ABTU_ret_err int xstream_migrate_thread (ABTI_local *p_local, ABTI_thread *p_thread)
 
int ABT_xstream_create (ABT_sched sched, ABT_xstream *newxstream)
 Create a new ES and return its handle through newxstream. More...
 
int ABT_xstream_create_basic (ABT_sched_predef predef, int num_pools, ABT_pool *pools, ABT_sched_config config, ABT_xstream *newxstream)
 Create a new ES with a predefined scheduler and return its handle through newxstream. More...
 
int ABT_xstream_create_with_rank (ABT_sched sched, int rank, ABT_xstream *newxstream)
 Create a new ES with a specific rank. More...
 
int ABT_xstream_revive (ABT_xstream xstream)
 Restart an ES that has been joined by ABT_xstream_join(). More...
 
int ABT_xstream_free (ABT_xstream *xstream)
 Release the ES object associated with ES handle. More...
 
int ABT_xstream_join (ABT_xstream xstream)
 Wait for xstream to terminate. More...
 
int ABT_xstream_exit (void)
 Terminate the ES associated with the calling ULT. More...
 
int ABT_xstream_cancel (ABT_xstream xstream)
 Request the cancellation of the target ES. More...
 
int ABT_xstream_self (ABT_xstream *xstream)
 Return the ES handle associated with the caller work unit. More...
 
int ABT_xstream_self_rank (int *rank)
 Return the rank of ES associated with the caller work unit. More...
 
int ABT_xstream_set_rank (ABT_xstream xstream, int rank)
 Set the rank for target ES. More...
 
int ABT_xstream_get_rank (ABT_xstream xstream, int *rank)
 Return the rank of ES. More...
 
int ABT_xstream_set_main_sched (ABT_xstream xstream, ABT_sched sched)
 Set the main scheduler of the target ES. More...
 
int ABT_xstream_set_main_sched_basic (ABT_xstream xstream, ABT_sched_predef predef, int num_pools, ABT_pool *pools)
 Set the main scheduler for xstream with a predefined scheduler. More...
 
int ABT_xstream_get_main_sched (ABT_xstream xstream, ABT_sched *sched)
 Get the main scheduler of the target ES. More...
 
int ABT_xstream_get_main_pools (ABT_xstream xstream, int max_pools, ABT_pool *pools)
 Get the pools of the main scheduler of the target ES. More...
 
int ABT_xstream_get_state (ABT_xstream xstream, ABT_xstream_state *state)
 Return the state of xstream. More...
 
int ABT_xstream_equal (ABT_xstream xstream1, ABT_xstream xstream2, ABT_bool *result)
 Compare two ES handles for equality. More...
 
int ABT_xstream_get_num (int *num_xstreams)
 Return the number of current existing ESs. More...
 
int ABT_xstream_is_primary (ABT_xstream xstream, ABT_bool *flag)
 Check if the target ES is the primary ES. More...
 
int ABT_xstream_run_unit (ABT_unit unit, ABT_pool pool)
 Execute a unit on the local ES. More...
 
int ABT_xstream_check_events (ABT_sched sched)
 Check the events and process them. More...
 
int ABT_xstream_set_cpubind (ABT_xstream xstream, int cpuid)
 Bind the target ES to a target CPU. More...
 
int ABT_xstream_get_cpubind (ABT_xstream xstream, int *cpuid)
 Get the CPU binding for the target ES. More...
 
int ABT_xstream_set_affinity (ABT_xstream xstream, int cpuset_size, int *cpuset)
 Set the CPU affinity of the target ES. More...
 
int ABT_xstream_get_affinity (ABT_xstream xstream, int cpuset_size, int *cpuset, int *num_cpus)
 Get the CPU affinity for the target ES. More...
 

Function Documentation

static ABTU_ret_err int xstream_create ( ABTI_sched *  p_sched,
ABTI_xstream_type  xstream_type,
int  rank,
ABTI_xstream **  pp_xstream 
)
static
static void xstream_init_main_sched ( ABTI_xstream *  p_xstream,
ABTI_sched *  p_sched 
)
static

Definition at line 1345 of file stream.c.

Referenced by xstream_create().

static ABTU_ret_err int xstream_join ( ABTI_local **  pp_local,
ABTI_xstream *  p_xstream 
)
static

Definition at line 1119 of file stream.c.

Referenced by ABT_xstream_free(), and ABT_xstream_join().

static void * xstream_launch_root_ythread ( void *  p_xstream)
static

Definition at line 1022 of file stream.c.

Referenced by xstream_start().

static ABTU_ret_err int xstream_migrate_thread ( ABTI_local *  p_local,
ABTI_thread *  p_thread 
)
static

Definition at line 1306 of file stream.c.

Referenced by xstream_schedule_ythread().

static void xstream_return_rank ( ABTI_xstream *  p_xstream)
static

Definition at line 1532 of file stream.c.

static void xstream_schedule_task ( ABTI_xstream *  p_local_xstream,
ABTI_thread *  p_task 
)
inlinestatic

Definition at line 1260 of file stream.c.

static void xstream_schedule_ythread ( ABTI_xstream **  pp_local_xstream,
ABTI_ythread *  p_ythread 
)
inlinestatic

Definition at line 1143 of file stream.c.

static ABT_bool xstream_set_new_rank ( ABTI_xstream *  p_newxstream,
int  rank 
)
static

Definition at line 1436 of file stream.c.

Referenced by xstream_create().

static ABTU_ret_err int xstream_start ( ABTI_xstream *  p_xstream)
static
static ABTU_ret_err int xstream_update_main_sched ( ABTI_xstream **  pp_local_xstream,
ABTI_xstream *  p_xstream,
ABTI_sched *  p_sched 
)
static

Definition at line 1358 of file stream.c.

Referenced by ABT_xstream_set_main_sched(), and ABT_xstream_set_main_sched_basic().