LibCircle 0.3.0
A simple interface for processing workloads using an automatically distributed global queue.
Loading...
Searching...
No Matches
worker.c File Reference
+ Include dependency graph for worker.c:

Functions

int8_t _CIRCLE_read_restarts (void)
 
int8_t _CIRCLE_checkpoint (void)
 
int8_t CIRCLE_worker ()
 Sets up libcircle, calls work loop function.
 

Variables

CIRCLE_handle queue_handle
 
CIRCLE_input_st CIRCLE_INPUT_ST
 

Detailed Description

The abstraction of a worker process.

Function Documentation

◆ _CIRCLE_checkpoint()

int8_t _CIRCLE_checkpoint ( void )

Wrapper for checkpointing

References CIRCLE_global_rank, CIRCLE_INPUT_ST, and CIRCLE_internal_queue_write().

Referenced by CIRCLE_checkpoint().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ _CIRCLE_read_restarts()

int8_t _CIRCLE_read_restarts ( void )

Wrapper for reading in restart files

References CIRCLE_global_rank, CIRCLE_INPUT_ST, and CIRCLE_internal_queue_read().

Referenced by CIRCLE_read_restarts().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ CIRCLE_worker()

int8_t CIRCLE_worker ( void )

Sets up libcircle, calls work loop function.

  • Main worker function. This function:
    1. Initializes MPI
    2. Initializes internal libcircle data structures
    3. Calls libcircle's main work loop function.
    4. Checkpoints if CIRCLE_abort has been called by a rank.

References CIRCLE_checkpoint(), CIRCLE_debug_level, CIRCLE_INPUT_ST, and queue_handle.

Referenced by CIRCLE_begin().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

Variable Documentation

◆ CIRCLE_INPUT_ST

◆ queue_handle

CIRCLE_handle queue_handle

Handle to the queue

Referenced by CIRCLE_get_handle(), and CIRCLE_worker().