wornvirtue
/
premiere-libtorrent
forked from premiere/premiere-libtorrent
1
0
Fork 0
Code Pull Requests Activity

fix name clash with 'thread' on freebsd (#664)

This commit is contained in:
Arvid Norberg 2016-04-29 12:00:39 -04:00
parent d93bf9096d
commit 95e348bef7
6 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/dht_server.cpp
View File

@ -89,7 +89,7 @@ struct dht_server
fprintf(stderr, "%s: DHT initialized on port %d\n", time_now_string(), m_port); fprintf(stderr, "%s: DHT initialized on port %d\n", time_now_string(), m_port);
m_thread.reset(new thread(boost::bind(&dht_server::thread_fun, this))); m_thread.reset(new libtorrent::thread(boost::bind(&dht_server::thread_fun, this)));
} }
~dht_server() ~dht_server()

2
test/peer_server.cpp
View File

@ -92,7 +92,7 @@ struct peer_server
fprintf(stderr, "%s: PEER peer initialized on port %d\n", time_now_string(), m_port); fprintf(stderr, "%s: PEER peer initialized on port %d\n", time_now_string(), m_port);
m_thread.reset(new thread(boost::bind(&peer_server::thread_fun, this))); m_thread.reset(new libtorrent::thread(boost::bind(&peer_server::thread_fun, this)));
} }
~peer_server() ~peer_server()

2
test/test_alert_manager.cpp
View File

@ -262,7 +262,7 @@ TORRENT_TEST(wait_for_alert)
mgr.get_all(alerts, num_resume); mgr.get_all(alerts, num_resume);
start = clock_type::now(); start = clock_type::now();
thread posting_thread(boost::bind(&post_torrent_added, &mgr)); libtorrent::thread posting_thread(boost::bind(&post_torrent_added, &mgr));
a = mgr.wait_for_alert(seconds(10)); a = mgr.wait_for_alert(seconds(10));
end = clock_type::now(); end = clock_type::now();

12
test/test_threads.cpp
View File

@ -77,11 +77,11 @@ TORRENT_TEST(threads)
{ {
condition_variable cond; condition_variable cond;
libtorrent::mutex m; libtorrent::mutex m;
std::list<thread*> threads; std::list<libtorrent::thread*> threads;
int waiting = 0; int waiting = 0;
for (int i = 0; i < 20; ++i) for (int i = 0; i < 20; ++i)
{ {
threads.push_back(new thread(boost::bind(&fun, &cond, &m, &waiting, i))); threads.push_back(new libtorrent::thread(boost::bind(&fun, &cond, &m, &waiting, i)));
} }
// make sure all threads are waiting on the condition_variable // make sure all threads are waiting on the condition_variable
@ -96,7 +96,7 @@ TORRENT_TEST(threads)
cond.notify_all(); cond.notify_all();
l.unlock(); l.unlock();
for (std::list<thread*>::iterator i = threads.begin(); i != threads.end(); ++i) for (std::list<libtorrent::thread*>::iterator i = threads.begin(); i != threads.end(); ++i)
{ {
(*i)->join(); (*i)->join();
delete *i; delete *i;
@ -107,8 +107,8 @@ TORRENT_TEST(threads)
boost::atomic<int> c(0); boost::atomic<int> c(0);
for (int i = 0; i < 3; ++i) for (int i = 0; i < 3; ++i)
{ {
threads.push_back(new thread(boost::bind(&increment, &cond, &m, &waiting, &c))); threads.push_back(new libtorrent::thread(boost::bind(&increment, &cond, &m, &waiting, &c)));
threads.push_back(new thread(boost::bind(&decrement, &cond, &m, &waiting, &c))); threads.push_back(new libtorrent::thread(boost::bind(&decrement, &cond, &m, &waiting, &c)));
} }
// make sure all threads are waiting on the condition_variable // make sure all threads are waiting on the condition_variable
@ -123,7 +123,7 @@ TORRENT_TEST(threads)
cond.notify_all(); cond.notify_all();
l.unlock(); l.unlock();
for (std::list<thread*>::iterator i = threads.begin(); i != threads.end(); ++i) for (std::list<libtorrent::thread*>::iterator i = threads.begin(); i != threads.end(); ++i)
{ {
(*i)->join(); (*i)->join();
delete *i; delete *i;

8
test/test_time.cpp
View File

@ -83,10 +83,10 @@ TORRENT_TEST(time)
mutex m; mutex m;
condition_variable cv; condition_variable cv;
thread t1(boost::bind(&check_timer_loop, boost::ref(m), boost::ref(last), boost::ref(cv))); libtorrent::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))); libtorrent::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))); libtorrent::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))); libtorrent::thread t4(boost::bind(&check_timer_loop, boost::ref(m), boost::ref(last), boost::ref(cv)));
test_sleep(100); test_sleep(100);

2
test/udp_tracker.cpp
View File

@ -171,7 +171,7 @@ struct udp_tracker
fprintf(stderr, "%s: UDP tracker initialized on port %d\n", time_now_string(), m_port); fprintf(stderr, "%s: UDP tracker initialized on port %d\n", time_now_string(), m_port);
m_thread.reset(new thread(boost::bind(&udp_tracker::thread_fun, this))); m_thread.reset(new libtorrent::thread(boost::bind(&udp_tracker::thread_fun, this)));
} }
void stop() void stop()