[f07e037] | 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 |
---|
[91c389a] | 11 | // Last Modified By : Peter A. Buhr |
---|
[751d963] | 12 | // Last Modified On : Sat Oct 7 18:06:45 2017 |
---|
| 13 | // Update Count : 10 |
---|
[f07e037] | 14 | // |
---|
| 15 | |
---|
[6b0b624] | 16 | #pragma once |
---|
[f07e037] | 17 | |
---|
[690f13c] | 18 | #include <stddef.h> |
---|
| 19 | |
---|
[91c389a] | 20 | #include <assert.h> |
---|
[f07e037] | 21 | #include "invoke.h" |
---|
[2781e65] | 22 | #include "stdlib" |
---|
[f07e037] | 23 | |
---|
[1dcd9554] | 24 | trait is_monitor(dtype T) { |
---|
| 25 | monitor_desc * get_monitor( T & ); |
---|
| 26 | void ^?{}( T & mutex ); |
---|
| 27 | }; |
---|
| 28 | |
---|
[242a902] | 29 | static inline void ?{}(monitor_desc & this) { |
---|
[6b224a52] | 30 | (this.lock){}; |
---|
| 31 | (this.entry_queue){}; |
---|
| 32 | (this.signal_stack){}; |
---|
[549c006] | 33 | this.owner = NULL; |
---|
| 34 | this.recursion = 0; |
---|
[6ae8c92] | 35 | this.mask.accepted = NULL; |
---|
| 36 | this.mask.clauses = NULL; |
---|
| 37 | this.mask.size = 0; |
---|
[549c006] | 38 | this.dtor_node = NULL; |
---|
[cc7f4b1] | 39 | } |
---|
| 40 | |
---|
| 41 | struct monitor_guard_t { |
---|
[84c52a8] | 42 | monitor_desc ** m; |
---|
[59a0bde] | 43 | __lock_size_t count; |
---|
[4aa2fb2] | 44 | monitor_desc ** prev_mntrs; |
---|
[c1a9c86] | 45 | __lock_size_t prev_count; |
---|
[90c4df0] | 46 | fptr_t prev_func; |
---|
[51f3798] | 47 | }; |
---|
| 48 | |
---|
[59a0bde] | 49 | void ?{}( monitor_guard_t & this, monitor_desc ** m, __lock_size_t count, void (*func)() ); |
---|
[242a902] | 50 | void ^?{}( monitor_guard_t & this ); |
---|
[51f3798] | 51 | |
---|
[549c006] | 52 | struct monitor_dtor_guard_t { |
---|
| 53 | monitor_desc * m; |
---|
| 54 | monitor_desc ** prev_mntrs; |
---|
[c1a9c86] | 55 | __lock_size_t prev_count; |
---|
[549c006] | 56 | fptr_t prev_func; |
---|
| 57 | }; |
---|
| 58 | |
---|
| 59 | void ?{}( monitor_dtor_guard_t & this, monitor_desc ** m, void (*func)() ); |
---|
| 60 | void ^?{}( monitor_dtor_guard_t & this ); |
---|
| 61 | |
---|
[751d963] | 62 | static inline forall( dtype T | sized(T) | { void ^?{}( T & mutex ); } ) |
---|
| 63 | void delete( T * th ) { |
---|
| 64 | ^(*th){}; |
---|
| 65 | free( th ); |
---|
| 66 | } |
---|
| 67 | |
---|
[5ea06d6] | 68 | //----------------------------------------------------------------------------- |
---|
| 69 | // Internal scheduling |
---|
[0c78741] | 70 | |
---|
| 71 | struct __condition_criterion_t { |
---|
[025278e] | 72 | // Whether or not the criterion is met (True if met) |
---|
| 73 | bool ready; |
---|
| 74 | |
---|
| 75 | // The monitor this criterion concerns |
---|
| 76 | monitor_desc * target; |
---|
| 77 | |
---|
| 78 | // The parent node to which this criterion belongs |
---|
| 79 | struct __condition_node_t * owner; |
---|
| 80 | |
---|
| 81 | // Intrusive linked list Next field |
---|
| 82 | __condition_criterion_t * next; |
---|
[0c78741] | 83 | }; |
---|
| 84 | |
---|
| 85 | struct __condition_node_t { |
---|
[025278e] | 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 |
---|
[c1a9c86] | 93 | __lock_size_t count; |
---|
[025278e] | 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; |
---|
[0c78741] | 100 | }; |
---|
| 101 | |
---|
| 102 | struct __condition_blocked_queue_t { |
---|
| 103 | __condition_node_t * head; |
---|
| 104 | __condition_node_t ** tail; |
---|
| 105 | }; |
---|
| 106 | |
---|
[59a0bde] | 107 | void ?{}(__condition_node_t & this, thread_desc * waiting_thread, __lock_size_t count, uintptr_t user_info ); |
---|
[e5c8488] | 108 | void ?{}(__condition_criterion_t & this ); |
---|
| 109 | void ?{}(__condition_criterion_t & this, monitor_desc * target, __condition_node_t * owner ); |
---|
| 110 | |
---|
[242a902] | 111 | void ?{}( __condition_blocked_queue_t & ); |
---|
[8fc45b7] | 112 | void append( __condition_blocked_queue_t &, __condition_node_t * ); |
---|
| 113 | __condition_node_t * pop_head( __condition_blocked_queue_t & ); |
---|
[0c78741] | 114 | |
---|
[5ea06d6] | 115 | struct condition { |
---|
[025278e] | 116 | // Link list which contains the blocked threads as-well as the information needed to unblock them |
---|
| 117 | __condition_blocked_queue_t blocked; |
---|
| 118 | |
---|
| 119 | // Array of monitor pointers (Monitors are NOT contiguous in memory) |
---|
| 120 | monitor_desc ** monitors; |
---|
| 121 | |
---|
| 122 | // Number of monitors in the array |
---|
[c1a9c86] | 123 | __lock_size_t monitor_count; |
---|
[5ea06d6] | 124 | }; |
---|
[51f3798] | 125 | |
---|
[242a902] | 126 | static inline void ?{}( condition & this ) { |
---|
| 127 | this.monitors = NULL; |
---|
| 128 | this.monitor_count = 0; |
---|
[5ea06d6] | 129 | } |
---|
[2781e65] | 130 | |
---|
[242a902] | 131 | static inline void ^?{}( condition & this ) { |
---|
| 132 | free( this.monitors ); |
---|
[1167cd4] | 133 | } |
---|
| 134 | |
---|
[8fc45b7] | 135 | void wait ( condition & this, uintptr_t user_info = 0 ); |
---|
| 136 | bool signal ( condition & this ); |
---|
| 137 | bool signal_block( condition & this ); |
---|
| 138 | static inline bool is_empty ( condition & this ) { return !this.blocked.head; } |
---|
| 139 | uintptr_t front ( condition & this ); |
---|
[be3d020] | 140 | |
---|
[97e3296] | 141 | //----------------------------------------------------------------------------- |
---|
| 142 | // External scheduling |
---|
| 143 | |
---|
[c81ebf9] | 144 | struct __acceptable_t { |
---|
[aaa4f93] | 145 | __monitor_group_t; |
---|
[9f5ecf5] | 146 | bool is_dtor; |
---|
[c81ebf9] | 147 | }; |
---|
| 148 | |
---|
[6ae8c92] | 149 | void __waitfor_internal( const __waitfor_mask_t & mask, int duration ); |
---|
[c81ebf9] | 150 | |
---|
[6b0b624] | 151 | // Local Variables: // |
---|
| 152 | // mode: c // |
---|
| 153 | // tab-width: 4 // |
---|
| 154 | // End: // |
---|