[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 | |
---|
[549c006] | 41 | // static inline int ?<?(monitor_desc* lhs, monitor_desc* rhs) { |
---|
| 42 | // return ((intptr_t)lhs) < ((intptr_t)rhs); |
---|
| 43 | // } |
---|
| 44 | |
---|
[cc7f4b1] | 45 | struct monitor_guard_t { |
---|
[84c52a8] | 46 | monitor_desc ** m; |
---|
[2781e65] | 47 | int count; |
---|
[4aa2fb2] | 48 | monitor_desc ** prev_mntrs; |
---|
| 49 | unsigned short prev_count; |
---|
[90c4df0] | 50 | fptr_t prev_func; |
---|
[51f3798] | 51 | }; |
---|
| 52 | |
---|
[bf7b9da7] | 53 | void ?{}( monitor_guard_t & this, monitor_desc ** m, int count, void (*func)() ); |
---|
[242a902] | 54 | void ^?{}( monitor_guard_t & this ); |
---|
[51f3798] | 55 | |
---|
[549c006] | 56 | struct monitor_dtor_guard_t { |
---|
| 57 | monitor_desc * m; |
---|
| 58 | monitor_desc ** prev_mntrs; |
---|
| 59 | unsigned short prev_count; |
---|
| 60 | fptr_t prev_func; |
---|
| 61 | }; |
---|
| 62 | |
---|
| 63 | void ?{}( monitor_dtor_guard_t & this, monitor_desc ** m, void (*func)() ); |
---|
| 64 | void ^?{}( monitor_dtor_guard_t & this ); |
---|
| 65 | |
---|
[751d963] | 66 | static inline forall( dtype T | sized(T) | { void ^?{}( T & mutex ); } ) |
---|
| 67 | void delete( T * th ) { |
---|
| 68 | ^(*th){}; |
---|
| 69 | free( th ); |
---|
| 70 | } |
---|
| 71 | |
---|
[5ea06d6] | 72 | //----------------------------------------------------------------------------- |
---|
| 73 | // Internal scheduling |
---|
[0c78741] | 74 | |
---|
| 75 | struct __condition_criterion_t { |
---|
| 76 | bool ready; //Whether or not the criterion is met (True if met) |
---|
| 77 | monitor_desc * target; //The monitor this criterion concerns |
---|
| 78 | struct __condition_node_t * owner; //The parent node to which this criterion belongs |
---|
| 79 | __condition_criterion_t * next; //Intrusive linked list Next field |
---|
| 80 | }; |
---|
| 81 | |
---|
| 82 | struct __condition_node_t { |
---|
| 83 | thread_desc * waiting_thread; //Thread that needs to be woken when all criteria are met |
---|
| 84 | __condition_criterion_t * criteria; //Array of criteria (Criterions are contiguous in memory) |
---|
| 85 | unsigned short count; //Number of criterions in the criteria |
---|
| 86 | __condition_node_t * next; //Intrusive linked list Next field |
---|
[be3d020] | 87 | uintptr_t user_info; //Custom user info accessible before signalling |
---|
[0c78741] | 88 | }; |
---|
| 89 | |
---|
| 90 | struct __condition_blocked_queue_t { |
---|
| 91 | __condition_node_t * head; |
---|
| 92 | __condition_node_t ** tail; |
---|
| 93 | }; |
---|
| 94 | |
---|
[e5c8488] | 95 | void ?{}(__condition_node_t & this, thread_desc * waiting_thread, unsigned short count, uintptr_t user_info ); |
---|
| 96 | void ?{}(__condition_criterion_t & this ); |
---|
| 97 | void ?{}(__condition_criterion_t & this, monitor_desc * target, __condition_node_t * owner ); |
---|
| 98 | |
---|
[242a902] | 99 | void ?{}( __condition_blocked_queue_t & ); |
---|
[0c78741] | 100 | void append( __condition_blocked_queue_t *, __condition_node_t * ); |
---|
| 101 | __condition_node_t * pop_head( __condition_blocked_queue_t * ); |
---|
| 102 | |
---|
[5ea06d6] | 103 | struct condition { |
---|
[0c78741] | 104 | __condition_blocked_queue_t blocked; //Link list which contains the blocked threads as-well as the information needed to unblock them |
---|
| 105 | monitor_desc ** monitors; //Array of monitor pointers (Monitors are NOT contiguous in memory) |
---|
| 106 | unsigned short monitor_count; //Number of monitors in the array |
---|
[5ea06d6] | 107 | }; |
---|
[51f3798] | 108 | |
---|
[242a902] | 109 | static inline void ?{}( condition & this ) { |
---|
| 110 | this.monitors = NULL; |
---|
| 111 | this.monitor_count = 0; |
---|
[5ea06d6] | 112 | } |
---|
[2781e65] | 113 | |
---|
[242a902] | 114 | static inline void ^?{}( condition & this ) { |
---|
| 115 | free( this.monitors ); |
---|
[1167cd4] | 116 | } |
---|
| 117 | |
---|
[be3d020] | 118 | void wait( condition * this, uintptr_t user_info = 0 ); |
---|
| 119 | bool signal( condition * this ); |
---|
| 120 | bool signal_block( condition * this ); |
---|
| 121 | static inline bool is_empty( condition * this ) { return !this->blocked.head; } |
---|
| 122 | uintptr_t front( condition * this ); |
---|
| 123 | |
---|
[97e3296] | 124 | //----------------------------------------------------------------------------- |
---|
| 125 | // External scheduling |
---|
| 126 | |
---|
[c81ebf9] | 127 | struct __acceptable_t { |
---|
[aaa4f93] | 128 | __monitor_group_t; |
---|
[9f5ecf5] | 129 | bool is_dtor; |
---|
[c81ebf9] | 130 | }; |
---|
| 131 | |
---|
[6ae8c92] | 132 | void __waitfor_internal( const __waitfor_mask_t & mask, int duration ); |
---|
[c81ebf9] | 133 | |
---|
[6b0b624] | 134 | // Local Variables: // |
---|
| 135 | // mode: c // |
---|
| 136 | // tab-width: 4 // |
---|
| 137 | // End: // |
---|