From 03a6829070cd1c6a092f6d3bd3d601e51b2ac108 Mon Sep 17 00:00:00 2001 From: Arvid Norberg Date: Fri, 1 Nov 2013 16:05:48 +0000 Subject: [PATCH] add unit test for timer functions --- test/Jamfile | 1 + test/test_primitives.cpp | 7 --- test/test_time.cpp | 100 +++++++++++++++++++++++++++++++++++++++ 3 files changed, 101 insertions(+), 7 deletions(-) create mode 100644 test/test_time.cpp diff --git a/test/Jamfile b/test/Jamfile index c5913108b..b1afb39d8 100644 --- a/test/Jamfile +++ b/test/Jamfile @@ -99,6 +99,7 @@ feature launcher : none valgrind : composite ; feature.compose valgrind : "valgrind --tool=memcheck -v --num-callers=20 --read-var-info=yes --track-origins=yes --error-exitcode=222" on ; test-suite libtorrent : + [ run test_time.cpp ] [ run test_file_storage.cpp ] [ run test_priority.cpp ] [ run test_peer_priority.cpp ] diff --git a/test/test_primitives.cpp b/test/test_primitives.cpp index ea84fe64b..b73e1179e 100644 --- a/test/test_primitives.cpp +++ b/test/test_primitives.cpp @@ -213,13 +213,6 @@ int test_main() snprintf(msg, sizeof(msg), "too %s format string", "long"); TEST_CHECK(strcmp(msg, "too long ") == 0); - // make sure the time classes have correct semantics - - TEST_EQUAL(total_milliseconds(milliseconds(100)), 100); - TEST_EQUAL(total_milliseconds(milliseconds(1)), 1); - TEST_EQUAL(total_milliseconds(seconds(1)), 1000); - - if (supports_ipv6()) { // make sure the assumption we use in policy's peer list hold diff --git a/test/test_time.cpp b/test/test_time.cpp new file mode 100644 index 000000000..1fbd24be0 --- /dev/null +++ b/test/test_time.cpp @@ -0,0 +1,100 @@ +/* + +Copyright (c) 2013, Arvid Norberg +All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions +are met: + + * Redistributions of source code must retain the above copyright + notice, this list of conditions and the following disclaimer. + * Redistributions in binary form must reproduce the above copyright + notice, this list of conditions and the following disclaimer in + the documentation and/or other materials provided with the distribution. + * Neither the name of the author nor the names of its + contributors may be used to endorse or promote products derived + from this software without specific prior written permission. + +THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" +AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE +IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE +ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE +LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR +CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF +SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS +INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN +CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) +ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE +POSSIBILITY OF SUCH DAMAGE. + +*/ + +#include "test.hpp" +#include "libtorrent/time.hpp" +#include "libtorrent/thread.hpp" + +#include + +using namespace libtorrent; + +void check_timer_loop(mutex& m, ptime& last, condition_variable& cv) +{ + mutex::scoped_lock l(m); + cv.wait(l); + l.unlock(); + + for (int i = 0; i < 10000; ++i) + { + mutex::scoped_lock l(m); + ptime now = time_now_hires(); + TEST_CHECK(now >= last); + last = now; + } +} + +int test_main() +{ + + // make sure the time classes have correct semantics + + TEST_EQUAL(total_milliseconds(milliseconds(100)), 100); + TEST_EQUAL(total_milliseconds(milliseconds(1)), 1); + TEST_EQUAL(total_milliseconds(seconds(1)), 1000); + TEST_EQUAL(total_seconds(minutes(1)), 60); + TEST_EQUAL(total_seconds(hours(1)), 3600); + + // make sure it doesn't wrap at 32 bit arithmetic + TEST_EQUAL(total_seconds(seconds(281474976)), 281474976); + TEST_EQUAL(total_milliseconds(milliseconds(281474976)), 281474976); + + // make sure the timer is monotonic + + ptime now = time_now_hires(); + ptime last = now; + for (int i = 0; i < 1000; ++i) + { + now = time_now_hires(); + TEST_CHECK(now >= last); + last = now; + } + + mutex m; + condition_variable cv; + thread t1(boost::bind(&check_timer_loop, boost::ref(m), boost::ref(last), boost::ref(cv))); + thread t2(boost::bind(&check_timer_loop, boost::ref(m), boost::ref(last), boost::ref(cv))); + thread t3(boost::bind(&check_timer_loop, boost::ref(m), boost::ref(last), boost::ref(cv))); + thread t4(boost::bind(&check_timer_loop, boost::ref(m), boost::ref(last), boost::ref(cv))); + + sleep(100); + + cv.notify_all(); + + t1.join(); + t2.join(); + t3.join(); + t4.join(); + + return 0; +} +