[Boost-commit] svn:boost r66002 - trunk/libs/asio/test

Subject: [Boost-commit] svn:boost r66002 - trunk/libs/asio/test
From: chris_at_[hidden]
Date: 2010-10-16 01:13:47

Author: chris_kohlhoff
Date: 2010-10-16 01:13:46 EDT (Sat, 16 Oct 2010)
New Revision: 66002
URL: http://svn.boost.org/trac/boost/changeset/66002

Log:
Add a test case for bug where a deadline timer never fires if the io_service is run in a background thread. N.B. fails only on platforms that use kqueue. Refs #4568.

Text files modified: 
   trunk/libs/asio/test/deadline_timer.cpp |    27 +++++++++++++++++++++++++++             
   1 files changed, 27 insertions(+), 0 deletions(-)

Modified: trunk/libs/asio/test/deadline_timer.cpp
==============================================================================
--- trunk/libs/asio/test/deadline_timer.cpp	(original)
+++ trunk/libs/asio/test/deadline_timer.cpp	2010-10-16 01:13:46 EDT (Sat, 16 Oct 2010)
@@ -16,6 +16,7 @@
 // Test that header file is self-contained.
 #include <boost/asio/deadline_timer.hpp>
 
+#include <boost/thread.hpp>
 #include <boost/bind.hpp>
 #include <boost/asio/io_service.hpp>
 #include <boost/asio/placeholders.hpp>
@@ -260,11 +261,37 @@
   BOOST_CHECK(allocation_count == 0);
 }
 
+void deadline_timer_thread_test()
+{
+  boost::asio::io_service ios;
+  boost::asio::io_service::work w(ios);
+  boost::asio::deadline_timer t1(ios);
+  boost::asio::deadline_timer t2(ios);
+  int count = 0;
+
+  boost::thread th(boost::bind(&boost::asio::io_service::run, &ios));
+
+  t2.expires_from_now(boost::posix_time::seconds(2));
+  t2.wait();
+
+  t1.expires_from_now(boost::posix_time::seconds(2));
+  t1.async_wait(boost::bind(increment, &count));
+
+  t2.expires_from_now(boost::posix_time::seconds(4));
+  t2.wait();
+
+  ios.stop();
+  th.join();
+
+  BOOST_CHECK(count == 1);
+}
+
 test_suite* init_unit_test_suite(int, char*[])
 {
   test_suite* test = BOOST_TEST_SUITE("deadline_timer");
   test->add(BOOST_TEST_CASE(&deadline_timer_test));
   test->add(BOOST_TEST_CASE(&deadline_timer_cancel_test));
   test->add(BOOST_TEST_CASE(&deadline_timer_custom_allocation_test));
+  test->add(BOOST_TEST_CASE(&deadline_timer_thread_test));
   return test;
 }