-
Notifications
You must be signed in to change notification settings - Fork 47
/
ccqueue.c
73 lines (57 loc) · 1.49 KB
/
ccqueue.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
#include <stdlib.h>
#include "delay.h"
#include "ccqueue.h"
static inline
void serialEnqueue(void * state, void * data)
{
node_t * volatile * tail = (node_t **) state;
node_t * node = (node_t *) data;
(*tail)->next = node;
*tail = node;
}
static inline
void serialDequeue(void * state, void * data)
{
node_t * volatile * head = (node_t **) state;
node_t ** ptr = (node_t **) data;
node_t * node = *head;
node_t * next = node->next;
if (next) {
node->data = next->data;
*head = next;
} else {
node = (void *) -1;
}
*ptr = node;
}
void queue_init(queue_t * queue, int nprocs)
{
ccsynch_init(&queue->enq);
ccsynch_init(&queue->deq);
node_t * dummy = align_malloc(CACHE_LINE_SIZE, sizeof(node_t));
dummy->data = 0;
dummy->next = NULL;
queue->head = dummy;
queue->tail = dummy;
}
void queue_register(queue_t * queue, handle_t * handle, int id)
{
ccsynch_handle_init(&handle->enq);
ccsynch_handle_init(&handle->deq);
handle->next = align_malloc(CACHE_LINE_SIZE, sizeof(node_t));
}
void enqueue(queue_t * queue, handle_t * handle, void * data)
{
node_t * node = handle->next;
node->data = data;
node->next = NULL;
ccsynch_apply(&queue->enq, &handle->enq, &serialEnqueue, &queue->tail, node);
}
void * dequeue(queue_t * queue, handle_t * handle)
{
node_t * node;
ccsynch_apply(&queue->deq, &handle->deq, &serialDequeue, &queue->head, &node);
handle->next = node;
return node ? node->data : (void *) -1;
}
void queue_free(int id, int nprocs) {}