source: mainline/uspace/lib/cpp/src/mutex.cpp@ 9283830

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since 9283830 was 9283830, checked in by Dzejrou <dzejrou@…>, 7 years ago

cpp: added a threading middle layer

  • Property mode set to 100644
File size: 3.0 KB
Line 
1/*
2 * Copyright (c) 2018 Jaroslav Jindrak
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29#include <mutex>
30
31namespace std
32{
33 mutex::~mutex()
34 { /* DUMMY BODY */ }
35
36 void mutex::lock()
37 {
38 aux::threading::mutex::lock(mtx_);
39 }
40
41 bool mutex::try_lock()
42 {
43 return aux::threading::mutex::try_lock(mtx_);
44 }
45
46 void mutex::unlock()
47 {
48 aux::threading::mutex::unlock(mtx_);
49 }
50
51 mutex::native_handle_type mutex::native_handle()
52 {
53 return &mtx_;
54 }
55
56 constexpr recursive_mutex::recursive_mutex() noexcept
57 : mtx_{}, lock_level_{}, owner_{}
58 {
59 aux::threading::mutex::init(mtx_);
60 }
61
62 recursive_mutex::~recursive_mutex()
63 { /* DUMMY BODY */ }
64
65 void recursive_mutex::lock()
66 {
67 if (owner_ != this_thread::get_id())
68 {
69 aux::threading::mutex::lock(mtx_);
70 owner_ = this_thread::get_id();
71 lock_level_ = 1;
72 }
73 else
74 ++lock_level_;
75 }
76
77 bool recursive_mutex::try_lock()
78 {
79 if (owner_ != this_thread::get_id())
80 {
81 bool res = aux::threading::mutex::try_lock(mtx_);
82 if (res)
83 {
84 owner_ = this_thread::get_id();
85 lock_level_ = 1;
86 }
87
88 return res;
89 }
90 else
91 ++lock_level_;
92
93 return true;
94 }
95
96 void recursive_mutex::unlock()
97 {
98 if (owner_ != this_thread::get_id())
99 return;
100 else if (--lock_level_ == 0)
101 aux::threading::mutex::unlock(mtx_);
102 }
103
104 recursive_mutex::native_handle_type recursive_mutex::native_handle()
105 {
106 return &mtx_;
107 }
108}
Note: See TracBrowser for help on using the repository browser.