summaryrefslogtreecommitdiffstats
path: root/filedistribution
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2016-09-13 14:58:15 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2016-09-14 09:16:54 +0000
commit0124c7479478e9510d7a48c74e69445355193d50 (patch)
treebc52de7bdfd372e51c76f2f4d9ba8ce33a8fa586 /filedistribution
parent3aff0538e4a4ce16c2f3b1e98ad900d56d7b6999 (diff)
boost::thread -> std::thread
Diffstat (limited to 'filedistribution')
-rw-r--r--filedistribution/src/tests/scheduler/test-scheduler.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/filedistribution/src/tests/scheduler/test-scheduler.cpp b/filedistribution/src/tests/scheduler/test-scheduler.cpp
index 906bd07c971..c8afca84f26 100644
--- a/filedistribution/src/tests/scheduler/test-scheduler.cpp
+++ b/filedistribution/src/tests/scheduler/test-scheduler.cpp
@@ -21,19 +21,19 @@ class TestException {};
struct CallRun {
volatile bool _caughtException;
+ std::atomic<bool> _closed;
CallRun()
- :_caughtException(false)
+ :_caughtException(false),
+ _closed(false)
{}
void operator()(asio::io_service& ioService) {
- while (!boost::this_thread::interruption_requested()) {
- try {
- //No reset needed after handling exceptions.
- ioService.run();
- } catch(const TestException& e ) {
- _caughtException = true;
- }
+ try {
+ //No reset needed after handling exceptions.
+ ioService.run();
+ } catch(const TestException& e ) {
+ _caughtException = true;
}
}
};
@@ -43,7 +43,7 @@ struct Fixture {
Scheduler scheduler;
Fixture()
- : scheduler(boost::ref(callRun))
+ : scheduler(std::ref(callRun))
{}
};