source: src/libcfa/concurrency/monitor @ 827a190

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since 827a190 was 0cf5b79, checked in by Thierry Delisle <tdelisle@…>, 6 years ago

Added generic containers for runtime.
Moved some internal code to bits folder.
consistently used cforall instead of CFORALL define.

  • Property mode set to 100644
File size: 3.8 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
7// monitor --
8//
9// Author           : Thierry Delisle
10// Created On       : Thd Feb 23 12:27:26 2017
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Sat Oct  7 18:06:45 2017
13// Update Count     : 10
14//
15
16#pragma once
17
18#include <stddef.h>
19
20#include <assert.h>
21#include "invoke.h"
22#include "stdlib"
23
24trait is_monitor(dtype T) {
25        monitor_desc * get_monitor( T & );
26        void ^?{}( T & mutex );
27};
28
29static inline void ?{}(monitor_desc & this) {
30        (this.lock){};
31        (this.entry_queue){};
32        (this.signal_stack){};
33        this.owner         = NULL;
34        this.recursion     = 0;
35        this.mask.accepted = NULL;
36        this.mask.data     = NULL;
37        this.mask.size     = 0;
38        this.dtor_node     = NULL;
39}
40
41struct monitor_guard_t {
42        monitor_desc **         m;
43        __lock_size_t           count;
44        __monitor_group_t prev;
45};
46
47void ?{}( monitor_guard_t & this, monitor_desc ** m, __lock_size_t count, void (*func)() );
48void ^?{}( monitor_guard_t & this );
49
50struct monitor_dtor_guard_t {
51        monitor_desc *    m;
52        __monitor_group_t prev;
53};
54
55void ?{}( monitor_dtor_guard_t & this, monitor_desc ** m, void (*func)() );
56void ^?{}( monitor_dtor_guard_t & this );
57
58static inline forall( dtype T | sized(T) | { void ^?{}( T & mutex ); } )
59void delete( T * th ) {
60        ^(*th){};
61        free( th );
62}
63
64//-----------------------------------------------------------------------------
65// Internal scheduling
66
67struct __condition_criterion_t {
68        // Whether or not the criterion is met (True if met)
69        bool ready;
70
71        // The monitor this criterion concerns
72        monitor_desc * target;
73
74        // The parent node to which this criterion belongs
75        struct __condition_node_t * owner;
76
77        // Intrusive linked list Next field
78        __condition_criterion_t * next;
79};
80
81static inline __condition_criterion_t * & get_next( __condition_criterion_t & this ) {
82        return this.next;
83}
84
85struct __condition_node_t {
86        // Thread that needs to be woken when all criteria are met
87        thread_desc * waiting_thread;
88
89        // Array of criteria (Criterions are contiguous in memory)
90        __condition_criterion_t * criteria;
91
92        // Number of criterions in the criteria
93        __lock_size_t count;
94
95        // Intrusive linked list Next field
96        __condition_node_t * next;
97
98        // Custom user info accessible before signalling
99        uintptr_t user_info;
100};
101
102static inline __condition_node_t * & get_next( __condition_node_t & this ) {
103        return this.next;
104}
105
106void ?{}(__condition_node_t & this, thread_desc * waiting_thread, __lock_size_t count, uintptr_t user_info );
107void ?{}(__condition_criterion_t & this );
108void ?{}(__condition_criterion_t & this, monitor_desc * target, __condition_node_t * owner );
109
110struct condition {
111        // Link list which contains the blocked threads as-well as the information needed to unblock them
112        __queue_t(__condition_node_t) blocked;
113
114        // Array of monitor pointers (Monitors are NOT contiguous in memory)
115        monitor_desc ** monitors;
116
117        // Number of monitors in the array
118        __lock_size_t monitor_count;
119};
120
121static inline void ?{}( condition & this ) {
122        this.monitors = NULL;
123        this.monitor_count = 0;
124}
125
126static inline void ^?{}( condition & this ) {
127        free( this.monitors );
128}
129
130              void wait        ( condition & this, uintptr_t user_info = 0 );
131              bool signal      ( condition & this );
132              bool signal_block( condition & this );
133static inline bool is_empty    ( condition & this ) { return !this.blocked.head; }
134         uintptr_t front       ( condition & this );
135
136//-----------------------------------------------------------------------------
137// External scheduling
138
139struct __acceptable_t {
140        __monitor_group_t;
141        bool is_dtor;
142};
143
144void __waitfor_internal( const __waitfor_mask_t & mask, int duration );
145
146// Local Variables: //
147// mode: c //
148// tab-width: 4 //
149// End: //
Note: See TracBrowser for help on using the repository browser.