|
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().
Referenced by CIRCLE_init().
| 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().