projects / apple / xnu.git / blame
| Commit | Line | Data |
|---|---|---|
| 0a7de745 A |
1 | #ifndef _KERN_MPQUEUE_H |
| 2 | #define _KERN_MPQUEUE_H | |
| 3 | #include <kern/locks.h> | |
| 4 | ||
| 5 | __BEGIN_DECLS | |
| 6 | ||
| 7 | #ifdef MACH_KERNEL_PRIVATE | |
| 8 | ||
| f427ee49 A |
9 | #include <kern/priority_queue.h> |
| 10 | ||
| 0a7de745 A |
11 | /*----------------------------------------------------------------*/ |
| 12 | /* | |
| 13 | * Define macros for queues with locks. | |
| 14 | */ | |
| 15 | struct mpqueue_head { | |
| 16 | struct queue_entry head; /* header for queue */ | |
| f427ee49 | 17 | struct priority_queue_deadline_min mpq_pqhead; |
| 0a7de745 A |
18 | uint64_t earliest_soft_deadline; |
| 19 | uint64_t count; | |
| 20 | lck_mtx_t lock_data; | |
| 21 | #if defined(__i386__) || defined(__x86_64__) | |
| 22 | lck_mtx_ext_t lock_data_ext; | |
| 23 | #endif | |
| 24 | }; | |
| 25 | ||
| 26 | typedef struct mpqueue_head mpqueue_head_t; | |
| 27 | ||
| 0a7de745 A |
28 | #if defined(__i386__) || defined(__x86_64__) |
| 29 | ||
| 30 | #define mpqueue_init(q, lck_grp, lck_attr) \ | |
| 31 | MACRO_BEGIN \ | |
| 32 | queue_init(&(q)->head); \ | |
| 33 | lck_mtx_init_ext(&(q)->lock_data, \ | |
| 34 | &(q)->lock_data_ext, \ | |
| 35 | lck_grp, \ | |
| 36 | lck_attr); \ | |
| 37 | (q)->earliest_soft_deadline = UINT64_MAX; \ | |
| 38 | (q)->count = 0; \ | |
| f427ee49 | 39 | priority_queue_init(&(q)->mpq_pqhead); \ |
| 0a7de745 A |
40 | MACRO_END |
| 41 | ||
| 42 | #else | |
| 43 | ||
| 44 | #define mpqueue_init(q, lck_grp, lck_attr) \ | |
| 45 | MACRO_BEGIN \ | |
| 46 | queue_init(&(q)->head); \ | |
| 47 | lck_mtx_init(&(q)->lock_data, \ | |
| 48 | lck_grp, \ | |
| 49 | lck_attr); \ | |
| f427ee49 | 50 | priority_queue_init(&(q)->mpq_pqhead); \ |
| 0a7de745 A |
51 | MACRO_END |
| 52 | #endif | |
| 53 | ||
| 54 | ||
| 55 | #define mpenqueue_tail(q, elt) \ | |
| 56 | MACRO_BEGIN \ | |
| 57 | lck_mtx_lock_spin_always(&(q)->lock_data); \ | |
| 58 | enqueue_tail(&(q)->head, elt); \ | |
| 59 | lck_mtx_unlock_always(&(q)->lock_data); \ | |
| 60 | MACRO_END | |
| 61 | ||
| 62 | #define mpdequeue_head(q, elt) \ | |
| 63 | MACRO_BEGIN \ | |
| 64 | lck_mtx_lock_spin_always(&(q)->lock_data); \ | |
| 65 | if (queue_empty(&(q)->head)) \ | |
| 66 | *(elt) = 0; \ | |
| 67 | else \ | |
| 68 | *(elt) = dequeue_head(&(q)->head); \ | |
| 69 | lck_mtx_unlock_always(&(q)->lock_data); \ | |
| 70 | MACRO_END | |
| 71 | ||
| 72 | #endif /* MACH_KERNEL_PRIVATE */ | |
| 73 | ||
| 74 | __END_DECLS | |
| 75 | ||
| 76 | ||
| 77 | #endif /* _KERN_QUEUE_H */ |