[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 |
|
---|
[4cedd9f] | 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 );
|
---|
[be3d020] | 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: //
|
---|