source: src/libcfa/concurrency/monitor @ 9f5ecf5

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 9f5ecf5 was 9f5ecf5, checked in by Thierry Delisle <tdelisle@…>, 7 years ago

Skeleton for waitfor language support

  • Property mode set to 100644
File size: 3.3 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 Jul 22 09:59:01 2017
13// Update Count     : 3
14//
15
16#pragma once
17
18#include <stddef.h>
19
20#include <assert.h>
21#include "invoke.h"
22#include "stdlib"
23
24static inline void ?{}(monitor_desc & this) {
25        (this.lock){};
26        this.owner = NULL;
27        (this.entry_queue){};
28        (this.signal_stack){};
29        this.recursion = 0;
30        this.acceptables = NULL;
31        this.acceptable_count = 0;
32        this.accepted_index = -1;
33}
34
35struct monitor_guard_t {
36        monitor_desc ** m;
37        int count;
38        monitor_desc ** prev_mntrs;
39        unsigned short  prev_count;
40        fptr_t          prev_func;
41};
42
43static inline int ?<?(monitor_desc* lhs, monitor_desc* rhs) {
44        return ((intptr_t)lhs) < ((intptr_t)rhs);
45}
46
47void ?{}( monitor_guard_t & this, monitor_desc ** m, int count, void (*func)() );
48void ^?{}( monitor_guard_t & this );
49
50//-----------------------------------------------------------------------------
51// Internal scheduling
52
53struct __condition_criterion_t {
54        bool ready;                                             //Whether or not the criterion is met (True if met)
55        monitor_desc * target;                          //The monitor this criterion concerns
56        struct __condition_node_t * owner;              //The parent node to which this criterion belongs
57        __condition_criterion_t * next;         //Intrusive linked list Next field
58};
59
60struct __condition_node_t {
61        thread_desc * waiting_thread;                   //Thread that needs to be woken when all criteria are met
62        __condition_criterion_t * criteria;     //Array of criteria (Criterions are contiguous in memory)
63        unsigned short count;                           //Number of criterions in the criteria
64        __condition_node_t * next;                      //Intrusive linked list Next field
65        uintptr_t user_info;                            //Custom user info accessible before signalling
66};
67
68struct __condition_blocked_queue_t {
69        __condition_node_t * head;
70        __condition_node_t ** tail;
71};
72
73void ?{}( __condition_blocked_queue_t & );
74void append( __condition_blocked_queue_t *, __condition_node_t * );
75__condition_node_t * pop_head( __condition_blocked_queue_t * );
76
77struct condition {
78        __condition_blocked_queue_t blocked;    //Link list which contains the blocked threads as-well as the information needed to unblock them
79        monitor_desc ** monitors;                       //Array of monitor pointers (Monitors are NOT contiguous in memory)
80        unsigned short monitor_count;                   //Number of monitors in the array
81};
82
83static inline void ?{}( condition & this ) {
84        this.monitors = NULL;
85        this.monitor_count = 0;
86}
87
88static inline void ^?{}( condition & this ) {
89        free( this.monitors );
90}
91
92void wait( condition * this, uintptr_t user_info = 0 );
93bool signal( condition * this );
94bool signal_block( condition * this );
95static inline bool is_empty( condition * this ) { return !this->blocked.head; }
96uintptr_t front( condition * this );
97
98//-----------------------------------------------------------------------------
99// External scheduling
100
101struct __acceptable_t {
102        fptr_t func;
103        unsigned short count;
104        monitor_desc ** monitors;
105        bool is_dtor;
106};
107
108int __accept_internal( unsigned short count, __acceptable_t * acceptables );
109
110// Local Variables: //
111// mode: c //
112// tab-width: 4 //
113// End: //
Note: See TracBrowser for help on using the repository browser.