LibCircle
0.3.0
A simple interface for processing workloads using an automatically distributed global queue.
|
Functions | |
CIRCLE_internal_queue_t * | CIRCLE_internal_queue_init (void) |
int8_t | CIRCLE_internal_queue_free (CIRCLE_internal_queue_t *qp) |
void | CIRCLE_internal_queue_dump (CIRCLE_internal_queue_t *qp) |
void | CIRCLE_internal_queue_print (CIRCLE_internal_queue_t *qp) |
int8_t | CIRCLE_internal_queue_str_extend (CIRCLE_internal_queue_t *qp, int32_t new_size) |
int8_t | CIRCLE_internal_queue_extend (CIRCLE_internal_queue_t *qp, size_t new_size) |
int8_t | CIRCLE_internal_queue_push (CIRCLE_internal_queue_t *qp, char *str) |
int8_t | CIRCLE_internal_queue_pop (CIRCLE_internal_queue_t *qp, char *str) |
int8_t | CIRCLE_internal_queue_read (CIRCLE_internal_queue_t *qp, int rank) |
int8_t | CIRCLE_internal_queue_write (CIRCLE_internal_queue_t *qp, int rank) |
This file contains functions related to the local queue structure.
void CIRCLE_internal_queue_dump | ( | CIRCLE_internal_queue_t * | qp | ) |
Dump the raw contents of the queue structure to logging.
qp | the queue structure that should be dumped. |
int8_t CIRCLE_internal_queue_extend | ( | CIRCLE_internal_queue_t * | qp, |
size_t | new_size | ||
) |
Extend the circle queue size
Referenced by CIRCLE_internal_queue_push().
int8_t CIRCLE_internal_queue_free | ( | CIRCLE_internal_queue_t * | qp | ) |
Free the memory used by a libcircle basic queue structure.
qp | the reference to the queue that should be freed. |
Referenced by CIRCLE_finalize(), and CIRCLE_internal_queue_init().
CIRCLE_internal_queue_t* CIRCLE_internal_queue_init | ( | void | ) |
Allocate memory for the basic queue structure used by libcircle.
References CIRCLE_internal_queue_free().
int8_t CIRCLE_internal_queue_pop | ( | CIRCLE_internal_queue_t * | qp, |
char * | str | ||
) |
Removes an item from the queue and returns a copy.
qp | the queue structure to remove the item from. |
str | a reference to the value removed. |
Referenced by CIRCLE_internal_queue_write().
void CIRCLE_internal_queue_print | ( | CIRCLE_internal_queue_t * | qp | ) |
Pretty-print the queue data structure.
qp | the queue structure that should be pretty-printed. |
int8_t CIRCLE_internal_queue_push | ( | CIRCLE_internal_queue_t * | qp, |
char * | str | ||
) |
Push the specified string onto the queue structure.
qp | the queue structure to push the value onto. |
str | the string value to push onto the queue. |
References CIRCLE_internal_queue_extend(), and CIRCLE_internal_queue_str_extend().
Referenced by CIRCLE_internal_queue_read().
int8_t CIRCLE_internal_queue_read | ( | CIRCLE_internal_queue_t * | qp, |
int | rank | ||
) |
Read a queue checkpoint file into working memory.
qp | the queue structure to read the checkpoint file into. |
rank | the node which holds the checkpoint file. |
References CIRCLE_internal_queue_push().
Referenced by _CIRCLE_read_restarts().
int8_t CIRCLE_internal_queue_str_extend | ( | CIRCLE_internal_queue_t * | qp, |
int32_t | new_size | ||
) |
Extend the string array size size
Referenced by CIRCLE_internal_queue_push().
int8_t CIRCLE_internal_queue_write | ( | CIRCLE_internal_queue_t * | qp, |
int | rank | ||
) |
Write out the queue structure to a checkpoint file.
qp | the queue structure to be written to the checkpoint file. |
rank | the node which is writing out the checkpoint file. |
References CIRCLE_internal_queue_pop().
Referenced by _CIRCLE_checkpoint().