projects
/
urcu.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Install urcu/map/*.h into system
[urcu.git]
/
urcu
/
wfqueue-static.h
diff --git
a/urcu/wfqueue-static.h
b/urcu/wfqueue-static.h
index 30d6e963f321f9c7f836e8ae2f9a0b2d5a7e857d..790931bef25db04d2156fe0cd39dd260b31a0474 100644
(file)
--- a/
urcu/wfqueue-static.h
+++ b/
urcu/wfqueue-static.h
@@
-28,6
+28,7
@@
#include <pthread.h>
#include <assert.h>
#include <pthread.h>
#include <assert.h>
+#include <poll.h>
#include <urcu/compiler.h>
#include <urcu/uatomic_arch.h>
#include <urcu/compiler.h>
#include <urcu/uatomic_arch.h>
@@
-47,12
+48,12
@@
extern "C" {
#define WFQ_ADAPT_ATTEMPTS 10 /* Retry if being set */
#define WFQ_WAIT 10 /* Wait 10 ms if being set */
#define WFQ_ADAPT_ATTEMPTS 10 /* Retry if being set */
#define WFQ_WAIT 10 /* Wait 10 ms if being set */
-void _cds_wfq_node_init(struct cds_wfq_node *node)
+
static inline
void _cds_wfq_node_init(struct cds_wfq_node *node)
{
node->next = NULL;
}
{
node->next = NULL;
}
-void _cds_wfq_init(struct cds_wfq_queue *q)
+
static inline
void _cds_wfq_init(struct cds_wfq_queue *q)
{
int ret;
{
int ret;
@@
-64,7
+65,8
@@
void _cds_wfq_init(struct cds_wfq_queue *q)
assert(!ret);
}
assert(!ret);
}
-void _cds_wfq_enqueue(struct cds_wfq_queue *q, struct cds_wfq_node *node)
+static inline void _cds_wfq_enqueue(struct cds_wfq_queue *q,
+ struct cds_wfq_node *node)
{
struct cds_wfq_node **old_tail;
{
struct cds_wfq_node **old_tail;
@@
-90,7
+92,7
@@
void _cds_wfq_enqueue(struct cds_wfq_queue *q, struct cds_wfq_node *node)
* thread to be scheduled. The queue appears empty until tail->next is set by
* enqueue.
*/
* thread to be scheduled. The queue appears empty until tail->next is set by
* enqueue.
*/
-struct cds_wfq_node *
+st
atic inline st
ruct cds_wfq_node *
___cds_wfq_dequeue_blocking(struct cds_wfq_queue *q)
{
struct cds_wfq_node *node, *next;
___cds_wfq_dequeue_blocking(struct cds_wfq_queue *q)
{
struct cds_wfq_node *node, *next;
@@
-128,7
+130,7
@@
___cds_wfq_dequeue_blocking(struct cds_wfq_queue *q)
return node;
}
return node;
}
-struct cds_wfq_node *
+st
atic inline st
ruct cds_wfq_node *
_cds_wfq_dequeue_blocking(struct cds_wfq_queue *q)
{
struct cds_wfq_node *retnode;
_cds_wfq_dequeue_blocking(struct cds_wfq_queue *q)
{
struct cds_wfq_node *retnode;
This page took
0.023903 seconds
and
4
git commands to generate.