123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259 |
- // (C) Copyright 2006-7 Anthony Williams
- // Distributed under the Boost Software License, Version 1.0. (See
- // accompanying file LICENSE_1_0.txt or copy at
- // http://www.boost.org/LICENSE_1_0.txt)
- #define BOOST_THREAD_VERSION 2
- #define BOOST_TEST_MODULE Boost.Threads: shared_mutex_locks_chrono test suite
- #include <boost/test/unit_test.hpp>
- #include <boost/thread/thread.hpp>
- #include <boost/thread/shared_mutex.hpp>
- #include "./util.inl"
- #include "./shared_mutex_locking_thread.hpp"
- #if defined BOOST_THREAD_USES_CHRONO
- #define CHECK_LOCKED_VALUE_EQUAL(mutex_name,value,expected_value) \
- { \
- boost::unique_lock<boost::mutex> lock(mutex_name); \
- BOOST_CHECK_EQUAL(value,expected_value); \
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_shared_times_out_if_write_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- unsigned unblocked_count=0;
- boost::unique_lock<boost::mutex> finish_lock(finish_mutex);
- boost::thread writer(simple_writing_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
- boost::this_thread::sleep_for(boost::chrono::seconds(1));
- CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- boost::chrono::milliseconds const timeout_resolution(50);
- bool timed_lock_succeeded=rw_mutex.try_lock_shared_until(timeout);
- BOOST_CHECK((timeout-timeout_resolution)<boost::chrono::steady_clock::now());
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- boost::chrono::milliseconds const wait_duration(500);
- boost::chrono::steady_clock::time_point const timeout2=boost::chrono::steady_clock::now()+wait_duration;
- timed_lock_succeeded=rw_mutex.try_lock_shared_for(wait_duration);
- BOOST_CHECK((timeout2-timeout_resolution)<boost::chrono::steady_clock::now());
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- finish_lock.unlock();
- writer.join();
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_shared_succeeds_if_no_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- bool timed_lock_succeeded=rw_mutex.try_lock_shared_until(timeout);
- BOOST_CHECK(boost::chrono::steady_clock::now()<timeout);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- boost::chrono::milliseconds const wait_duration(500);
- boost::chrono::steady_clock::time_point const timeout2=boost::chrono::steady_clock::now()+wait_duration;
- timed_lock_succeeded=rw_mutex.try_lock_shared_for(wait_duration);
- BOOST_CHECK(boost::chrono::steady_clock::now()<timeout2);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_shared_succeeds_if_read_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- unsigned unblocked_count=0;
- boost::unique_lock<boost::mutex> finish_lock(finish_mutex);
- boost::thread reader(simple_reading_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
- boost::this_thread::sleep_for(boost::chrono::seconds(1));
- CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- bool timed_lock_succeeded=rw_mutex.try_lock_shared_until(timeout);
- BOOST_CHECK(boost::chrono::steady_clock::now()<timeout);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- boost::chrono::milliseconds const wait_duration(500);
- boost::chrono::steady_clock::time_point const timeout2=boost::chrono::steady_clock::now()+wait_duration;
- timed_lock_succeeded=rw_mutex.try_lock_shared_for(wait_duration);
- BOOST_CHECK(boost::chrono::steady_clock::now()<timeout2);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- finish_lock.unlock();
- reader.join();
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_times_out_if_write_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- unsigned unblocked_count=0;
- boost::unique_lock<boost::mutex> finish_lock(finish_mutex);
- boost::thread writer(simple_writing_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
- boost::this_thread::sleep_for(boost::chrono::seconds(1));
- CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- boost::chrono::milliseconds const timeout_resolution(50);
- bool timed_lock_succeeded=rw_mutex.try_lock_until(timeout);
- BOOST_CHECK((timeout-timeout_resolution)<boost::chrono::steady_clock::now());
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- boost::chrono::milliseconds const wait_duration(500);
- boost::chrono::steady_clock::time_point const timeout2=boost::chrono::steady_clock::now()+wait_duration;
- timed_lock_succeeded=rw_mutex.try_lock_for(wait_duration);
- BOOST_CHECK((timeout2-timeout_resolution)<boost::chrono::steady_clock::now());
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- finish_lock.unlock();
- writer.join();
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_succeeds_if_no_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- bool timed_lock_succeeded=rw_mutex.try_lock_until(timeout);
- BOOST_CHECK(boost::chrono::steady_clock::now()<timeout);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- boost::chrono::milliseconds const wait_duration(500);
- boost::chrono::steady_clock::time_point const timeout2=boost::chrono::steady_clock::now()+wait_duration;
- timed_lock_succeeded=rw_mutex.try_lock_for(wait_duration);
- BOOST_CHECK(boost::chrono::steady_clock::now()<timeout2);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_times_out_if_read_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- unsigned unblocked_count=0;
- boost::unique_lock<boost::mutex> finish_lock(finish_mutex);
- boost::thread reader(simple_reading_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
- boost::this_thread::sleep_for(boost::chrono::seconds(1));
- CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- boost::chrono::milliseconds const timeout_resolution(50);
- bool timed_lock_succeeded=rw_mutex.try_lock_until(timeout);
- BOOST_CHECK((timeout-timeout_resolution)<boost::chrono::steady_clock::now());
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- boost::chrono::milliseconds const wait_duration(500);
- boost::chrono::steady_clock::time_point const timeout2=boost::chrono::steady_clock::now()+wait_duration;
- timed_lock_succeeded=rw_mutex.try_lock_for(wait_duration);
- BOOST_CHECK((timeout2-timeout_resolution)<boost::chrono::steady_clock::now());
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- finish_lock.unlock();
- reader.join();
- }
- BOOST_AUTO_TEST_CASE(test_timed_lock_times_out_but_read_lock_succeeds_if_read_lock_held)
- {
- boost::shared_mutex rw_mutex;
- boost::mutex finish_mutex;
- boost::mutex unblocked_mutex;
- unsigned unblocked_count=0;
- boost::unique_lock<boost::mutex> finish_lock(finish_mutex);
- boost::thread reader(simple_reading_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
- boost::this_thread::sleep_for(boost::chrono::seconds(1));
- CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
- boost::chrono::steady_clock::time_point const start=boost::chrono::steady_clock::now();
- boost::chrono::steady_clock::time_point const timeout=start+boost::chrono::milliseconds(500);
- bool timed_lock_succeeded=rw_mutex.try_lock_until(timeout);
- BOOST_CHECK(!timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock();
- }
- boost::chrono::milliseconds const wait_duration(500);
- timed_lock_succeeded=rw_mutex.try_lock_shared_for(wait_duration);
- BOOST_CHECK(timed_lock_succeeded);
- if(timed_lock_succeeded)
- {
- rw_mutex.unlock_shared();
- }
- finish_lock.unlock();
- reader.join();
- }
- #else
- #error "Test not applicable: BOOST_THREAD_USES_CHRONO not defined for this platform as not supported"
- #endif
|