1 //===----------------------------------------------------------------------===//
2 //
3 // The LLVM Compiler Infrastructure
4 //
5 // This file is dual licensed under the MIT and the University of Illinois Open
6 // Source Licenses. See LICENSE.TXT for details.
7 //
8 //===----------------------------------------------------------------------===//
9
10 // Copyright (C) 2011 Vicente J. Botet Escriba
11 //
12 // Distributed under the Boost Software License, Version 1.0. (See accompanying
13 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
14
15 // <boost/thread/locks.hpp>
16
17 // template <class Mutex> class upgrade_lock;
18
19 // template <class Clock, class Duration>
20 // upgrade_lock(mutex_type& m, const chrono::time_point<Clock, Duration>& abs_time);
21
22 #define BOOST_THREAD_PROVIDES_GENERIC_SHARED_MUTEX_ON_WIN
23
24 #include <boost/thread/lock_types.hpp>
25 #include <boost/thread/shared_mutex.hpp>
26 #include <boost/thread/thread.hpp>
27 #include <boost/detail/lightweight_test.hpp>
28 #include "../../../../../timming.hpp"
29
30 boost::shared_mutex m;
31
32 typedef boost::chrono::high_resolution_clock Clock;
33 typedef Clock::time_point time_point;
34 typedef Clock::duration duration;
35 typedef boost::chrono::milliseconds ms;
36 typedef boost::chrono::nanoseconds ns;
37 time_point t0;
38 time_point t1;
39
40 const ms max_diff(BOOST_THREAD_TEST_TIME_MS);
41
f1()42 void f1()
43 {
44 t0 = Clock::now();
45 boost::upgrade_lock<boost::shared_mutex> lk(m, Clock::now() + ms(750));
46 BOOST_TEST(lk.owns_lock() == true);
47 t1 = Clock::now();
48 }
49
f2()50 void f2()
51 {
52 t0 = Clock::now();
53 boost::upgrade_lock<boost::shared_mutex> lk(m, Clock::now() + ms(250));
54 BOOST_TEST(lk.owns_lock() == false);
55 t1 = Clock::now();
56 ns d = t1 - t0 - ms(250);
57 BOOST_THREAD_TEST_IT(d, ns(max_diff));
58 }
59
main()60 int main()
61 {
62 {
63 m.lock();
64 boost::thread t(f1);
65 time_point t2 = Clock::now();
66 boost::this_thread::sleep_for(ms(250));
67 time_point t3 = Clock::now();
68 m.unlock();
69 t.join();
70
71 ns sleep_time = t3 - t2;
72 ns d_ns = t1 - t0 - sleep_time;
73 ms d_ms = boost::chrono::duration_cast<boost::chrono::milliseconds>(d_ns);
74 // BOOST_TEST_GE(d_ms.count(), 0);
75 BOOST_THREAD_TEST_IT(d_ms, max_diff);
76 BOOST_THREAD_TEST_IT(d_ns, ns(max_diff));
77 }
78 {
79 m.lock();
80 boost::thread t(f2);
81 boost::this_thread::sleep_for(ms(750));
82 m.unlock();
83 t.join();
84 }
85
86 return boost::report_errors();
87 }
88
89