source: libcfa/src/bits/weakso_locks.hfa

Last change on this file was e84ab3d, checked in by Thierry Delisle <tdelisle@…>, 5 months ago

Step 1 of changing $thread to thread$

  • 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#include "containers/list.hfa"
24
25struct thread$;
26
27//-----------------------------------------------------------------------------
28// Blocking Locks
29struct blocking_lock {
30        // Spin lock used for mutual exclusion
31        __spinlock_t lock;
32
33        // List of blocked threads
34        dlist( thread$ ) blocked_threads;
35
36        // Count of current blocked threads
37        size_t wait_count;
38
39        // Flag if the lock allows multiple acquisition
40        bool multi_acquisition;
41
42        // Flag if lock can be released by non owner
43        bool strict_owner;
44
45        // Current thread owning the lock
46        struct thread$ * owner;
47
48        // Number of recursion level
49        size_t recursion_count;
50};
51
52void  ?{}( blocking_lock & this, bool multi_acquisition, bool strict_owner ) OPTIONAL_THREAD;
53void ^?{}( blocking_lock & this ) OPTIONAL_THREAD;
54
55void lock( blocking_lock & this ) OPTIONAL_THREAD;
56bool try_lock( blocking_lock & this ) OPTIONAL_THREAD;
57void unlock( blocking_lock & this ) OPTIONAL_THREAD;
58void on_notify( blocking_lock & this, struct thread$ * t ) OPTIONAL_THREAD;
59size_t on_wait( blocking_lock & this ) OPTIONAL_THREAD;
60void on_wakeup( blocking_lock & this, size_t ) OPTIONAL_THREAD;
61size_t wait_count( blocking_lock & this ) OPTIONAL_THREAD;
62
63//----------
64struct multiple_acquisition_lock {
65        inline blocking_lock;
66};
67
68
69static inline void  ?{}( multiple_acquisition_lock & this ) {((blocking_lock &)this){ true, false };}
70static inline void ^?{}( multiple_acquisition_lock & this ) {}
71static inline void   lock     ( multiple_acquisition_lock & this ) { lock    ( (blocking_lock &)this ); }
72static inline bool   try_lock ( multiple_acquisition_lock & this ) { return try_lock( (blocking_lock &)this ); }
73static inline void   unlock   ( multiple_acquisition_lock & this ) { unlock  ( (blocking_lock &)this ); }
74static inline size_t on_wait  ( multiple_acquisition_lock & this ) { return on_wait ( (blocking_lock &)this ); }
75static inline void   on_wakeup( multiple_acquisition_lock & this, size_t v ) { on_wakeup ( (blocking_lock &)this, v ); }
76static 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.