rmontanana/BayesNet
rmontanana/BayesNet
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 3 Wiki Activity
convergence_best
BayesNet/html/usr/include/c++/13/mutex.gcov.html

1094 lines
108 KiB
HTML
Raw Permalink Normal View History

Enhance tests coverage and report output
2024-04-30 12:00:24 +00:00
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html lang="en">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>LCOV - coverage.info - usr/include/c++/13/mutex</title>
<link rel="stylesheet" type="text/css" href="../../../../gcov.css">
</head>
<body>
<table width="100%" border=0 cellspacing=0 cellpadding=0>
<tr><td class="title">LCOV - code coverage report</td></tr>
<tr><td class="ruler"><img src="../../../../glass.png" width=3 height=3 alt=""></td></tr>
<tr>
<td width="100%">
<table cellpadding=1 border=0 width="100%">
<tr>
<td width="10%" class="headerItem">Current view:</td>
<td width="10%" class="headerValue"><a href="../../../../index.html">top level</a> - <a href="index.html">/usr/include/c++/13</a> - mutex<span style="font-size: 80%;"> (source / <a href="mutex.func-c.html">functions</a>)</span></td>
<td width="5%"></td>
<td width="5%"></td>
<td width="5%" class="headerCovTableHead">Coverage</td>
<td width="5%" class="headerCovTableHead" title="Covered + Uncovered code">Total</td>
<td width="5%" class="headerCovTableHead" title="Exercised code only">Hit</td>
</tr>
<tr>
<td class="headerItem">Test:</td>
<td class="headerValue">coverage.info</td>
<td></td>
<td class="headerItem">Lines:</td>
<td class="headerCovTableEntryMed">87.5&nbsp;%</td>
<td class="headerCovTableEntry">8</td>
<td class="headerCovTableEntry">7</td>
</tr>
<tr>
<td class="headerItem">Test Date:</td>
<td class="headerValue">2024-04-30 13:17:26</td>
<td></td>
<td class="headerItem">Functions:</td>
<td class="headerCovTableEntryHi">100.0&nbsp;%</td>
<td class="headerCovTableEntry">2</td>
<td class="headerCovTableEntry">2</td>
</tr>
<tr><td><img src="../../../../glass.png" width=3 height=3 alt=""></td></tr>
</table>
</td>
</tr>
<tr><td class="ruler"><img src="../../../../glass.png" width=3 height=3 alt=""></td></tr>
</table>
<table cellpadding=0 cellspacing=0 border=0>
<tr>
<td><br></td>
</tr>
<tr>
<td>
<pre class="sourceHeading"> Line data Source code</pre>
<pre class="source">
<span id="L1"><span class="lineNum"> 1</span> : // &lt;mutex&gt; -*- C++ -*-</span>
<span id="L2"><span class="lineNum"> 2</span> : </span>
<span id="L3"><span class="lineNum"> 3</span> : // Copyright (C) 2003-2023 Free Software Foundation, Inc.</span>
<span id="L4"><span class="lineNum"> 4</span> : //</span>
<span id="L5"><span class="lineNum"> 5</span> : // This file is part of the GNU ISO C++ Library. This library is free</span>
<span id="L6"><span class="lineNum"> 6</span> : // software; you can redistribute it and/or modify it under the</span>
<span id="L7"><span class="lineNum"> 7</span> : // terms of the GNU General Public License as published by the</span>
<span id="L8"><span class="lineNum"> 8</span> : // Free Software Foundation; either version 3, or (at your option)</span>
<span id="L9"><span class="lineNum"> 9</span> : // any later version.</span>
<span id="L10"><span class="lineNum"> 10</span> : </span>
<span id="L11"><span class="lineNum"> 11</span> : // This library is distributed in the hope that it will be useful,</span>
<span id="L12"><span class="lineNum"> 12</span> : // but WITHOUT ANY WARRANTY; without even the implied warranty of</span>
<span id="L13"><span class="lineNum"> 13</span> : // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the</span>
<span id="L14"><span class="lineNum"> 14</span> : // GNU General Public License for more details.</span>
<span id="L15"><span class="lineNum"> 15</span> : </span>
<span id="L16"><span class="lineNum"> 16</span> : // Under Section 7 of GPL version 3, you are granted additional</span>
<span id="L17"><span class="lineNum"> 17</span> : // permissions described in the GCC Runtime Library Exception, version</span>
<span id="L18"><span class="lineNum"> 18</span> : // 3.1, as published by the Free Software Foundation.</span>
<span id="L19"><span class="lineNum"> 19</span> : </span>
<span id="L20"><span class="lineNum"> 20</span> : // You should have received a copy of the GNU General Public License and</span>
<span id="L21"><span class="lineNum"> 21</span> : // a copy of the GCC Runtime Library Exception along with this program;</span>
<span id="L22"><span class="lineNum"> 22</span> : // see the files COPYING3 and COPYING.RUNTIME respectively. If not, see</span>
<span id="L23"><span class="lineNum"> 23</span> : // &lt;http://www.gnu.org/licenses/&gt;.</span>
<span id="L24"><span class="lineNum"> 24</span> : </span>
<span id="L25"><span class="lineNum"> 25</span> : /** @file include/mutex</span>
<span id="L26"><span class="lineNum"> 26</span> : * This is a Standard C++ Library header.</span>
<span id="L27"><span class="lineNum"> 27</span> : */</span>
<span id="L28"><span class="lineNum"> 28</span> : </span>
<span id="L29"><span class="lineNum"> 29</span> : #ifndef _GLIBCXX_MUTEX</span>
<span id="L30"><span class="lineNum"> 30</span> : #define _GLIBCXX_MUTEX 1</span>
<span id="L31"><span class="lineNum"> 31</span> : </span>
<span id="L32"><span class="lineNum"> 32</span> : #pragma GCC system_header</span>
<span id="L33"><span class="lineNum"> 33</span> : </span>
<span id="L34"><span class="lineNum"> 34</span> : #include &lt;bits/requires_hosted.h&gt; // concurrency</span>
<span id="L35"><span class="lineNum"> 35</span> : </span>
<span id="L36"><span class="lineNum"> 36</span> : #if __cplusplus &lt; 201103L</span>
<span id="L37"><span class="lineNum"> 37</span> : # include &lt;bits/c++0x_warning.h&gt;</span>
<span id="L38"><span class="lineNum"> 38</span> : #else</span>
<span id="L39"><span class="lineNum"> 39</span> : </span>
<span id="L40"><span class="lineNum"> 40</span> : #include &lt;tuple&gt;</span>
<span id="L41"><span class="lineNum"> 41</span> : #include &lt;exception&gt;</span>
<span id="L42"><span class="lineNum"> 42</span> : #include &lt;type_traits&gt;</span>
<span id="L43"><span class="lineNum"> 43</span> : #include &lt;bits/chrono.h&gt;</span>
<span id="L44"><span class="lineNum"> 44</span> : #include &lt;bits/error_constants.h&gt;</span>
<span id="L45"><span class="lineNum"> 45</span> : #include &lt;bits/std_mutex.h&gt;</span>
<span id="L46"><span class="lineNum"> 46</span> : #include &lt;bits/unique_lock.h&gt;</span>
<span id="L47"><span class="lineNum"> 47</span> : #if ! _GTHREAD_USE_MUTEX_TIMEDLOCK</span>
<span id="L48"><span class="lineNum"> 48</span> : # include &lt;condition_variable&gt;</span>
<span id="L49"><span class="lineNum"> 49</span> : # include &lt;thread&gt;</span>
<span id="L50"><span class="lineNum"> 50</span> : #endif</span>
<span id="L51"><span class="lineNum"> 51</span> : #include &lt;ext/atomicity.h&gt; // __gnu_cxx::__is_single_threaded</span>
<span id="L52"><span class="lineNum"> 52</span> : </span>
<span id="L53"><span class="lineNum"> 53</span> : #if defined _GLIBCXX_HAS_GTHREADS &amp;&amp; ! defined _GLIBCXX_HAVE_TLS</span>
<span id="L54"><span class="lineNum"> 54</span> : # include &lt;bits/std_function.h&gt; // std::function</span>
<span id="L55"><span class="lineNum"> 55</span> : #endif</span>
<span id="L56"><span class="lineNum"> 56</span> : </span>
<span id="L57"><span class="lineNum"> 57</span> : namespace std _GLIBCXX_VISIBILITY(default)</span>
<span id="L58"><span class="lineNum"> 58</span> : {</span>
<span id="L59"><span class="lineNum"> 59</span> : _GLIBCXX_BEGIN_NAMESPACE_VERSION</span>
<span id="L60"><span class="lineNum"> 60</span> : </span>
<span id="L61"><span class="lineNum"> 61</span> : /**</span>
<span id="L62"><span class="lineNum"> 62</span> : * @addtogroup mutexes</span>
<span id="L63"><span class="lineNum"> 63</span> : * @{</span>
<span id="L64"><span class="lineNum"> 64</span> : */</span>
<span id="L65"><span class="lineNum"> 65</span> : </span>
<span id="L66"><span class="lineNum"> 66</span> : #ifdef _GLIBCXX_HAS_GTHREADS</span>
<span id="L67"><span class="lineNum"> 67</span> : /// @cond undocumented</span>
<span id="L68"><span class="lineNum"> 68</span> : </span>
<span id="L69"><span class="lineNum"> 69</span> : // Common base class for std::recursive_mutex and std::recursive_timed_mutex</span>
<span id="L70"><span class="lineNum"> 70</span> : class __recursive_mutex_base</span>
<span id="L71"><span class="lineNum"> 71</span> : {</span>
<span id="L72"><span class="lineNum"> 72</span> : protected:</span>
<span id="L73"><span class="lineNum"> 73</span> : typedef __gthread_recursive_mutex_t __native_type;</span>
<span id="L74"><span class="lineNum"> 74</span> : </span>
<span id="L75"><span class="lineNum"> 75</span> : __recursive_mutex_base(const __recursive_mutex_base&amp;) = delete;</span>
<span id="L76"><span class="lineNum"> 76</span> : __recursive_mutex_base&amp; operator=(const __recursive_mutex_base&amp;) = delete;</span>
<span id="L77"><span class="lineNum"> 77</span> : </span>
<span id="L78"><span class="lineNum"> 78</span> : #ifdef __GTHREAD_RECURSIVE_MUTEX_INIT</span>
<span id="L79"><span class="lineNum"> 79</span> : __native_type _M_mutex = __GTHREAD_RECURSIVE_MUTEX_INIT;</span>
<span id="L80"><span class="lineNum"> 80</span> : </span>
<span id="L81"><span class="lineNum"> 81</span> : __recursive_mutex_base() = default;</span>
<span id="L82"><span class="lineNum"> 82</span> : #else</span>
<span id="L83"><span class="lineNum"> 83</span> : __native_type _M_mutex;</span>
<span id="L84"><span class="lineNum"> 84</span> : </span>
<span id="L85"><span class="lineNum"> 85</span> : __recursive_mutex_base()</span>
<span id="L86"><span class="lineNum"> 86</span> : {</span>
<span id="L87"><span class="lineNum"> 87</span> : // XXX EAGAIN, ENOMEM, EPERM, EBUSY(may), EINVAL(may)</span>
<span id="L88"><span class="lineNum"> 88</span> : __GTHREAD_RECURSIVE_MUTEX_INIT_FUNCTION(&amp;_M_mutex);</span>
<span id="L89"><span class="lineNum"> 89</span> : }</span>
<span id="L90"><span class="lineNum"> 90</span> : </span>
<span id="L91"><span class="lineNum"> 91</span> : ~__recursive_mutex_base()</span>
<span id="L92"><span class="lineNum"> 92</span> : { __gthread_recursive_mutex_destroy(&amp;_M_mutex); }</span>
<span id="L93"><span class="lineNum"> 93</span> : #endif</span>
<span id="L94"><span class="lineNum"> 94</span> : };</span>
<span id="L95"><span class="lineNum"> 95</span> : /// @endcond</span>
<span id="L96"><span class="lineNum"> 96</span> : </span>
<span id="L97"><span class="lineNum"> 97</span> : /** The standard recursive mutex type.</span>
<span id="L98"><span class="lineNum"> 98</span> : *</span>
<span id="L99"><span class="lineNum"> 99</span> : * A recursive mutex can be locked more than once by the same thread.</span>
<span id="L100"><span class="lineNum"> 100</span> : * Other threads cannot lock the mutex until the owning thread unlocks it</span>
<span id="L101"><span class="lineNum"> 101</span> : * as many times as it was locked.</span>
<span id="L102"><span class="lineNum"> 102</span> : *</span>
<span id="L103"><span class="lineNum"> 103</span> : * @headerfile mutex</span>
<span id="L104"><span class="lineNum"> 104</span> : * @since C++11</span>
<span id="L105"><span class="lineNum"> 105</span> : */</span>
<span id="L106"><span class="lineNum"> 106</span> : class recursive_mutex : private __recursive_mutex_base</span>
<span id="L107"><span class="lineNum"> 107</span> : {</span>
<span id="L108"><span class="lineNum"> 108</span> : public:</span>
<span id="L109"><span class="lineNum"> 109</span> : typedef __native_type* native_handle_type;</span>
<span id="L110"><span class="lineNum"> 110</span> : </span>
<span id="L111"><span class="lineNum"> 111</span> : recursive_mutex() = default;</span>
<span id="L112"><span class="lineNum"> 112</span> : ~recursive_mutex() = default;</span>
<span id="L113"><span class="lineNum"> 113</span> : </span>
<span id="L114"><span class="lineNum"> 114</span> : recursive_mutex(const recursive_mutex&amp;) = delete;</span>
<span id="L115"><span class="lineNum"> 115</span> : recursive_mutex&amp; operator=(const recursive_mutex&amp;) = delete;</span>
<span id="L116"><span class="lineNum"> 116</span> : </span>
<span id="L117"><span class="lineNum"> 117</span> : void</span>
<span id="L118"><span class="lineNum"> 118</span> <span class="tlaGNC tlaBgGNC"> 3564 : lock()</span></span>
<span id="L119"><span class="lineNum"> 119</span> : {</span>
<span id="L120"><span class="lineNum"> 120</span> <span class="tlaGNC"> 3564 : int __e = __gthread_recursive_mutex_lock(&amp;_M_mutex);</span></span>
<span id="L121"><span class="lineNum"> 121</span> : </span>
<span id="L122"><span class="lineNum"> 122</span> : // EINVAL, EAGAIN, EBUSY, EINVAL, EDEADLK(may)</span>
<span id="L123"><span class="lineNum"> 123</span> <span class="tlaGNC"> 3564 : if (__e)</span></span>
<span id="L124"><span class="lineNum"> 124</span> <span class="tlaUNC tlaBgUNC"> 0 : __throw_system_error(__e);</span></span>
<span id="L125"><span class="lineNum"> 125</span> <span class="tlaGNC tlaBgGNC"> 3564 : }</span></span>
<span id="L126"><span class="lineNum"> 126</span> : </span>
<span id="L127"><span class="lineNum"> 127</span> : _GLIBCXX_NODISCARD</span>
<span id="L128"><span class="lineNum"> 128</span> : bool</span>
<span id="L129"><span class="lineNum"> 129</span> : try_lock() noexcept</span>
<span id="L130"><span class="lineNum"> 130</span> : {</span>
<span id="L131"><span class="lineNum"> 131</span> : // XXX EINVAL, EAGAIN, EBUSY</span>
<span id="L132"><span class="lineNum"> 132</span> : return !__gthread_recursive_mutex_trylock(&amp;_M_mutex);</span>
<span id="L133"><span class="lineNum"> 133</span> : }</span>
<span id="L134"><span class="lineNum"> 134</span> : </span>
<span id="L135"><span class="lineNum"> 135</span> : void</span>
<span id="L136"><span class="lineNum"> 136</span> <span class="tlaGNC"> 3564 : unlock()</span></span>
<span id="L137"><span class="lineNum"> 137</span> : {</span>
<span id="L138"><span class="lineNum"> 138</span> : // XXX EINVAL, EAGAIN, EBUSY</span>
<span id="L139"><span class="lineNum"> 139</span> <span class="tlaGNC"> 3564 : __gthread_recursive_mutex_unlock(&amp;_M_mutex);</span></span>
<span id="L140"><span class="lineNum"> 140</span> <span class="tlaGNC"> 3564 : }</span></span>
<span id="L141"><span class="lineNum"> 141</span> : </span>
<span id="L142"><span class="lineNum"> 142</span> : native_handle_type</span>
<span id="L143"><span class="lineNum"> 143</span> : native_handle() noexcept</span>
<span id="L144"><span class="lineNum"> 144</span> : { return &amp;_M_mutex; }</span>
<span id="L145"><span class="lineNum"> 145</span> : };</span>
<span id="L146"><span class="lineNum"> 146</span> : </span>
<span id="L147"><span class="lineNum"> 147</span> : #if _GTHREAD_USE_MUTEX_TIMEDLOCK</span>
<span id="L148"><span class="lineNum"> 148</span> : /// @cond undocumented</span>
<span id="L149"><span class="lineNum"> 149</span> : </span>
<span id="L150"><span class="lineNum"> 150</span> : template&lt;typename _Derived&gt;</span>
<span id="L151"><span class="lineNum"> 151</span> : class __timed_mutex_impl</span>
<span id="L152"><span class="lineNum"> 152</span> : {</span>
<span id="L153"><span class="lineNum"> 153</span> : protected:</span>
<span id="L154"><span class="lineNum"> 154</span> : template&lt;typename _Rep, typename _Period&gt;</span>
<span id="L155"><span class="lineNum"> 155</span> : bool</span>
<span id="L156"><span class="lineNum"> 156</span> : _M_try_lock_for(const chrono::duration&lt;_Rep, _Period&gt;&amp; __rtime)</span>
<span id="L157"><span class="lineNum"> 157</span> : {</span>
<span id="L158"><span class="lineNum"> 158</span> : #if _GLIBCXX_USE_PTHREAD_MUTEX_CLOCKLOCK</span>
<span id="L159"><span class="lineNum"> 159</span> : using __clock = chrono::steady_clock;</span>
<span id="L160"><span class="lineNum"> 160</span> : #else</span>
<span id="L161"><span class="lineNum"> 161</span> : using __clock = chrono::system_clock;</span>
<span id="L162"><span class="lineNum"> 162</span> : #endif</span>
<span id="L163"><span class="lineNum"> 163</span> : </span>
<span id="L164"><span class="lineNum"> 164</span> : auto __rt = chrono::duration_cast&lt;__clock::duration&gt;(__rtime);</span>
<span id="L165"><span class="lineNum"> 165</span> : if (ratio_greater&lt;__clock::period, _Period&gt;())</span>
<span id="L166"><span class="lineNum"> 166</span> : ++__rt;</span>
<span id="L167"><span class="lineNum"> 167</span> : return _M_try_lock_until(__clock::now() + __rt);</span>
<span id="L168"><span class="lineNum"> 168</span> : }</span>
<span id="L169"><span class="lineNum"> 169</span> : </span>
<span id="L170"><span class="lineNum"> 170</span> : template&lt;typename _Duration&gt;</span>
<span id="L171"><span class="lineNum"> 171</span> : bool</span>
<span id="L172"><span class="lineNum"> 172</span> : _M_try_lock_until(const chrono::time_point&lt;chrono::system_clock,</span>
<span id="L173"><span class="lineNum"> 173</span> : _Duration&gt;&amp; __atime)</span>
<span id="L174"><span class="lineNum"> 174</span> : {</span>
<span id="L175"><span class="lineNum"> 175</span> : auto __s = chrono::time_point_cast&lt;chrono::seconds&gt;(__atime);</span>
<span id="L176"><span class="lineNum"> 176</span> : auto __ns = chrono::duration_cast&lt;chrono::nanoseconds&gt;(__atime - __s);</span>
<span id="L177"><span class="lineNum"> 177</span> : </span>
<span id="L178"><span class="lineNum"> 178</span> : __gthread_time_t __ts = {</span>
<span id="L179"><span class="lineNum"> 179</span> : static_cast&lt;std::time_t&gt;(__s.time_since_epoch().count()),</span>
<span id="L180"><span class="lineNum"> 180</span> : static_cast&lt;long&gt;(__ns.count())</span>
<span id="L181"><span class="lineNum"> 181</span> : };</span>
<span id="L182"><span class="lineNum"> 182</span> : </span>
<span id="L183"><span class="lineNum"> 183</span> : return static_cast&lt;_Derived*&gt;(this)-&gt;_M_timedlock(__ts);</span>
<span id="L184"><span class="lineNum"> 184</span> : }</span>
<span id="L185"><span class="lineNum"> 185</span> : </span>
<span id="L186"><span class="lineNum"> 186</span> : #ifdef _GLIBCXX_USE_PTHREAD_MUTEX_CLOCKLOCK</span>
<span id="L187"><span class="lineNum"> 187</span> : template&lt;typename _Duration&gt;</span>
<span id="L188"><span class="lineNum"> 188</span> : bool</span>
<span id="L189"><span class="lineNum"> 189</span> : _M_try_lock_until(const chrono::time_point&lt;chrono::steady_clock,</span>
<span id="L190"><span class="lineNum"> 190</span> : _Duration&gt;&amp; __atime)</span>
<span id="L191"><span class="lineNum"> 191</span> : {</span>
<span id="L192"><span class="lineNum"> 192</span> : auto __s = chrono::time_point_cast&lt;chrono::seconds&gt;(__atime);</span>
<span id="L193"><span class="lineNum"> 193</span> : auto __ns = chrono::duration_cast&lt;chrono::nanoseconds&gt;(__atime - __s);</span>
<span id="L194"><span class="lineNum"> 194</span> : </span>
<span id="L195"><span class="lineNum"> 195</span> : __gthread_time_t __ts = {</span>
<span id="L196"><span class="lineNum"> 196</span> : static_cast&lt;std::time_t&gt;(__s.time_since_epoch().count()),</span>
<span id="L197"><span class="lineNum"> 197</span> : static_cast&lt;long&gt;(__ns.count())</span>
<span id="L198"><span class="lineNum"> 198</span> : };</span>
<span id="L199"><span class="lineNum"> 199</span> : </span>
<span id="L200"><span class="lineNum"> 200</span> : return static_cast&lt;_Derived*&gt;(this)-&gt;_M_clocklock(CLOCK_MONOTONIC,</span>
<span id="L201"><span class="lineNum"> 201</span> : __ts);</span>
<span id="L202"><span class="lineNum"> 202</span> : }</span>
<span id="L203"><span class="lineNum"> 203</span> : #endif</span>
<span id="L204"><span class="lineNum"> 204</span> : </span>
<span id="L205"><span class="lineNum"> 205</span> : template&lt;typename _Clock, typename _Duration&gt;</span>
<span id="L206"><span class="lineNum"> 206</span> : bool</span>
<span id="L207"><span class="lineNum"> 207</span> : _M_try_lock_until(const chrono::time_point&lt;_Clock, _Duration&gt;&amp; __atime)</span>
<span id="L208"><span class="lineNum"> 208</span> : {</span>
<span id="L209"><span class="lineNum"> 209</span> : #if __cplusplus &gt; 201703L</span>
<span id="L210"><span class="lineNum"> 210</span> : static_assert(chrono::is_clock_v&lt;_Clock&gt;);</span>
<span id="L211"><span class="lineNum"> 211</span> : #endif</span>
<span id="L212"><span class="lineNum"> 212</span> : // The user-supplied clock may not tick at the same rate as</span>
<span id="L213"><span class="lineNum"> 213</span> : // steady_clock, so we must loop in order to guarantee that</span>
<span id="L214"><span class="lineNum"> 214</span> : // the timeout has expired before returning false.</span>
<span id="L215"><span class="lineNum"> 215</span> : auto __now = _Clock::now();</span>
<span id="L216"><span class="lineNum"> 216</span> : do {</span>
<span id="L217"><span class="lineNum"> 217</span> : auto __rtime = __atime - __now;</span>
<span id="L218"><span class="lineNum"> 218</span> : if (_M_try_lock_for(__rtime))</span>
<span id="L219"><span class="lineNum"> 219</span> : return true;</span>
<span id="L220"><span class="lineNum"> 220</span> : __now = _Clock::now();</span>
<span id="L221"><span class="lineNum"> 221</span> : } while (__atime &gt; __now);</span>
<span id="L222"><span class="lineNum"> 222</span> : return false;</span>
<span id="L223"><span class="lineNum"> 223</span> : }</span>
<span id="L224"><span class="lineNum"> 224</span> : };</span>
<span id="L225"><span class="lineNum"> 225</span> : /// @endcond</span>
<span id="L226"><span class="lineNum"> 226</span> : </span>
<span id="L227"><span class="lineNum"> 227</span> : /** The standard timed mutex type.</span>
<span id="L228"><span class="lineNum"> 228</span> : *</span>
<span id="L229"><span class="lineNum"> 229</span> : * A non-recursive mutex that supports a timeout when trying to acquire the</span>
<span id="L230"><span class="lineNum"> 230</span> : * lock.</span>
<span id="L231"><span class="lineNum"> 231</span> : *</span>
<span id="L232"><span class="lineNum"> 232</span> : * @headerfile mutex</span>
<span id="L233"><span class="lineNum"> 233</span> : * @since C++11</span>
<span id="L234"><span class="lineNum"> 234</span> : */</span>
<span id="L235"><span class="lineNum"> 235</span> : class timed_mutex</span>
<span id="L236"><span class="lineNum"> 236</span> : : private __mutex_base, public __timed_mutex_impl&lt;timed_mutex&gt;</span>
<span id="L237"><span class="lineNum"> 237</span> : {</span>
<span id="L238"><span class="lineNum"> 238</span> : public:</span>
<span id="L239"><span class="lineNum"> 239</span> : typedef __native_type* native_handle_type;</span>
<span id="L240"><span class="lineNum"> 240</span> : </span>
<span id="L241"><span class="lineNum"> 241</span> : timed_mutex() = default;</span>
<span id="L242"><span class="lineNum"> 242</span> : ~timed_mutex() = default;</span>
<span id="L243"><span class="lineNum"> 243</span> : </span>
<span id="L244"><span class="lineNum"> 244</span> : timed_mutex(const timed_mutex&amp;) = delete;</span>
<span id="L245"><span class="lineNum"> 245</span> : timed_mutex&amp; operator=(const timed_mutex&amp;) = delete;</span>
<span id="L246"><span class="lineNum"> 246</span> : </span>
<span id="L247"><span class="lineNum"> 247</span> : void</span>
<span id="L248"><span class="lineNum"> 248</span> : lock()</span>
<span id="L249"><span class="lineNum"> 249</span> : {</span>
<span id="L250"><span class="lineNum"> 250</span> : int __e = __gthread_mutex_lock(&amp;_M_mutex);</span>
<span id="L251"><span class="lineNum"> 251</span> : </span>
<span id="L252"><span class="lineNum"> 252</span> : // EINVAL, EAGAIN, EBUSY, EINVAL, EDEADLK(may)</span>
<span id="L253"><span class="lineNum"> 253</span> : if (__e)</span>
<span id="L254"><span class="lineNum"> 254</span> : __throw_system_error(__e);</span>
<span id="L255"><span class="lineNum"> 255</span> : }</span>
<span id="L256"><span class="lineNum"> 256</span> : </span>
<span id="L257"><span class="lineNum"> 257</span> : _GLIBCXX_NODISCARD</span>
<span id="L258"><span class="lineNum"> 258</span> : bool</span>
<span id="L259"><span class="lineNum"> 259</span> : try_lock() noexcept</span>
<span id="L260"><span class="lineNum"> 260</span> : {</span>
<span id="L261"><span class="lineNum"> 261</span> : // XXX EINVAL, EAGAIN, EBUSY</span>
<span id="L262"><span class="lineNum"> 262</span> : return !__gthread_mutex_trylock(&amp;_M_mutex);</span>
<span id="L263"><span class="lineNum"> 263</span> : }</span>
<span id="L264"><span class="lineNum"> 264</span> : </span>
<span id="L265"><span class="lineNum"> 265</span> : template &lt;class _Rep, class _Period&gt;</span>
<span id="L266"><span class="lineNum"> 266</span> : _GLIBCXX_NODISCARD</span>
<span id="L267"><span class="lineNum"> 267</span> : bool</span>
<span id="L268"><span class="lineNum"> 268</span> : try_lock_for(const chrono::duration&lt;_Rep, _Period&gt;&amp; __rtime)</span>
<span id="L269"><span class="lineNum"> 269</span> : { return _M_try_lock_for(__rtime); }</span>
<span id="L270"><span class="lineNum"> 270</span> : </span>
<span id="L271"><span class="lineNum"> 271</span> : template &lt;class _Clock, class _Duration&gt;</span>
<span id="L272"><span class="lineNum"> 272</span> : _GLIBCXX_NODISCARD</span>
<span id="L273"><span class="lineNum"> 273</span> : bool</span>
<span id="L274"><span class="lineNum"> 274</span> : try_lock_until(const chrono::time_point&lt;_Clock, _Duration&gt;&amp; __atime)</span>
<span id="L275"><span class="lineNum"> 275</span> : { return _M_try_lock_until(__atime); }</span>
<span id="L276"><span class="lineNum"> 276</span> : </span>
<span id="L277"><span class="lineNum"> 277</span> : void</span>
<span id="L278"><span class="lineNum"> 278</span> : unlock()</span>
<span id="L279"><span class="lineNum"> 279</span> : {</span>
<span id="L280"><span class="lineNum"> 280</span> : // XXX EINVAL, EAGAIN, EBUSY</span>
<span id="L281"><span class="lineNum"> 281</span> : __gthread_mutex_unlock(&amp;_M_mutex);</span>
<span id="L282"><span class="lineNum"> 282</span> : }</span>
<span id="L283"><span class="lineNum"> 283</span> : </span>
<span id="L284"><span class="lineNum"> 284</span> : native_handle_type</span>
<span id="L285"><span class="lineNum"> 285</span> : native_handle() noexcept</span>
<span id="L286"><span class="lineNum"> 286</span> : { return &amp;_M_mutex; }</span>
<span id="L287"><span class="lineNum"> 287</span> : </span>
<span id="L288"><span class="lineNum"> 288</span> : private:</span>
<span id="L289"><span class="lineNum"> 289</span> : friend class __timed_mutex_impl&lt;timed_mutex&gt;;</span>
<span id="L290"><span class="lineNum"> 290</span> : </span>
<span id="L291"><span class="lineNum"> 291</span> : bool</span>
<span id="L292"><span class="lineNum"> 292</span> : _M_timedlock(const __gthread_time_t&amp; __ts)</span>
<span id="L293"><span class="lineNum"> 293</span> : { return !__gthread_mutex_timedlock(&amp;_M_mutex, &amp;__ts); }</span>
<span id="L294"><span class="lineNum"> 294</span> : </span>
<span id="L295"><span class="lineNum"> 295</span> : #if _GLIBCXX_USE_PTHREAD_MUTEX_CLOCKLOCK</span>
<span id="L296"><span class="lineNum"> 296</span> : bool</span>
<span id="L297"><span class="lineNum"> 297</span> : _M_clocklock(clockid_t __clockid, const __gthread_time_t&amp; __ts)</span>
<span id="L298"><span class="lineNum"> 298</span> : { return !pthread_mutex_clocklock(&amp;_M_mutex, __clockid, &amp;__ts); }</span>
<span id="L299"><span class="lineNum"> 299</span> : #endif</span>
<span id="L300"><span class="lineNum"> 300</span> : };</span>
<span id="L301"><span class="lineNum"> 301</span> : </span>
<span id="L302"><span class="lineNum"> 302</span> : /** The standard recursive timed mutex type.</span>
<span id="L303"><span class="lineNum"> 303</span> : *</span>
<span id="L304"><span class="lineNum"> 304</span> : * A recursive mutex that supports a timeout when trying to acquire the</span>
<span id="L305"><span class="lineNum"> 305</span> : * lock. A recursive mutex can be locked more than once by the same thread.</span>
<span id="L306"><span class="lineNum"> 306</span> : * Other threads cannot lock the mutex until the owning thread unlocks it</span>
<span id="L307"><span class="lineNum"> 307</span> : * as many times as it was locked.</span>
<span id="L308"><span class="lineNum"> 308</span> : *</span>
<span id="L309"><span class="lineNum"> 309</span> : * @headerfile mutex</span>
<span id="L310"><span class="lineNum"> 310</span> : * @since C++11</span>
<span id="L311"><span class="lineNum"> 311</span> : */</span>
<span id="L312"><span class="lineNum"> 312</span> : class recursive_timed_mutex</span>
<span id="L313"><span class="lineNum"> 313</span> : : private __recursive_mutex_base,</span>
<span id="L314"><span class="lineNum"> 314</span> : public __timed_mutex_impl&lt;recursive_timed_mutex&gt;</span>
<span id="L315"><span class="lineNum"> 315</span> : {</span>
<span id="L316"><span class="lineNum"> 316</span> : public:</span>
<span id="L317"><span class="lineNum"> 317</span> : typedef __native_type* native_handle_type;</span>
<span id="L318"><span class="lineNum"> 318</span> : </span>
<span id="L319"><span class="lineNum"> 319</span> : recursive_timed_mutex() = default;</span>
<span id="L320"><span class="lineNum"> 320</span> : ~recursive_timed_mutex() = default;</span>
<span id="L321"><span class="lineNum"> 321</span> : </span>
<span id="L322"><span class="lineNum"> 322</span> : recursive_timed_mutex(const recursive_timed_mutex&amp;) = delete;</span>
<span id="L323"><span class="lineNum"> 323</span> : recursive_timed_mutex&amp; operator=(const recursive_timed_mutex&amp;) = delete;</span>
<span id="L324"><span class="lineNum"> 324</span> : </span>
<span id="L325"><span class="lineNum"> 325</span> : void</span>
<span id="L326"><span class="lineNum"> 326</span> : lock()</span>
<span id="L327"><span class="lineNum"> 327</span> : {</span>
<span id="L328"><span class="lineNum"> 328</span> : int __e = __gthread_recursive_mutex_lock(&amp;_M_mutex);</span>
<span id="L329"><span class="lineNum"> 329</span> : </span>
<span id="L330"><span class="lineNum"> 330</span> : // EINVAL, EAGAIN, EBUSY, EINVAL, EDEADLK(may)</span>
<span id="L331"><span class="lineNum"> 331</span> : if (__e)</span>
<span id="L332"><span class="lineNum"> 332</span> : __throw_system_error(__e);</span>
<span id="L333"><span class="lineNum"> 333</span> : }</span>
<span id="L334"><span class="lineNum"> 334</span> : </span>
<span id="L335"><span class="lineNum"> 335</span> : _GLIBCXX_NODISCARD</span>
<span id="L336"><span class="lineNum"> 336</span> : bool</span>
<span id="L337"><span class="lineNum"> 337</span> : try_lock() noexcept</span>
<span id="L338"><span class="lineNum"> 338</span> : {</span>
<span id="L339"><span class="lineNum"> 339</span> : // XXX EINVAL, EAGAIN, EBUSY</span>
<span id="L340"><span class="lineNum"> 340</span> : return !__gthread_recursive_mutex_trylock(&amp;_M_mutex);</span>
<span id="L341"><span class="lineNum"> 341</span> : }</span>
<span id="L342"><span class="lineNum"> 342</span> : </span>
<span id="L343"><span class="lineNum"> 343</span> : template &lt;class _Rep, class _Period&gt;</span>
<span id="L344"><span class="lineNum"> 344</span> : _GLIBCXX_NODISCARD</span>
<span id="L345"><span class="lineNum"> 345</span> : bool</span>
<span id="L346"><span class="lineNum"> 346</span> : try_lock_for(const chrono::duration&lt;_Rep, _Period&gt;&amp; __rtime)</span>
<span id="L347"><span class="lineNum"> 347</span> : { return _M_try_lock_for(__rtime); }</span>
<span id="L348"><span class="lineNum"> 348</span> : </span>
<span id="L349"><span class="lineNum"> 349</span> : template &lt;class _Clock, class _Duration&gt;</span>
<span id="L350"><span class="lineNum"> 350</span> : _GLIBCXX_NODISCARD</span>
<span id="L351"><span class="lineNum"> 351</span> : bool</span>
<span id="L352"><span class="lineNum"> 352</span> : try_lock_until(const chrono::time_point&lt;_Clock, _Duration&gt;&amp; __atime)</span>
<span id="L353"><span class="lineNum"> 353</span> : { return _M_try_lock_until(__atime); }</span>
<span id="L354"><span class="lineNum"> 354</span> : </span>
<span id="L355"><span class="lineNum"> 355</span> : void</span>
<span id="L356"><span class="lineNum"> 356</span> : unlock()</span>
<span id="L357"><span class="lineNum"> 357</span> : {</span>
<span id="L358"><span class="lineNum"> 358</span> : // XXX EINVAL, EAGAIN, EBUSY</span>
<span id="L359"><span class="lineNum"> 359</span> : __gthread_recursive_mutex_unlock(&amp;_M_mutex);</span>
<span id="L360"><span class="lineNum"> 360</span> : }</span>
<span id="L361"><span class="lineNum"> 361</span> : </span>
<span id="L362"><span class="lineNum"> 362</span> : native_handle_type</span>
<span id="L363"><span class="lineNum"> 363</span> : native_handle() noexcept</span>
<span id="L364"><span class="lineNum"> 364</span> : { return &amp;_M_mutex; }</span>
<span id="L365"><span class="lineNum"> 365</span> : </span>
<span id="L366"><span class="lineNum"> 366</span> : private:</span>
<span id="L367"><span class="lineNum"> 367</span> : friend class __timed_mutex_impl&lt;recursive_timed_mutex&gt;;</span>
<span id="L368"><span class="lineNum"> 368</span> : </span>
<span id="L369"><span class="lineNum"> 369</span> : bool</span>
<span id="L370"><span class="lineNum"> 370</span> : _M_timedlock(const __gthread_time_t&amp; __ts)</span>
<span id="L371"><span class="lineNum"> 371</span> : { return !__gthread_recursive_mutex_timedlock(&amp;_M_mutex, &amp;__ts); }</span>
<span id="L372"><span class="lineNum"> 372</span> : </span>
<span id="L373"><span class="lineNum"> 373</span> : #ifdef _GLIBCXX_USE_PTHREAD_MUTEX_CLOCKLOCK</span>
<span id="L374"><span class="lineNum"> 374</span> : bool</span>
<span id="L375"><span class="lineNum"> 375</span> : _M_clocklock(clockid_t __clockid, const __gthread_time_t&amp; __ts)</span>
<span id="L376"><span class="lineNum"> 376</span> : { return !pthread_mutex_clocklock(&amp;_M_mutex, __clockid, &amp;__ts); }</span>
<span id="L377"><span class="lineNum"> 377</span> : #endif</span>
<span id="L378"><span class="lineNum"> 378</span> : };</span>
<span id="L379"><span class="lineNum"> 379</span> : </span>
<span id="L380"><span class="lineNum"> 380</span> : #else // !_GTHREAD_USE_MUTEX_TIMEDLOCK</span>
<span id="L381"><span class="lineNum"> 381</span> : </span>
<span id="L382"><span class="lineNum"> 382</span> : /// timed_mutex</span>
<span id="L383"><span class="lineNum"> 383</span> : class timed_mutex</span>
<span id="L384"><span class="lineNum"> 384</span> : {</span>
<span id="L385"><span class="lineNum"> 385</span> : mutex _M_mut;</span>
<span id="L386"><span class="lineNum"> 386</span> : condition_variable _M_cv;</span>
<span id="L387"><span class="lineNum"> 387</span> : bool _M_locked = false;</span>
<span id="L388"><span class="lineNum"> 388</span> : </span>
<span id="L389"><span class="lineNum"> 389</span> : public:</span>
<span id="L390"><span class="lineNum"> 390</span> : </span>
<span id="L391"><span class="lineNum"> 391</span> : timed_mutex() = default;</span>
<span id="L392"><span class="lineNum"> 392</span> : ~timed_mutex() { __glibcxx_assert( !_M_locked ); }</span>
<span id="L393"><span class="lineNum"> 393</span> : </span>
<span id="L394"><span class="lineNum"> 394</span> : timed_mutex(const timed_mutex&amp;) = delete;</span>
<span id="L395"><span class="lineNum"> 395</span> : timed_mutex&amp; operator=(const timed_mutex&amp;) = delete;</span>
<span id="L396"><span class="lineNum"> 396</span> : </span>
<span id="L397"><span class="lineNum"> 397</span> : void</span>
<span id="L398"><span class="lineNum"> 398</span> : lock()</span>
<span id="L399"><span class="lineNum"> 399</span> : {</span>
<span id="L400"><span class="lineNum"> 400</span> : unique_lock&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L401"><span class="lineNum"> 401</span> : _M_cv.wait(__lk, [&amp;]{ return !_M_locked; });</span>
<span id="L402"><span class="lineNum"> 402</span> : _M_locked = true;</span>
<span id="L403"><span class="lineNum"> 403</span> : }</span>
<span id="L404"><span class="lineNum"> 404</span> : </span>
<span id="L405"><span class="lineNum"> 405</span> : _GLIBCXX_NODISCARD</span>
<span id="L406"><span class="lineNum"> 406</span> : bool</span>
<span id="L407"><span class="lineNum"> 407</span> : try_lock()</span>
<span id="L408"><span class="lineNum"> 408</span> : {</span>
<span id="L409"><span class="lineNum"> 409</span> : lock_guard&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L410"><span class="lineNum"> 410</span> : if (_M_locked)</span>
<span id="L411"><span class="lineNum"> 411</span> : return false;</span>
<span id="L412"><span class="lineNum"> 412</span> : _M_locked = true;</span>
<span id="L413"><span class="lineNum"> 413</span> : return true;</span>
<span id="L414"><span class="lineNum"> 414</span> : }</span>
<span id="L415"><span class="lineNum"> 415</span> : </span>
<span id="L416"><span class="lineNum"> 416</span> : template&lt;typename _Rep, typename _Period&gt;</span>
<span id="L417"><span class="lineNum"> 417</span> : _GLIBCXX_NODISCARD</span>
<span id="L418"><span class="lineNum"> 418</span> : bool</span>
<span id="L419"><span class="lineNum"> 419</span> : try_lock_for(const chrono::duration&lt;_Rep, _Period&gt;&amp; __rtime)</span>
<span id="L420"><span class="lineNum"> 420</span> : {</span>
<span id="L421"><span class="lineNum"> 421</span> : unique_lock&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L422"><span class="lineNum"> 422</span> : if (!_M_cv.wait_for(__lk, __rtime, [&amp;]{ return !_M_locked; }))</span>
<span id="L423"><span class="lineNum"> 423</span> : return false;</span>
<span id="L424"><span class="lineNum"> 424</span> : _M_locked = true;</span>
<span id="L425"><span class="lineNum"> 425</span> : return true;</span>
<span id="L426"><span class="lineNum"> 426</span> : }</span>
<span id="L427"><span class="lineNum"> 427</span> : </span>
<span id="L428"><span class="lineNum"> 428</span> : template&lt;typename _Clock, typename _Duration&gt;</span>
<span id="L429"><span class="lineNum"> 429</span> : _GLIBCXX_NODISCARD</span>
<span id="L430"><span class="lineNum"> 430</span> : bool</span>
<span id="L431"><span class="lineNum"> 431</span> : try_lock_until(const chrono::time_point&lt;_Clock, _Duration&gt;&amp; __atime)</span>
<span id="L432"><span class="lineNum"> 432</span> : {</span>
<span id="L433"><span class="lineNum"> 433</span> : unique_lock&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L434"><span class="lineNum"> 434</span> : if (!_M_cv.wait_until(__lk, __atime, [&amp;]{ return !_M_locked; }))</span>
<span id="L435"><span class="lineNum"> 435</span> : return false;</span>
<span id="L436"><span class="lineNum"> 436</span> : _M_locked = true;</span>
<span id="L437"><span class="lineNum"> 437</span> : return true;</span>
<span id="L438"><span class="lineNum"> 438</span> : }</span>
<span id="L439"><span class="lineNum"> 439</span> : </span>
<span id="L440"><span class="lineNum"> 440</span> : void</span>
<span id="L441"><span class="lineNum"> 441</span> : unlock()</span>
<span id="L442"><span class="lineNum"> 442</span> : {</span>
<span id="L443"><span class="lineNum"> 443</span> : lock_guard&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L444"><span class="lineNum"> 444</span> : __glibcxx_assert( _M_locked );</span>
<span id="L445"><span class="lineNum"> 445</span> : _M_locked = false;</span>
<span id="L446"><span class="lineNum"> 446</span> : _M_cv.notify_one();</span>
<span id="L447"><span class="lineNum"> 447</span> : }</span>
<span id="L448"><span class="lineNum"> 448</span> : };</span>
<span id="L449"><span class="lineNum"> 449</span> : </span>
<span id="L450"><span class="lineNum"> 450</span> : /// recursive_timed_mutex</span>
<span id="L451"><span class="lineNum"> 451</span> : class recursive_timed_mutex</span>
<span id="L452"><span class="lineNum"> 452</span> : {</span>
<span id="L453"><span class="lineNum"> 453</span> : mutex _M_mut;</span>
<span id="L454"><span class="lineNum"> 454</span> : condition_variable _M_cv;</span>
<span id="L455"><span class="lineNum"> 455</span> : thread::id _M_owner;</span>
<span id="L456"><span class="lineNum"> 456</span> : unsigned _M_count = 0;</span>
<span id="L457"><span class="lineNum"> 457</span> : </span>
<span id="L458"><span class="lineNum"> 458</span> : // Predicate type that tests whether the current thread can lock a mutex.</span>
<span id="L459"><span class="lineNum"> 459</span> : struct _Can_lock</span>
<span id="L460"><span class="lineNum"> 460</span> : {</span>
<span id="L461"><span class="lineNum"> 461</span> : // Returns true if the mutex is unlocked or is locked by _M_caller.</span>
<span id="L462"><span class="lineNum"> 462</span> : bool</span>
<span id="L463"><span class="lineNum"> 463</span> : operator()() const noexcept</span>
<span id="L464"><span class="lineNum"> 464</span> : { return _M_mx-&gt;_M_count == 0 || _M_mx-&gt;_M_owner == _M_caller; }</span>
<span id="L465"><span class="lineNum"> 465</span> : </span>
<span id="L466"><span class="lineNum"> 466</span> : const recursive_timed_mutex* _M_mx;</span>
<span id="L467"><span class="lineNum"> 467</span> : thread::id _M_caller;</span>
<span id="L468"><span class="lineNum"> 468</span> : };</span>
<span id="L469"><span class="lineNum"> 469</span> : </span>
<span id="L470"><span class="lineNum"> 470</span> : public:</span>
<span id="L471"><span class="lineNum"> 471</span> : </span>
<span id="L472"><span class="lineNum"> 472</span> : recursive_timed_mutex() = default;</span>
<span id="L473"><span class="lineNum"> 473</span> : ~recursive_timed_mutex() { __glibcxx_assert( _M_count == 0 ); }</span>
<span id="L474"><span class="lineNum"> 474</span> : </span>
<span id="L475"><span class="lineNum"> 475</span> : recursive_timed_mutex(const recursive_timed_mutex&amp;) = delete;</span>
<span id="L476"><span class="lineNum"> 476</span> : recursive_timed_mutex&amp; operator=(const recursive_timed_mutex&amp;) = delete;</span>
<span id="L477"><span class="lineNum"> 477</span> : </span>
<span id="L478"><span class="lineNum"> 478</span> : void</span>
<span id="L479"><span class="lineNum"> 479</span> : lock()</span>
<span id="L480"><span class="lineNum"> 480</span> : {</span>
<span id="L481"><span class="lineNum"> 481</span> : auto __id = this_thread::get_id();</span>
<span id="L482"><span class="lineNum"> 482</span> : _Can_lock __can_lock{this, __id};</span>
<span id="L483"><span class="lineNum"> 483</span> : unique_lock&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L484"><span class="lineNum"> 484</span> : _M_cv.wait(__lk, __can_lock);</span>
<span id="L485"><span class="lineNum"> 485</span> : if (_M_count == -1u)</span>
<span id="L486"><span class="lineNum"> 486</span> : __throw_system_error(EAGAIN); // [thread.timedmutex.recursive]/3</span>
<span id="L487"><span class="lineNum"> 487</span> : _M_owner = __id;</span>
<span id="L488"><span class="lineNum"> 488</span> : ++_M_count;</span>
<span id="L489"><span class="lineNum"> 489</span> : }</span>
<span id="L490"><span class="lineNum"> 490</span> : </span>
<span id="L491"><span class="lineNum"> 491</span> : _GLIBCXX_NODISCARD</span>
<span id="L492"><span class="lineNum"> 492</span> : bool</span>
<span id="L493"><span class="lineNum"> 493</span> : try_lock()</span>
<span id="L494"><span class="lineNum"> 494</span> : {</span>
<span id="L495"><span class="lineNum"> 495</span> : auto __id = this_thread::get_id();</span>
<span id="L496"><span class="lineNum"> 496</span> : _Can_lock __can_lock{this, __id};</span>
<span id="L497"><span class="lineNum"> 497</span> : lock_guard&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L498"><span class="lineNum"> 498</span> : if (!__can_lock())</span>
<span id="L499"><span class="lineNum"> 499</span> : return false;</span>
<span id="L500"><span class="lineNum"> 500</span> : if (_M_count == -1u)</span>
<span id="L501"><span class="lineNum"> 501</span> : return false;</span>
<span id="L502"><span class="lineNum"> 502</span> : _M_owner = __id;</span>
<span id="L503"><span class="lineNum"> 503</span> : ++_M_count;</span>
<span id="L504"><span class="lineNum"> 504</span> : return true;</span>
<span id="L505"><span class="lineNum"> 505</span> : }</span>
<span id="L506"><span class="lineNum"> 506</span> : </span>
<span id="L507"><span class="lineNum"> 507</span> : template&lt;typename _Rep, typename _Period&gt;</span>
<span id="L508"><span class="lineNum"> 508</span> : _GLIBCXX_NODISCARD</span>
<span id="L509"><span class="lineNum"> 509</span> : bool</span>
<span id="L510"><span class="lineNum"> 510</span> : try_lock_for(const chrono::duration&lt;_Rep, _Period&gt;&amp; __rtime)</span>
<span id="L511"><span class="lineNum"> 511</span> : {</span>
<span id="L512"><span class="lineNum"> 512</span> : auto __id = this_thread::get_id();</span>
<span id="L513"><span class="lineNum"> 513</span> : _Can_lock __can_lock{this, __id};</span>
<span id="L514"><span class="lineNum"> 514</span> : unique_lock&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L515"><span class="lineNum"> 515</span> : if (!_M_cv.wait_for(__lk, __rtime, __can_lock))</span>
<span id="L516"><span class="lineNum"> 516</span> : return false;</span>
<span id="L517"><span class="lineNum"> 517</span> : if (_M_count == -1u)</span>
<span id="L518"><span class="lineNum"> 518</span> : return false;</span>
<span id="L519"><span class="lineNum"> 519</span> : _M_owner = __id;</span>
<span id="L520"><span class="lineNum"> 520</span> : ++_M_count;</span>
<span id="L521"><span class="lineNum"> 521</span> : return true;</span>
<span id="L522"><span class="lineNum"> 522</span> : }</span>
<span id="L523"><span class="lineNum"> 523</span> : </span>
<span id="L524"><span class="lineNum"> 524</span> : template&lt;typename _Clock, typename _Duration&gt;</span>
<span id="L525"><span class="lineNum"> 525</span> : _GLIBCXX_NODISCARD</span>
<span id="L526"><span class="lineNum"> 526</span> : bool</span>
<span id="L527"><span class="lineNum"> 527</span> : try_lock_until(const chrono::time_point&lt;_Clock, _Duration&gt;&amp; __atime)</span>
<span id="L528"><span class="lineNum"> 528</span> : {</span>
<span id="L529"><span class="lineNum"> 529</span> : auto __id = this_thread::get_id();</span>
<span id="L530"><span class="lineNum"> 530</span> : _Can_lock __can_lock{this, __id};</span>
<span id="L531"><span class="lineNum"> 531</span> : unique_lock&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L532"><span class="lineNum"> 532</span> : if (!_M_cv.wait_until(__lk, __atime, __can_lock))</span>
<span id="L533"><span class="lineNum"> 533</span> : return false;</span>
<span id="L534"><span class="lineNum"> 534</span> : if (_M_count == -1u)</span>
<span id="L535"><span class="lineNum"> 535</span> : return false;</span>
<span id="L536"><span class="lineNum"> 536</span> : _M_owner = __id;</span>
<span id="L537"><span class="lineNum"> 537</span> : ++_M_count;</span>
<span id="L538"><span class="lineNum"> 538</span> : return true;</span>
<span id="L539"><span class="lineNum"> 539</span> : }</span>
<span id="L540"><span class="lineNum"> 540</span> : </span>
<span id="L541"><span class="lineNum"> 541</span> : void</span>
<span id="L542"><span class="lineNum"> 542</span> : unlock()</span>
<span id="L543"><span class="lineNum"> 543</span> : {</span>
<span id="L544"><span class="lineNum"> 544</span> : lock_guard&lt;mutex&gt; __lk(_M_mut);</span>
<span id="L545"><span class="lineNum"> 545</span> : __glibcxx_assert( _M_owner == this_thread::get_id() );</span>
<span id="L546"><span class="lineNum"> 546</span> : __glibcxx_assert( _M_count &gt; 0 );</span>
<span id="L547"><span class="lineNum"> 547</span> : if (--_M_count == 0)</span>
<span id="L548"><span class="lineNum"> 548</span> : {</span>
<span id="L549"><span class="lineNum"> 549</span> : _M_owner = {};</span>
<span id="L550"><span class="lineNum"> 550</span> : _M_cv.notify_one();</span>
<span id="L551"><span class="lineNum"> 551</span> : }</span>
<span id="L552"><span class="lineNum"> 552</span> : }</span>
<span id="L553"><span class="lineNum"> 553</span> : };</span>
<span id="L554"><span class="lineNum"> 554</span> : </span>
<span id="L555"><span class="lineNum"> 555</span> : #endif</span>
<span id="L556"><span class="lineNum"> 556</span> : #endif // _GLIBCXX_HAS_GTHREADS</span>
<span id="L557"><span class="lineNum"> 557</span> : </span>
<span id="L558"><span class="lineNum"> 558</span> : /// @cond undocumented</span>
<span id="L559"><span class="lineNum"> 559</span> : namespace __detail</span>
<span id="L560"><span class="lineNum"> 560</span> : {</span>
<span id="L561"><span class="lineNum"> 561</span> : // Lock the last lockable, after all previous ones are locked.</span>
<span id="L562"><span class="lineNum"> 562</span> : template&lt;typename _Lockable&gt;</span>
<span id="L563"><span class="lineNum"> 563</span> : inline int</span>
<span id="L564"><span class="lineNum"> 564</span> : __try_lock_impl(_Lockable&amp; __l)</span>
<span id="L565"><span class="lineNum"> 565</span> : {</span>
<span id="L566"><span class="lineNum"> 566</span> : if (unique_lock&lt;_Lockable&gt; __lock{__l, try_to_lock})</span>
<span id="L567"><span class="lineNum"> 567</span> : {</span>
<span id="L568"><span class="lineNum"> 568</span> : __lock.release();</span>
<span id="L569"><span class="lineNum"> 569</span> : return -1;</span>
<span id="L570"><span class="lineNum"> 570</span> : }</span>
<span id="L571"><span class="lineNum"> 571</span> : else</span>
<span id="L572"><span class="lineNum"> 572</span> : return 0;</span>
<span id="L573"><span class="lineNum"> 573</span> : }</span>
<span id="L574"><span class="lineNum"> 574</span> : </span>
<span id="L575"><span class="lineNum"> 575</span> : // Lock each lockable in turn.</span>
<span id="L576"><span class="lineNum"> 576</span> : // Use iteration if all lockables are the same type, recursion otherwise.</span>
<span id="L577"><span class="lineNum"> 577</span> : template&lt;typename _L0, typename... _Lockables&gt;</span>
<span id="L578"><span class="lineNum"> 578</span> : inline int</span>
<span id="L579"><span class="lineNum"> 579</span> : __try_lock_impl(_L0&amp; __l0, _Lockables&amp;... __lockables)</span>
<span id="L580"><span class="lineNum"> 580</span> : {</span>
<span id="L581"><span class="lineNum"> 581</span> : #if __cplusplus &gt;= 201703L</span>
<span id="L582"><span class="lineNum"> 582</span> : if constexpr ((is_same_v&lt;_L0, _Lockables&gt; &amp;&amp; ...))</span>
<span id="L583"><span class="lineNum"> 583</span> : {</span>
<span id="L584"><span class="lineNum"> 584</span> : constexpr int _Np = 1 + sizeof...(_Lockables);</span>
<span id="L585"><span class="lineNum"> 585</span> : unique_lock&lt;_L0&gt; __locks[_Np] = {</span>
<span id="L586"><span class="lineNum"> 586</span> : {__l0, defer_lock}, {__lockables, defer_lock}...</span>
<span id="L587"><span class="lineNum"> 587</span> : };</span>
<span id="L588"><span class="lineNum"> 588</span> : for (int __i = 0; __i &lt; _Np; ++__i)</span>
<span id="L589"><span class="lineNum"> 589</span> : {</span>
<span id="L590"><span class="lineNum"> 590</span> : if (!__locks[__i].try_lock())</span>
<span id="L591"><span class="lineNum"> 591</span> : {</span>
<span id="L592"><span class="lineNum"> 592</span> : const int __failed = __i;</span>
<span id="L593"><span class="lineNum"> 593</span> : while (__i--)</span>
<span id="L594"><span class="lineNum"> 594</span> : __locks[__i].unlock();</span>
<span id="L595"><span class="lineNum"> 595</span> : return __failed;</span>
<span id="L596"><span class="lineNum"> 596</span> : }</span>
<span id="L597"><span class="lineNum"> 597</span> : }</span>
<span id="L598"><span class="lineNum"> 598</span> : for (auto&amp; __l : __locks)</span>
<span id="L599"><span class="lineNum"> 599</span> : __l.release();</span>
<span id="L600"><span class="lineNum"> 600</span> : return -1;</span>
<span id="L601"><span class="lineNum"> 601</span> : }</span>
<span id="L602"><span class="lineNum"> 602</span> : else</span>
<span id="L603"><span class="lineNum"> 603</span> : #endif</span>
<span id="L604"><span class="lineNum"> 604</span> : if (unique_lock&lt;_L0&gt; __lock{__l0, try_to_lock})</span>
<span id="L605"><span class="lineNum"> 605</span> : {</span>
<span id="L606"><span class="lineNum"> 606</span> : int __idx = __detail::__try_lock_impl(__lockables...);</span>
<span id="L607"><span class="lineNum"> 607</span> : if (__idx == -1)</span>
<span id="L608"><span class="lineNum"> 608</span> : {</span>
<span id="L609"><span class="lineNum"> 609</span> : __lock.release();</span>
<span id="L610"><span class="lineNum"> 610</span> : return -1;</span>
<span id="L611"><span class="lineNum"> 611</span> : }</span>
<span id="L612"><span class="lineNum"> 612</span> : return __idx + 1;</span>
<span id="L613"><span class="lineNum"> 613</span> : }</span>
<span id="L614"><span class="lineNum"> 614</span> : else</span>
<span id="L615"><span class="lineNum"> 615</span> : return 0;</span>
<span id="L616"><span class="lineNum"> 616</span> : }</span>
<span id="L617"><span class="lineNum"> 617</span> : </span>
<span id="L618"><span class="lineNum"> 618</span> : } // namespace __detail</span>
<span id="L619"><span class="lineNum"> 619</span> : /// @endcond</span>
<span id="L620"><span class="lineNum"> 620</span> : </span>
<span id="L621"><span class="lineNum"> 621</span> : /** @brief Generic try_lock.</span>
<span id="L622"><span class="lineNum"> 622</span> : * @param __l1 Meets Lockable requirements (try_lock() may throw).</span>
<span id="L623"><span class="lineNum"> 623</span> : * @param __l2 Meets Lockable requirements (try_lock() may throw).</span>
<span id="L624"><span class="lineNum"> 624</span> : * @param __l3 Meets Lockable requirements (try_lock() may throw).</span>
<span id="L625"><span class="lineNum"> 625</span> : * @return Returns -1 if all try_lock() calls return true. Otherwise returns</span>
<span id="L626"><span class="lineNum"> 626</span> : * a 0-based index corresponding to the argument that returned false.</span>
<span id="L627"><span class="lineNum"> 627</span> : * @post Either all arguments are locked, or none will be.</span>
<span id="L628"><span class="lineNum"> 628</span> : *</span>
<span id="L629"><span class="lineNum"> 629</span> : * Sequentially calls try_lock() on each argument.</span>
<span id="L630"><span class="lineNum"> 630</span> : */</span>
<span id="L631"><span class="lineNum"> 631</span> : template&lt;typename _L1, typename _L2, typename... _L3&gt;</span>
<span id="L632"><span class="lineNum"> 632</span> : _GLIBCXX_NODISCARD</span>
<span id="L633"><span class="lineNum"> 633</span> : inline int</span>
<span id="L634"><span class="lineNum"> 634</span> : try_lock(_L1&amp; __l1, _L2&amp; __l2, _L3&amp;... __l3)</span>
<span id="L635"><span class="lineNum"> 635</span> : {</span>
<span id="L636"><span class="lineNum"> 636</span> : return __detail::__try_lock_impl(__l1, __l2, __l3...);</span>
<span id="L637"><span class="lineNum"> 637</span> : }</span>
<span id="L638"><span class="lineNum"> 638</span> : </span>
<span id="L639"><span class="lineNum"> 639</span> : /// @cond undocumented</span>
<span id="L640"><span class="lineNum"> 640</span> : namespace __detail</span>
<span id="L641"><span class="lineNum"> 641</span> : {</span>
<span id="L642"><span class="lineNum"> 642</span> : // This function can recurse up to N levels deep, for N = 1+sizeof...(L1).</span>
<span id="L643"><span class="lineNum"> 643</span> : // On each recursion the lockables are rotated left one position,</span>
<span id="L644"><span class="lineNum"> 644</span> : // e.g. depth 0: l0, l1, l2; depth 1: l1, l2, l0; depth 2: l2, l0, l1.</span>
<span id="L645"><span class="lineNum"> 645</span> : // When a call to l_i.try_lock() fails it recurses/returns to depth=i</span>
<span id="L646"><span class="lineNum"> 646</span> : // so that l_i is the first argument, and then blocks until l_i is locked.</span>
<span id="L647"><span class="lineNum"> 647</span> : template&lt;typename _L0, typename... _L1&gt;</span>
<span id="L648"><span class="lineNum"> 648</span> : void</span>
<span id="L649"><span class="lineNum"> 649</span> : __lock_impl(int&amp; __i, int __depth, _L0&amp; __l0, _L1&amp;... __l1)</span>
<span id="L650"><span class="lineNum"> 650</span> : {</span>
<span id="L651"><span class="lineNum"> 651</span> : while (__i &gt;= __depth)</span>
<span id="L652"><span class="lineNum"> 652</span> : {</span>
<span id="L653"><span class="lineNum"> 653</span> : if (__i == __depth)</span>
<span id="L654"><span class="lineNum"> 654</span> : {</span>
<span id="L655"><span class="lineNum"> 655</span> : int __failed = 1; // index that couldn't be locked</span>
<span id="L656"><span class="lineNum"> 656</span> : {</span>
<span id="L657"><span class="lineNum"> 657</span> : unique_lock&lt;_L0&gt; __first(__l0);</span>
<span id="L658"><span class="lineNum"> 658</span> : __failed += __detail::__try_lock_impl(__l1...);</span>
<span id="L659"><span class="lineNum"> 659</span> : if (!__failed)</span>
<span id="L660"><span class="lineNum"> 660</span> : {</span>
<span id="L661"><span class="lineNum"> 661</span> : __i = -1; // finished</span>
<span id="L662"><span class="lineNum"> 662</span> : __first.release();</span>
<span id="L663"><span class="lineNum"> 663</span> : return;</span>
<span id="L664"><span class="lineNum"> 664</span> : }</span>
<span id="L665"><span class="lineNum"> 665</span> : }</span>
<span id="L666"><span class="lineNum"> 666</span> : #if defined _GLIBCXX_HAS_GTHREADS &amp;&amp; defined _GLIBCXX_USE_SCHED_YIELD</span>
<span id="L667"><span class="lineNum"> 667</span> : __gthread_yield();</span>
<span id="L668"><span class="lineNum"> 668</span> : #endif</span>
<span id="L669"><span class="lineNum"> 669</span> : constexpr auto __n = 1 + sizeof...(_L1);</span>
<span id="L670"><span class="lineNum"> 670</span> : __i = (__depth + __failed) % __n;</span>
<span id="L671"><span class="lineNum"> 671</span> : }</span>
<span id="L672"><span class="lineNum"> 672</span> : else // rotate left until l_i is first.</span>
<span id="L673"><span class="lineNum"> 673</span> : __detail::__lock_impl(__i, __depth + 1, __l1..., __l0);</span>
<span id="L674"><span class="lineNum"> 674</span> : }</span>
<span id="L675"><span class="lineNum"> 675</span> : }</span>
<span id="L676"><span class="lineNum"> 676</span> : </span>
<span id="L677"><span class="lineNum"> 677</span> : } // namespace __detail</span>
<span id="L678"><span class="lineNum"> 678</span> : /// @endcond</span>
<span id="L679"><span class="lineNum"> 679</span> : </span>
<span id="L680"><span class="lineNum"> 680</span> : /** @brief Generic lock.</span>
<span id="L681"><span class="lineNum"> 681</span> : * @param __l1 Meets Lockable requirements (try_lock() may throw).</span>
<span id="L682"><span class="lineNum"> 682</span> : * @param __l2 Meets Lockable requirements (try_lock() may throw).</span>
<span id="L683"><span class="lineNum"> 683</span> : * @param __l3 Meets Lockable requirements (try_lock() may throw).</span>
<span id="L684"><span class="lineNum"> 684</span> : * @throw An exception thrown by an argument's lock() or try_lock() member.</span>
<span id="L685"><span class="lineNum"> 685</span> : * @post All arguments are locked.</span>
<span id="L686"><span class="lineNum"> 686</span> : *</span>
<span id="L687"><span class="lineNum"> 687</span> : * All arguments are locked via a sequence of calls to lock(), try_lock()</span>
<span id="L688"><span class="lineNum"> 688</span> : * and unlock(). If this function exits via an exception any locks that</span>
<span id="L689"><span class="lineNum"> 689</span> : * were obtained will be released.</span>
<span id="L690"><span class="lineNum"> 690</span> : */</span>
<span id="L691"><span class="lineNum"> 691</span> : template&lt;typename _L1, typename _L2, typename... _L3&gt;</span>
<span id="L692"><span class="lineNum"> 692</span> : void</span>
<span id="L693"><span class="lineNum"> 693</span> : lock(_L1&amp; __l1, _L2&amp; __l2, _L3&amp;... __l3)</span>
<span id="L694"><span class="lineNum"> 694</span> : {</span>
<span id="L695"><span class="lineNum"> 695</span> : #if __cplusplus &gt;= 201703L</span>
<span id="L696"><span class="lineNum"> 696</span> : if constexpr (is_same_v&lt;_L1, _L2&gt; &amp;&amp; (is_same_v&lt;_L1, _L3&gt; &amp;&amp; ...))</span>
<span id="L697"><span class="lineNum"> 697</span> : {</span>
<span id="L698"><span class="lineNum"> 698</span> : constexpr int _Np = 2 + sizeof...(_L3);</span>
<span id="L699"><span class="lineNum"> 699</span> : unique_lock&lt;_L1&gt; __locks[] = {</span>
<span id="L700"><span class="lineNum"> 700</span> : {__l1, defer_lock}, {__l2, defer_lock}, {__l3, defer_lock}...</span>
<span id="L701"><span class="lineNum"> 701</span> : };</span>
<span id="L702"><span class="lineNum"> 702</span> : int __first = 0;</span>
<span id="L703"><span class="lineNum"> 703</span> : do {</span>
<span id="L704"><span class="lineNum"> 704</span> : __locks[__first].lock();</span>
<span id="L705"><span class="lineNum"> 705</span> : for (int __j = 1; __j &lt; _Np; ++__j)</span>
<span id="L706"><span class="lineNum"> 706</span> : {</span>
<span id="L707"><span class="lineNum"> 707</span> : const int __idx = (__first + __j) % _Np;</span>
<span id="L708"><span class="lineNum"> 708</span> : if (!__locks[__idx].try_lock())</span>
<span id="L709"><span class="lineNum"> 709</span> : {</span>
<span id="L710"><span class="lineNum"> 710</span> : for (int __k = __j; __k != 0; --__k)</span>
<span id="L711"><span class="lineNum"> 711</span> : __locks[(__first + __k - 1) % _Np].unlock();</span>
<span id="L712"><span class="lineNum"> 712</span> : __first = __idx;</span>
<span id="L713"><span class="lineNum"> 713</span> : break;</span>
<span id="L714"><span class="lineNum"> 714</span> : }</span>
<span id="L715"><span class="lineNum"> 715</span> : }</span>
<span id="L716"><span class="lineNum"> 716</span> : } while (!__locks[__first].owns_lock());</span>
<span id="L717"><span class="lineNum"> 717</span> : </span>
<span id="L718"><span class="lineNum"> 718</span> : for (auto&amp; __l : __locks)</span>
<span id="L719"><span class="lineNum"> 719</span> : __l.release();</span>
<span id="L720"><span class="lineNum"> 720</span> : }</span>
<span id="L721"><span class="lineNum"> 721</span> : else</span>
<span id="L722"><span class="lineNum"> 722</span> : #endif</span>
<span id="L723"><span class="lineNum"> 723</span> : {</span>
<span id="L724"><span class="lineNum"> 724</span> : int __i = 0;</span>
<span id="L725"><span class="lineNum"> 725</span> : __detail::__lock_impl(__i, 0, __l1, __l2, __l3...);</span>
<span id="L726"><span class="lineNum"> 726</span> : }</span>
<span id="L727"><span class="lineNum"> 727</span> : }</span>
<span id="L728"><span class="lineNum"> 728</span> : </span>
<span id="L729"><span class="lineNum"> 729</span> : #if __cplusplus &gt;= 201703L</span>
<span id="L730"><span class="lineNum"> 730</span> : #define __cpp_lib_scoped_lock 201703L</span>
<span id="L731"><span class="lineNum"> 731</span> : /** @brief A scoped lock type for multiple lockable objects.</span>
<span id="L732"><span class="lineNum"> 732</span> : *</span>
<span id="L733"><span class="lineNum"> 733</span> : * A scoped_lock controls mutex ownership within a scope, releasing</span>
<span id="L734"><span class="lineNum"> 734</span> : * ownership in the destructor.</span>
<span id="L735"><span class="lineNum"> 735</span> : *</span>
<span id="L736"><span class="lineNum"> 736</span> : * @headerfile mutex</span>
<span id="L737"><span class="lineNum"> 737</span> : * @since C++17</span>
<span id="L738"><span class="lineNum"> 738</span> : */</span>
<span id="L739"><span class="lineNum"> 739</span> : template&lt;typename... _MutexTypes&gt;</span>
<span id="L740"><span class="lineNum"> 740</span> : class scoped_lock</span>
<span id="L741"><span class="lineNum"> 741</span> : {</span>
<span id="L742"><span class="lineNum"> 742</span> : public:</span>
<span id="L743"><span class="lineNum"> 743</span> : explicit scoped_lock(_MutexTypes&amp;... __m) : _M_devices(std::tie(__m...))</span>
<span id="L744"><span class="lineNum"> 744</span> : { std::lock(__m...); }</span>
<span id="L745"><span class="lineNum"> 745</span> : </span>
<span id="L746"><span class="lineNum"> 746</span> : explicit scoped_lock(adopt_lock_t, _MutexTypes&amp;... __m) noexcept</span>
<span id="L747"><span class="lineNum"> 747</span> : : _M_devices(std::tie(__m...))</span>
<span id="L748"><span class="lineNum"> 748</span> : { } // calling thread owns mutex</span>
<span id="L749"><span class="lineNum"> 749</span> : </span>
<span id="L750"><span class="lineNum"> 750</span> : ~scoped_lock()</span>
<span id="L751"><span class="lineNum"> 751</span> : { std::apply([](auto&amp;... __m) { (__m.unlock(), ...); }, _M_devices); }</span>
<span id="L752"><span class="lineNum"> 752</span> : </span>
<span id="L753"><span class="lineNum"> 753</span> : scoped_lock(const scoped_lock&amp;) = delete;</span>
<span id="L754"><span class="lineNum"> 754</span> : scoped_lock&amp; operator=(const scoped_lock&amp;) = delete;</span>
<span id="L755"><span class="lineNum"> 755</span> : </span>
<span id="L756"><span class="lineNum"> 756</span> : private:</span>
<span id="L757"><span class="lineNum"> 757</span> : tuple&lt;_MutexTypes&amp;...&gt; _M_devices;</span>
<span id="L758"><span class="lineNum"> 758</span> : };</span>
<span id="L759"><span class="lineNum"> 759</span> : </span>
<span id="L760"><span class="lineNum"> 760</span> : template&lt;&gt;</span>
<span id="L761"><span class="lineNum"> 761</span> : class scoped_lock&lt;&gt;</span>
<span id="L762"><span class="lineNum"> 762</span> : {</span>
<span id="L763"><span class="lineNum"> 763</span> : public:</span>
<span id="L764"><span class="lineNum"> 764</span> : explicit scoped_lock() = default;</span>
<span id="L765"><span class="lineNum"> 765</span> : explicit scoped_lock(adopt_lock_t) noexcept { }</span>
<span id="L766"><span class="lineNum"> 766</span> : ~scoped_lock() = default;</span>
<span id="L767"><span class="lineNum"> 767</span> : </span>
<span id="L768"><span class="lineNum"> 768</span> : scoped_lock(const scoped_lock&amp;) = delete;</span>
<span id="L769"><span class="lineNum"> 769</span> : scoped_lock&amp; operator=(const scoped_lock&amp;) = delete;</span>
<span id="L770"><span class="lineNum"> 770</span> : };</span>
<span id="L771"><span class="lineNum"> 771</span> : </span>
<span id="L772"><span class="lineNum"> 772</span> : template&lt;typename _Mutex&gt;</span>
<span id="L773"><span class="lineNum"> 773</span> : class scoped_lock&lt;_Mutex&gt;</span>
<span id="L774"><span class="lineNum"> 774</span> : {</span>
<span id="L775"><span class="lineNum"> 775</span> : public:</span>
<span id="L776"><span class="lineNum"> 776</span> : using mutex_type = _Mutex;</span>
<span id="L777"><span class="lineNum"> 777</span> : </span>
<span id="L778"><span class="lineNum"> 778</span> : explicit scoped_lock(mutex_type&amp; __m) : _M_device(__m)</span>
<span id="L779"><span class="lineNum"> 779</span> : { _M_device.lock(); }</span>
<span id="L780"><span class="lineNum"> 780</span> : </span>
<span id="L781"><span class="lineNum"> 781</span> : explicit scoped_lock(adopt_lock_t, mutex_type&amp; __m) noexcept</span>
<span id="L782"><span class="lineNum"> 782</span> : : _M_device(__m)</span>
<span id="L783"><span class="lineNum"> 783</span> : { } // calling thread owns mutex</span>
<span id="L784"><span class="lineNum"> 784</span> : </span>
<span id="L785"><span class="lineNum"> 785</span> : ~scoped_lock()</span>
<span id="L786"><span class="lineNum"> 786</span> : { _M_device.unlock(); }</span>
<span id="L787"><span class="lineNum"> 787</span> : </span>
<span id="L788"><span class="lineNum"> 788</span> : scoped_lock(const scoped_lock&amp;) = delete;</span>
<span id="L789"><span class="lineNum"> 789</span> : scoped_lock&amp; operator=(const scoped_lock&amp;) = delete;</span>
<span id="L790"><span class="lineNum"> 790</span> : </span>
<span id="L791"><span class="lineNum"> 791</span> : private:</span>
<span id="L792"><span class="lineNum"> 792</span> : mutex_type&amp; _M_device;</span>
<span id="L793"><span class="lineNum"> 793</span> : };</span>
<span id="L794"><span class="lineNum"> 794</span> : #endif // C++17</span>
<span id="L795"><span class="lineNum"> 795</span> : </span>
<span id="L796"><span class="lineNum"> 796</span> : #ifdef _GLIBCXX_HAS_GTHREADS</span>
<span id="L797"><span class="lineNum"> 797</span> : /// Flag type used by std::call_once</span>
<span id="L798"><span class="lineNum"> 798</span> : struct once_flag</span>
<span id="L799"><span class="lineNum"> 799</span> : {</span>
<span id="L800"><span class="lineNum"> 800</span> : constexpr once_flag() noexcept = default;</span>
<span id="L801"><span class="lineNum"> 801</span> : </span>
<span id="L802"><span class="lineNum"> 802</span> : /// Deleted copy constructor</span>
<span id="L803"><span class="lineNum"> 803</span> : once_flag(const once_flag&amp;) = delete;</span>
<span id="L804"><span class="lineNum"> 804</span> : /// Deleted assignment operator</span>
<span id="L805"><span class="lineNum"> 805</span> : once_flag&amp; operator=(const once_flag&amp;) = delete;</span>
<span id="L806"><span class="lineNum"> 806</span> : </span>
<span id="L807"><span class="lineNum"> 807</span> : private:</span>
<span id="L808"><span class="lineNum"> 808</span> : // For gthreads targets a pthread_once_t is used with pthread_once, but</span>
<span id="L809"><span class="lineNum"> 809</span> : // for most targets this doesn't work correctly for exceptional executions.</span>
<span id="L810"><span class="lineNum"> 810</span> : __gthread_once_t _M_once = __GTHREAD_ONCE_INIT;</span>
<span id="L811"><span class="lineNum"> 811</span> : </span>
<span id="L812"><span class="lineNum"> 812</span> : struct _Prepare_execution;</span>
<span id="L813"><span class="lineNum"> 813</span> : </span>
<span id="L814"><span class="lineNum"> 814</span> : template&lt;typename _Callable, typename... _Args&gt;</span>
<span id="L815"><span class="lineNum"> 815</span> : friend void</span>
<span id="L816"><span class="lineNum"> 816</span> : call_once(once_flag&amp; __once, _Callable&amp;&amp; __f, _Args&amp;&amp;... __args);</span>
<span id="L817"><span class="lineNum"> 817</span> : };</span>
<span id="L818"><span class="lineNum"> 818</span> : </span>
<span id="L819"><span class="lineNum"> 819</span> : /// @cond undocumented</span>
<span id="L820"><span class="lineNum"> 820</span> : # ifdef _GLIBCXX_HAVE_TLS</span>
<span id="L821"><span class="lineNum"> 821</span> : // If TLS is available use thread-local state for the type-erased callable</span>
<span id="L822"><span class="lineNum"> 822</span> : // that is being run by std::call_once in the current thread.</span>
<span id="L823"><span class="lineNum"> 823</span> : extern __thread void* __once_callable;</span>
<span id="L824"><span class="lineNum"> 824</span> : extern __thread void (*__once_call)();</span>
<span id="L825"><span class="lineNum"> 825</span> : </span>
<span id="L826"><span class="lineNum"> 826</span> : // RAII type to set up state for pthread_once call.</span>
<span id="L827"><span class="lineNum"> 827</span> : struct once_flag::_Prepare_execution</span>
<span id="L828"><span class="lineNum"> 828</span> : {</span>
<span id="L829"><span class="lineNum"> 829</span> : template&lt;typename _Callable&gt;</span>
<span id="L830"><span class="lineNum"> 830</span> : explicit</span>
<span id="L831"><span class="lineNum"> 831</span> : _Prepare_execution(_Callable&amp; __c)</span>
<span id="L832"><span class="lineNum"> 832</span> : {</span>
<span id="L833"><span class="lineNum"> 833</span> : // Store address in thread-local pointer:</span>
<span id="L834"><span class="lineNum"> 834</span> : __once_callable = std::__addressof(__c);</span>
<span id="L835"><span class="lineNum"> 835</span> : // Trampoline function to invoke the closure via thread-local pointer:</span>
<span id="L836"><span class="lineNum"> 836</span> : __once_call = [] { (*static_cast&lt;_Callable*&gt;(__once_callable))(); };</span>
<span id="L837"><span class="lineNum"> 837</span> : }</span>
<span id="L838"><span class="lineNum"> 838</span> : </span>
<span id="L839"><span class="lineNum"> 839</span> : ~_Prepare_execution()</span>
<span id="L840"><span class="lineNum"> 840</span> : {</span>
<span id="L841"><span class="lineNum"> 841</span> : // PR libstdc++/82481</span>
<span id="L842"><span class="lineNum"> 842</span> : __once_callable = nullptr;</span>
<span id="L843"><span class="lineNum"> 843</span> : __once_call = nullptr;</span>
<span id="L844"><span class="lineNum"> 844</span> : }</span>
<span id="L845"><span class="lineNum"> 845</span> : </span>
<span id="L846"><span class="lineNum"> 846</span> : _Prepare_execution(const _Prepare_execution&amp;) = delete;</span>
<span id="L847"><span class="lineNum"> 847</span> : _Prepare_execution&amp; operator=(const _Prepare_execution&amp;) = delete;</span>
<span id="L848"><span class="lineNum"> 848</span> : };</span>
<span id="L849"><span class="lineNum"> 849</span> : </span>
<span id="L850"><span class="lineNum"> 850</span> : # else</span>
<span id="L851"><span class="lineNum"> 851</span> : // Without TLS use a global std::mutex and store the callable in a</span>
<span id="L852"><span class="lineNum"> 852</span> : // global std::function.</span>
<span id="L853"><span class="lineNum"> 853</span> : extern function&lt;void()&gt; __once_functor;</span>
<span id="L854"><span class="lineNum"> 854</span> : </span>
<span id="L855"><span class="lineNum"> 855</span> : extern void</span>
<span id="L856"><span class="lineNum"> 856</span> : __set_once_functor_lock_ptr(unique_lock&lt;mutex&gt;*);</span>
<span id="L857"><span class="lineNum"> 857</span> : </span>
<span id="L858"><span class="lineNum"> 858</span> : extern mutex&amp;</span>
<span id="L859"><span class="lineNum"> 859</span> : __get_once_mutex();</span>
<span id="L860"><span class="lineNum"> 860</span> : </span>
<span id="L861"><span class="lineNum"> 861</span> : // RAII type to set up state for pthread_once call.</span>
<span id="L862"><span class="lineNum"> 862</span> : struct once_flag::_Prepare_execution</span>
<span id="L863"><span class="lineNum"> 863</span> : {</span>
<span id="L864"><span class="lineNum"> 864</span> : template&lt;typename _Callable&gt;</span>
<span id="L865"><span class="lineNum"> 865</span> : explicit</span>
<span id="L866"><span class="lineNum"> 866</span> : _Prepare_execution(_Callable&amp; __c)</span>
<span id="L867"><span class="lineNum"> 867</span> : {</span>
<span id="L868"><span class="lineNum"> 868</span> : // Store the callable in the global std::function</span>
<span id="L869"><span class="lineNum"> 869</span> : __once_functor = __c;</span>
<span id="L870"><span class="lineNum"> 870</span> : __set_once_functor_lock_ptr(&amp;_M_functor_lock);</span>
<span id="L871"><span class="lineNum"> 871</span> : }</span>
<span id="L872"><span class="lineNum"> 872</span> : </span>
<span id="L873"><span class="lineNum"> 873</span> : ~_Prepare_execution()</span>
<span id="L874"><span class="lineNum"> 874</span> : {</span>
<span id="L875"><span class="lineNum"> 875</span> : if (_M_functor_lock)</span>
<span id="L876"><span class="lineNum"> 876</span> : __set_once_functor_lock_ptr(nullptr);</span>
<span id="L877"><span class="lineNum"> 877</span> : }</span>
<span id="L878"><span class="lineNum"> 878</span> : </span>
<span id="L879"><span class="lineNum"> 879</span> : private:</span>
<span id="L880"><span class="lineNum"> 880</span> : // XXX This deadlocks if used recursively (PR 97949)</span>
<span id="L881"><span class="lineNum"> 881</span> : unique_lock&lt;mutex&gt; _M_functor_lock{__get_once_mutex()};</span>
<span id="L882"><span class="lineNum"> 882</span> : </span>
<span id="L883"><span class="lineNum"> 883</span> : _Prepare_execution(const _Prepare_execution&amp;) = delete;</span>
<span id="L884"><span class="lineNum"> 884</span> : _Prepare_execution&amp; operator=(const _Prepare_execution&amp;) = delete;</span>
<span id="L885"><span class="lineNum"> 885</span> : };</span>
<span id="L886"><span class="lineNum"> 886</span> : # endif</span>
<span id="L887"><span class="lineNum"> 887</span> : /// @endcond</span>
<span id="L888"><span class="lineNum"> 888</span> : </span>
<span id="L889"><span class="lineNum"> 889</span> : // This function is passed to pthread_once by std::call_once.</span>
<span id="L890"><span class="lineNum"> 890</span> : // It runs __once_call() or __once_functor().</span>
<span id="L891"><span class="lineNum"> 891</span> : extern &quot;C&quot; void __once_proxy(void);</span>
<span id="L892"><span class="lineNum"> 892</span> : </span>
<span id="L893"><span class="lineNum"> 893</span> : /// Invoke a callable and synchronize with other calls using the same flag</span>
<span id="L894"><span class="lineNum"> 894</span> : template&lt;typename _Callable, typename... _Args&gt;</span>
<span id="L895"><span class="lineNum"> 895</span> : void</span>
<span id="L896"><span class="lineNum"> 896</span> : call_once(once_flag&amp; __once, _Callable&amp;&amp; __f, _Args&amp;&amp;... __args)</span>
<span id="L897"><span class="lineNum"> 897</span> : {</span>
<span id="L898"><span class="lineNum"> 898</span> : // Closure type that runs the function</span>
<span id="L899"><span class="lineNum"> 899</span> : auto __callable = [&amp;] {</span>
<span id="L900"><span class="lineNum"> 900</span> : std::__invoke(std::forward&lt;_Callable&gt;(__f),</span>
<span id="L901"><span class="lineNum"> 901</span> : std::forward&lt;_Args&gt;(__args)...);</span>
<span id="L902"><span class="lineNum"> 902</span> : };</span>
<span id="L903"><span class="lineNum"> 903</span> : </span>
<span id="L904"><span class="lineNum"> 904</span> : once_flag::_Prepare_execution __exec(__callable);</span>
<span id="L905"><span class="lineNum"> 905</span> : </span>
<span id="L906"><span class="lineNum"> 906</span> : // XXX pthread_once does not reset the flag if an exception is thrown.</span>
<span id="L907"><span class="lineNum"> 907</span> : if (int __e = __gthread_once(&amp;__once._M_once, &amp;__once_proxy))</span>
<span id="L908"><span class="lineNum"> 908</span> : __throw_system_error(__e);</span>
<span id="L909"><span class="lineNum"> 909</span> : }</span>
<span id="L910"><span class="lineNum"> 910</span> : </span>
<span id="L911"><span class="lineNum"> 911</span> : #else // _GLIBCXX_HAS_GTHREADS</span>
<span id="L912"><span class="lineNum"> 912</span> : </span>
<span id="L913"><span class="lineNum"> 913</span> : /// Flag type used by std::call_once</span>
<span id="L914"><span class="lineNum"> 914</span> : struct once_flag</span>
<span id="L915"><span class="lineNum"> 915</span> : {</span>
<span id="L916"><span class="lineNum"> 916</span> : constexpr once_flag() noexcept = default;</span>
<span id="L917"><span class="lineNum"> 917</span> : </span>
<span id="L918"><span class="lineNum"> 918</span> : /// Deleted copy constructor</span>
<span id="L919"><span class="lineNum"> 919</span> : once_flag(const once_flag&amp;) = delete;</span>
<span id="L920"><span class="lineNum"> 920</span> : /// Deleted assignment operator</span>
<span id="L921"><span class="lineNum"> 921</span> : once_flag&amp; operator=(const once_flag&amp;) = delete;</span>
<span id="L922"><span class="lineNum"> 922</span> : </span>
<span id="L923"><span class="lineNum"> 923</span> : private:</span>
<span id="L924"><span class="lineNum"> 924</span> : // There are two different std::once_flag interfaces, abstracting four</span>
<span id="L925"><span class="lineNum"> 925</span> : // different implementations.</span>
<span id="L926"><span class="lineNum"> 926</span> : // The single-threaded interface uses the _M_activate() and _M_finish(bool)</span>
<span id="L927"><span class="lineNum"> 927</span> : // functions, which start and finish an active execution respectively.</span>
<span id="L928"><span class="lineNum"> 928</span> : // See [thread.once.callonce] in C++11 for the definition of</span>
<span id="L929"><span class="lineNum"> 929</span> : // active/passive/returning/exceptional executions.</span>
<span id="L930"><span class="lineNum"> 930</span> : enum _Bits : int { _Init = 0, _Active = 1, _Done = 2 };</span>
<span id="L931"><span class="lineNum"> 931</span> : </span>
<span id="L932"><span class="lineNum"> 932</span> : int _M_once = _Bits::_Init;</span>
<span id="L933"><span class="lineNum"> 933</span> : </span>
<span id="L934"><span class="lineNum"> 934</span> : // Check to see if all executions will be passive now.</span>
<span id="L935"><span class="lineNum"> 935</span> : bool</span>
<span id="L936"><span class="lineNum"> 936</span> : _M_passive() const noexcept;</span>
<span id="L937"><span class="lineNum"> 937</span> : </span>
<span id="L938"><span class="lineNum"> 938</span> : // Attempts to begin an active execution.</span>
<span id="L939"><span class="lineNum"> 939</span> : bool _M_activate();</span>
<span id="L940"><span class="lineNum"> 940</span> : </span>
<span id="L941"><span class="lineNum"> 941</span> : // Must be called to complete an active execution.</span>
<span id="L942"><span class="lineNum"> 942</span> : // The argument is true if the active execution was a returning execution,</span>
<span id="L943"><span class="lineNum"> 943</span> : // false if it was an exceptional execution.</span>
<span id="L944"><span class="lineNum"> 944</span> : void _M_finish(bool __returning) noexcept;</span>
<span id="L945"><span class="lineNum"> 945</span> : </span>
<span id="L946"><span class="lineNum"> 946</span> : // RAII helper to call _M_finish.</span>
<span id="L947"><span class="lineNum"> 947</span> : struct _Active_execution</span>
<span id="L948"><span class="lineNum"> 948</span> : {</span>
<span id="L949"><span class="lineNum"> 949</span> : explicit _Active_execution(once_flag&amp; __flag) : _M_flag(__flag) { }</span>
<span id="L950"><span class="lineNum"> 950</span> : </span>
<span id="L951"><span class="lineNum"> 951</span> : ~_Active_execution() { _M_flag._M_finish(_M_returning); }</span>
<span id="L952"><span class="lineNum"> 952</span> : </span>
<span id="L953"><span class="lineNum"> 953</span> : _Active_execution(const _Active_execution&amp;) = delete;</span>
<span id="L954"><span class="lineNum"> 954</span> : _Active_execution&amp; operator=(const _Active_execution&amp;) = delete;</span>
<span id="L955"><span class="lineNum"> 955</span> : </span>
<span id="L956"><span class="lineNum"> 956</span> : once_flag&amp; _M_flag;</span>
<span id="L957"><span class="lineNum"> 957</span> : bool _M_returning = false;</span>
<span id="L958"><span class="lineNum"> 958</span> : };</span>
<span id="L959"><span class="lineNum"> 959</span> : </span>
<span id="L960"><span class="lineNum"> 960</span> : template&lt;typename _Callable, typename... _Args&gt;</span>
<span id="L961"><span class="lineNum"> 961</span> : friend void</span>
<span id="L962"><span class="lineNum"> 962</span> : call_once(once_flag&amp; __once, _Callable&amp;&amp; __f, _Args&amp;&amp;... __args);</span>
<span id="L963"><span class="lineNum"> 963</span> : };</span>
<span id="L964"><span class="lineNum"> 964</span> : </span>
<span id="L965"><span class="lineNum"> 965</span> : // Inline definitions of std::once_flag members for single-threaded targets.</span>
<span id="L966"><span class="lineNum"> 966</span> : </span>
<span id="L967"><span class="lineNum"> 967</span> : inline bool</span>
<span id="L968"><span class="lineNum"> 968</span> : once_flag::_M_passive() const noexcept</span>
<span id="L969"><span class="lineNum"> 969</span> : { return _M_once == _Bits::_Done; }</span>
<span id="L970"><span class="lineNum"> 970</span> : </span>
<span id="L971"><span class="lineNum"> 971</span> : inline bool</span>
<span id="L972"><span class="lineNum"> 972</span> : once_flag::_M_activate()</span>
<span id="L973"><span class="lineNum"> 973</span> : {</span>
<span id="L974"><span class="lineNum"> 974</span> : if (_M_once == _Bits::_Init) [[__likely__]]</span>
<span id="L975"><span class="lineNum"> 975</span> : {</span>
<span id="L976"><span class="lineNum"> 976</span> : _M_once = _Bits::_Active;</span>
<span id="L977"><span class="lineNum"> 977</span> : return true;</span>
<span id="L978"><span class="lineNum"> 978</span> : }</span>
<span id="L979"><span class="lineNum"> 979</span> : else if (_M_passive()) // Caller should have checked this already.</span>
<span id="L980"><span class="lineNum"> 980</span> : return false;</span>
<span id="L981"><span class="lineNum"> 981</span> : else</span>
<span id="L982"><span class="lineNum"> 982</span> : __throw_system_error(EDEADLK);</span>
<span id="L983"><span class="lineNum"> 983</span> : }</span>
<span id="L984"><span class="lineNum"> 984</span> : </span>
<span id="L985"><span class="lineNum"> 985</span> : inline void</span>
<span id="L986"><span class="lineNum"> 986</span> : once_flag::_M_finish(bool __returning) noexcept</span>
<span id="L987"><span class="lineNum"> 987</span> : { _M_once = __returning ? _Bits::_Done : _Bits::_Init; }</span>
<span id="L988"><span class="lineNum"> 988</span> : </span>
<span id="L989"><span class="lineNum"> 989</span> : /// Invoke a callable and synchronize with other calls using the same flag</span>
<span id="L990"><span class="lineNum"> 990</span> : template&lt;typename _Callable, typename... _Args&gt;</span>
<span id="L991"><span class="lineNum"> 991</span> : inline void</span>
<span id="L992"><span class="lineNum"> 992</span> : call_once(once_flag&amp; __once, _Callable&amp;&amp; __f, _Args&amp;&amp;... __args)</span>
<span id="L993"><span class="lineNum"> 993</span> : {</span>
<span id="L994"><span class="lineNum"> 994</span> : if (__once._M_passive())</span>
<span id="L995"><span class="lineNum"> 995</span> : return;</span>
<span id="L996"><span class="lineNum"> 996</span> : else if (__once._M_activate())</span>
<span id="L997"><span class="lineNum"> 997</span> : {</span>
<span id="L998"><span class="lineNum"> 998</span> : once_flag::_Active_execution __exec(__once);</span>
<span id="L999"><span class="lineNum"> 999</span> : </span>
<span id="L1000"><span class="lineNum"> 1000</span> : // _GLIBCXX_RESOLVE_LIB_DEFECTS</span>
<span id="L1001"><span class="lineNum"> 1001</span> : // 2442. call_once() shouldn't DECAY_COPY()</span>
<span id="L1002"><span class="lineNum"> 1002</span> : std::__invoke(std::forward&lt;_Callable&gt;(__f),</span>
<span id="L1003"><span class="lineNum"> 1003</span> : std::forward&lt;_Args&gt;(__args)...);</span>
<span id="L1004"><span class="lineNum"> 1004</span> : </span>
<span id="L1005"><span class="lineNum"> 1005</span> : // __f(__args...) did not throw</span>
<span id="L1006"><span class="lineNum"> 1006</span> : __exec._M_returning = true;</span>
<span id="L1007"><span class="lineNum"> 1007</span> : }</span>
<span id="L1008"><span class="lineNum"> 1008</span> : }</span>
<span id="L1009"><span class="lineNum"> 1009</span> : #endif // _GLIBCXX_HAS_GTHREADS</span>
<span id="L1010"><span class="lineNum"> 1010</span> : </span>
<span id="L1011"><span class="lineNum"> 1011</span> : /// @} group mutexes</span>
<span id="L1012"><span class="lineNum"> 1012</span> : _GLIBCXX_END_NAMESPACE_VERSION</span>
<span id="L1013"><span class="lineNum"> 1013</span> : } // namespace</span>
<span id="L1014"><span class="lineNum"> 1014</span> : </span>
<span id="L1015"><span class="lineNum"> 1015</span> : #endif // C++11</span>
<span id="L1016"><span class="lineNum"> 1016</span> : </span>
<span id="L1017"><span class="lineNum"> 1017</span> : #endif // _GLIBCXX_MUTEX</span>
</pre>
</td>
</tr>
</table>
<br>
<table width="100%" border=0 cellspacing=0 cellpadding=0>
<tr><td class="ruler"><img src="../../../../glass.png" width=3 height=3 alt=""></td></tr>
<tr><td class="versionInfo">Generated by: <a href="https://github.com//linux-test-project/lcov" target="_parent">LCOV version 2.0-1</a></td></tr>
</table>
<br>
</body>
</html>
Reference in New Issue Copy Permalink