| 1 | #pragma once
|
|---|
| 2 |
|
|---|
| 3 | #include "locks.hfa"
|
|---|
| 4 | #include <stdbool.h>
|
|---|
| 5 |
|
|---|
| 6 | #include "bits/algorithm.hfa"
|
|---|
| 7 | #include "bits/locks.hfa"
|
|---|
| 8 | #include "bits/containers.hfa"
|
|---|
| 9 |
|
|---|
| 10 | #include "invoke.h"
|
|---|
| 11 |
|
|---|
| 12 | #include "time_t.hfa"
|
|---|
| 13 | #include "time.hfa"
|
|---|
| 14 | #include <sys/time.h>
|
|---|
| 15 | #include "alarm.hfa"
|
|---|
| 16 |
|
|---|
| 17 | ///////////////////////////////////////////////////////////////////
|
|---|
| 18 | //// Semaphores
|
|---|
| 19 | ///////////////////////////////////////////////////////////////////
|
|---|
| 20 | forall(dtype L | is_blocking_lock(L)) {
|
|---|
| 21 |
|
|---|
| 22 | struct base_semaphore {
|
|---|
| 23 | // internal counter for the semaphore
|
|---|
| 24 | int count;
|
|---|
| 25 |
|
|---|
| 26 | // Spin lock used for mutual exclusion
|
|---|
| 27 | __spinlock_t lock;
|
|---|
| 28 |
|
|---|
| 29 | // List of blocked threads
|
|---|
| 30 | __queue_t(info_thread(L)) blocked_threads;
|
|---|
| 31 |
|
|---|
| 32 | // Flag if the semaphor is binary
|
|---|
| 33 | bool is_binary;
|
|---|
| 34 | };
|
|---|
| 35 |
|
|---|
| 36 | // A semaphore that is binary
|
|---|
| 37 | // If the current owner P's this semaphore it will not block
|
|---|
| 38 | struct binary_semaphore {
|
|---|
| 39 | inline base_semaphore(L);
|
|---|
| 40 | };
|
|---|
| 41 |
|
|---|
| 42 | // A semaphore that maintains a counter.
|
|---|
| 43 | // If a thread P's this semaphore it always decreases the counter
|
|---|
| 44 | struct counting_semaphore {
|
|---|
| 45 | inline base_semaphore(L);
|
|---|
| 46 | };
|
|---|
| 47 |
|
|---|
| 48 | void ?{}(base_semaphore(L) & this, int count, bool is_binary);
|
|---|
| 49 | void ^?{}(base_semaphore(L) & this);
|
|---|
| 50 |
|
|---|
| 51 | void ?{}(binary_semaphore(L) & this);
|
|---|
| 52 | void ?{}(binary_semaphore(L) & this, int count);
|
|---|
| 53 | void ^?{}(binary_semaphore(L) & this);
|
|---|
| 54 |
|
|---|
| 55 | void ?{}(counting_semaphore(L) & this);
|
|---|
| 56 | void ?{}(counting_semaphore(L) & this, int count);
|
|---|
| 57 | void ^?{}(counting_semaphore(L) & this);
|
|---|
| 58 |
|
|---|
| 59 | struct alarm_node_semaphore {
|
|---|
| 60 | alarm_node_t alarm_node;
|
|---|
| 61 |
|
|---|
| 62 | base_semaphore(L) * sem;
|
|---|
| 63 |
|
|---|
| 64 | info_thread(L) ** i;
|
|---|
| 65 | };
|
|---|
| 66 |
|
|---|
| 67 | void ?{}( alarm_node_semaphore(L) & this, $thread * thrd, Time alarm, Duration period, Alarm_Callback callback );
|
|---|
| 68 | void ^?{}( alarm_node_semaphore(L) & this );
|
|---|
| 69 |
|
|---|
| 70 | void add_( base_semaphore(L) & this, struct $thread * t );
|
|---|
| 71 | void remove_( base_semaphore(L) & this );
|
|---|
| 72 |
|
|---|
| 73 | // TODO: look into changing timout routines to return bool showing if signalled or woken by kernel
|
|---|
| 74 | void P(base_semaphore(L) & this);
|
|---|
| 75 | void P(base_semaphore(L) & this, uintptr_t info);
|
|---|
| 76 | void P(base_semaphore(L) & this, Duration duration);
|
|---|
| 77 | void P(base_semaphore(L) & this, uintptr_t info, Duration duration);
|
|---|
| 78 | void P(base_semaphore(L) & this, Time time);
|
|---|
| 79 | void P(base_semaphore(L) & this, uintptr_t info, Time time);
|
|---|
| 80 | void P(base_semaphore(L) & this, base_semaphore(L) & s);
|
|---|
| 81 | void P(base_semaphore(L) & this, base_semaphore(L) & s, uintptr_t info);
|
|---|
| 82 | void P(base_semaphore(L) & this, base_semaphore(L) & s, Duration duration );
|
|---|
| 83 | void P(base_semaphore(L) & this, base_semaphore(L) & s, uintptr_t info, Duration duration);
|
|---|
| 84 | void P(base_semaphore(L) & this, base_semaphore(L) & s, Time time);
|
|---|
| 85 | void P(base_semaphore(L) & this, base_semaphore(L) & s, uintptr_t info, Time time);
|
|---|
| 86 |
|
|---|
| 87 | bool tryP(base_semaphore(L) & this);
|
|---|
| 88 |
|
|---|
| 89 | void V(base_semaphore(L) & this);
|
|---|
| 90 | void V(base_semaphore(L) & this, int times);
|
|---|
| 91 |
|
|---|
| 92 | // void ?`++(base_semaphore(L) & this);
|
|---|
| 93 | // void ?`--(base_semaphore(L) & this);
|
|---|
| 94 |
|
|---|
| 95 | // void ?`V(base_semaphore(L) & this);
|
|---|
| 96 | // void ?`P(base_semaphore(L) & this);
|
|---|
| 97 |
|
|---|
| 98 | uintptr_t front(base_semaphore(L) & this);
|
|---|
| 99 | bool empty(base_semaphore(L) & this);
|
|---|
| 100 | int counter(base_semaphore(L) & this);
|
|---|
| 101 |
|
|---|
| 102 |
|
|---|
| 103 | // these are to satisfy the is_blocking_lock trait so that
|
|---|
| 104 | // semaphores can be released by condition variables and vice versa
|
|---|
| 105 | void set_recursion_count( base_semaphore(L) & this, size_t recursion );
|
|---|
| 106 | size_t get_recursion_count( base_semaphore(L) & this );
|
|---|
| 107 | }
|
|---|
