libmcl-sys 0.1.2-rc1

This system crate provides Rust language bindings to the Minos Compute Library (MCL)
Documentation 
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

#include <utlist.h>
#include <pthread.h>

#include <minos.h>
#include <minos_internal.h>


int rlist_init(pthread_rwlock_t* lock)
{
	if(lock)
		return pthread_rwlock_init(lock, NULL);

	return 0;
}

mcl_rlist* rlist_pop(mcl_rlist** head, pthread_rwlock_t* lock)
{
	mcl_rlist* el = NULL;

	if(*head == NULL)
		return NULL;

	if(lock)
		pthread_rwlock_wrlock(lock);
	el = *head;
	DL_DELETE(*head, el);
	if(lock)
		pthread_rwlock_unlock(lock);

	return el;
}

int rlist_append(mcl_rlist** head, pthread_rwlock_t* lock, mcl_rlist* el)
{
	if(lock)
		pthread_rwlock_wrlock(lock);
	DL_APPEND(*head, el);
	if(lock)
		pthread_rwlock_unlock(lock);

	return 0;
}

int rlist_add(mcl_rlist** head, pthread_rwlock_t* lock, mcl_request* r)
{
	mcl_rlist* el;
	
	if(!r){
		eprintf("Invalid argument!");
		return -1;
	}

	el = (mcl_rlist*) malloc(sizeof(mcl_rlist));
	if(!el){
		eprintf("Error allocating memory!");
		return -1;
	}
	el->rid  = r->hdl->rid;
	el->req  = r;
	el->next = NULL;
	
	if(lock)
		pthread_rwlock_wrlock(lock);
	DL_APPEND(*head, el);
	if(lock)
		pthread_rwlock_unlock(lock);
	return 0;
}

mcl_request* rlist_remove(mcl_rlist** head, pthread_rwlock_t* lock, uint32_t rid)
{
	mcl_rlist*   el  = NULL;
	mcl_rlist*   tmp = NULL;
	mcl_request* req = NULL;
	
	if(*head == NULL){
		eprintf("Pending task list empty");
		return NULL;
	}

	if(lock)
		pthread_rwlock_wrlock(lock);
	DL_FOREACH_SAFE(*head, el, tmp)
		if(el->rid == rid){
			DL_DELETE(*head, el);
			break;
		}
	if(lock)
		pthread_rwlock_unlock(lock);

	if(el){
		req = el->req;
		free(el);
	}
	return req;
}

mcl_request* rlist_search(mcl_rlist** head, pthread_rwlock_t* lock, uint32_t rid)
{
	mcl_rlist* el = NULL;

	if(*head == NULL)
		return NULL;

	if(lock)
		pthread_rwlock_rdlock(lock);
	DL_SEARCH_SCALAR(*head, el, rid, rid);
	if(lock)
		pthread_rwlock_unlock(lock);

	if(el)
		return el->req;

	return NULL;
}

int rlist_count(mcl_rlist** head, pthread_rwlock_t* lock)
{
	int ret;
	mcl_rlist* el;

	if(lock)
		pthread_rwlock_rdlock(lock);
	DL_COUNT(*head, el, ret);
	if(lock)
		pthread_rwlock_unlock(lock);

	return ret;
}