source: libcfa/src/bits/weakso_locks.hfa @ aec68b6

arm-ehjacob/cs343-translationnew-ast-unique-expr
Last change on this file since aec68b6 was 22b7579, checked in by Thierry Delisle <tdelisle@…>, 8 months ago

Changed is_blocking_lock trait to use on_wakeup.
Fixed fast_lock to work with conditions.

  • Property mode set to 100644
File size: 2.6 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2021 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// bits/weakso_locks.hfa -- PUBLIC
8// Runtime locks that are compiled out when used without linking the runtime
9// thread system.
10//
11// Author           : Thierry Delisle
12// Created On       : Thu Jan 21 19:46:50 2021
13// Last Modified By :
14// Last Modified On :
15// Update Count     :
16//
17
18#pragma once
19
20#include "bits/locks.hfa"
21#include "bits/sequence.hfa"
22#include "bits/containers.hfa"
23
24struct $thread;
25
26//-----------------------------------------------------------------------------
27// Blocking Locks
28struct blocking_lock {
29        // Spin lock used for mutual exclusion
30        __spinlock_t lock;
31
32        // List of blocked threads
33        Sequence( $thread ) blocked_threads;
34
35        // Count of current blocked threads
36        size_t wait_count;
37
38        // Flag if the lock allows multiple acquisition
39        bool multi_acquisition;
40
41        // Flag if lock can be released by non owner
42        bool strict_owner;
43
44        // Current thread owning the lock
45        struct $thread * owner;
46
47        // Number of recursion level
48        size_t recursion_count;
49};
50
51void  ?{}( blocking_lock & this, bool multi_acquisition, bool strict_owner ) OPTIONAL_THREAD;
52void ^?{}( blocking_lock & this ) OPTIONAL_THREAD;
53
54void lock( blocking_lock & this ) OPTIONAL_THREAD;
55bool try_lock( blocking_lock & this ) OPTIONAL_THREAD;
56void unlock( blocking_lock & this ) OPTIONAL_THREAD;
57void on_notify( blocking_lock & this, struct $thread * t ) OPTIONAL_THREAD;
58size_t on_wait( blocking_lock & this ) OPTIONAL_THREAD;
59void on_wakeup( blocking_lock & this, size_t ) OPTIONAL_THREAD;
60size_t wait_count( blocking_lock & this ) OPTIONAL_THREAD;
61
62//----------
63struct multiple_acquisition_lock {
64        inline blocking_lock;
65};
66
67
68static inline void  ?{}( multiple_acquisition_lock & this ) {((blocking_lock &)this){ true, false };}
69static inline void ^?{}( multiple_acquisition_lock & this ) {}
70static inline void   lock     ( multiple_acquisition_lock & this ) { lock    ( (blocking_lock &)this ); }
71static inline bool   try_lock ( multiple_acquisition_lock & this ) { return try_lock( (blocking_lock &)this ); }
72static inline void   unlock   ( multiple_acquisition_lock & this ) { unlock  ( (blocking_lock &)this ); }
73static inline size_t on_wait  ( multiple_acquisition_lock & this ) { return on_wait ( (blocking_lock &)this ); }
74static inline void   on_wakeup( multiple_acquisition_lock & this, size_t v ) { on_wakeup ( (blocking_lock &)this, v ); }
75static inline void   on_notify( multiple_acquisition_lock & this, struct $thread * t ){ on_notify( (blocking_lock &)this, t ); }
Note: See TracBrowser for help on using the repository browser.