1 /***** the library wide include file *****/
2 #include "liblfds610_internal.h"
7 #define LFDS610_QUEUE_STATE_UNKNOWN -1
8 #define LFDS610_QUEUE_STATE_EMPTY 0
9 #define LFDS610_QUEUE_STATE_ENQUEUE_OUT_OF_PLACE 1
10 #define LFDS610_QUEUE_STATE_ATTEMPT_DELFDS610_QUEUE 2
12 #define LFDS610_QUEUE_POINTER 0
13 #define LFDS610_QUEUE_COUNTER 1
14 #define LFDS610_QUEUE_PAC_SIZE 2
16 /***** structures *****/
17 #pragma pack( push, LFDS610_ALIGN_DOUBLE_POINTER )
19 struct lfds610_queue_state
21 struct lfds610_queue_element
22 *volatile enqueue[LFDS610_QUEUE_PAC_SIZE],
23 *volatile dequeue[LFDS610_QUEUE_PAC_SIZE];
28 struct lfds610_freelist_state
32 struct lfds610_queue_element
34 // TRD : next in a lfds610_queue requires volatile as it is target of CAS
35 struct lfds610_queue_element
36 *volatile next[LFDS610_QUEUE_PAC_SIZE];
38 struct lfds610_freelist_element
49 /***** private prototypes *****/
50 int lfds610_queue_internal_freelist_init_function( void **user_data, void *user_state );
51 void lfds610_queue_internal_freelist_delete_function( void *user_data, void *user_state );
53 void lfds610_queue_internal_new_element_from_freelist( struct lfds610_queue_state *qs, struct lfds610_queue_element *qe[LFDS610_QUEUE_PAC_SIZE], void *user_data );
54 void lfds610_queue_internal_guaranteed_new_element_from_freelist( struct lfds610_queue_state *qs, struct lfds610_queue_element * qe[LFDS610_QUEUE_PAC_SIZE], void *user_data );
55 void lfds610_queue_internal_init_element( struct lfds610_queue_state *qs, struct lfds610_queue_element *qe[LFDS610_QUEUE_PAC_SIZE], struct lfds610_freelist_element *fe, void *user_data );
57 void lfds610_queue_internal_queue( struct lfds610_queue_state *qs, struct lfds610_queue_element *qe[LFDS610_QUEUE_PAC_SIZE] );
59 void lfds610_queue_internal_validate( struct lfds610_queue_state *qs, struct lfds610_validation_info *vi, enum lfds610_data_structure_validity *lfds610_queue_validity, enum lfds610_data_structure_validity *lfds610_freelist_validity );