source: doc/working/unified_semaphores/semaphore.hfa

Last change on this file was c2409fd, checked in by caparsons <caparson@…>, 3 years ago

added WIP unified semaphore code

  • Property mode set to 100644
File size: 3.3 KB
Line 
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///////////////////////////////////////////////////////////////////
20forall(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}
Note: See TracBrowser for help on using the repository browser.