townforge/coroutine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

make pinning thread to cpu a choice

Browse Source
This commit is contained in:
Oliver Kowalke 2014-02-06 17:23:46 +01:00
parent 77cc851024
commit 1caaffa6b1
10 changed files with 84 additions and 80 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
performance/asymmetric/performance_create_prealloc.cpp
View File

@ -18,8 +18,8 @@
#include "../cycle.hpp"
#include "../preallocated_stack_allocator.hpp"
typedef preallocated_stack_allocator stack_allocator;
typedef boost::coroutines::asymmetric_coroutine< void, stack_allocator > coro_type;
typedef preallocated_stack_allocator stack_allocator;
typedef boost::coroutines::asymmetric_coroutine< void, stack_allocator > coro_type;
boost::coroutines::flag_fpu_t preserve_fpu = boost::coroutines::fpu_not_preserved;
boost::coroutines::flag_unwind_t unwind_stack = boost::coroutines::stack_unwind;
@ -68,12 +68,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false, unwind = true;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -94,6 +93,7 @@ int main( int argc, char * argv[])
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

6
performance/asymmetric/performance_create_protected.cpp
View File

@ -65,12 +65,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false, unwind = true;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -91,6 +90,7 @@ int main( int argc, char * argv[])
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

6
performance/asymmetric/performance_create_standard.cpp
View File

@ -65,12 +65,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false, unwind = true;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -91,6 +90,7 @@ int main( int argc, char * argv[])
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

6
performance/asymmetric/performance_switch.cpp
View File

@ -151,12 +151,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -175,6 +174,7 @@ int main( int argc, char * argv[])
}
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

13
performance/asymmetric/segmented/performance_create_segmented.cpp
View File

@ -18,6 +18,7 @@
#include "../../cycle.hpp"
boost::coroutines::flag_fpu_t preserve_fpu = boost::coroutines::fpu_not_preserved;
boost::coroutines::flag_unwind_t unwind_stack = boost::coroutines::stack_unwind;
boost::uint64_t jobs = 1000;
void fn( boost::coroutines::asymmetric_coroutine< void >::push_type & c)
@ -28,7 +29,7 @@ duration_type measure_time( duration_type overhead)
time_point_type start( clock_type::now() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::asymmetric_coroutine< void >::pull_type c( fn,
boost::coroutines::attributes( preserve_fpu) );
boost::coroutines::attributes( unwind_stack, preserve_fpu) );
}
duration_type total = clock_type::now() - start;
total -= overhead_clock(); // overhead of measurement
@ -43,7 +44,7 @@ cycle_type measure_cycles( cycle_type overhead)
cycle_type start( cycles() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::asymmetric_coroutine< void >::pull_type c( fn,
boost::coroutines::attributes( preserve_fpu) );
boost::coroutines::attributes( unwind_stack, preserve_fpu) );
}
cycle_type total = cycles() - start;
total -= overhead; // overhead of measurement
@ -57,13 +58,13 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
boost::program_options::variables_map vm;
@ -81,6 +82,8 @@ int main( int argc, char * argv[])
}
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

6
performance/symmetric/performance_create_prealloc.cpp
View File

@ -67,12 +67,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false, unwind = true;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -93,6 +92,7 @@ int main( int argc, char * argv[])
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

6
performance/symmetric/performance_create_protected.cpp
View File

@ -64,12 +64,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false, unwind = true;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -90,6 +89,7 @@ int main( int argc, char * argv[])
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

6
performance/symmetric/performance_create_standard.cpp
View File

@ -64,12 +64,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false, unwind = true;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -90,6 +89,7 @@ int main( int argc, char * argv[])
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

92
performance/symmetric/performance_switch.cpp
View File

@ -33,26 +33,26 @@ struct X
const X x("abc");
void fn_void( boost::coroutines::symmetric_coroutine< void >::yield_type &)
{}
void fn_void( boost::coroutines::symmetric_coroutine< void >::yield_type & yield)
{ while( true) yield(); }
void fn_int( boost::coroutines::symmetric_coroutine< int >::yield_type &)
{}
void fn_int( boost::coroutines::symmetric_coroutine< int >::yield_type & yield)
{ while( true) yield(); }
void fn_x( boost::coroutines::symmetric_coroutine< X >::yield_type &)
{}
void fn_x( boost::coroutines::symmetric_coroutine< X >::yield_type & yield)
{ while( true) yield(); }
duration_type measure_time_void( duration_type overhead)
{
duration_type total = duration_type::zero();
boost::coroutines::symmetric_coroutine< void >::call_type c( fn_void,
boost::coroutines::attributes( preserve_fpu) );
time_point_type start( clock_type::now() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< void >::call_type c( fn_void,
boost::coroutines::attributes( preserve_fpu) );
time_point_type start( clock_type::now() );
c();
total += clock_type::now() - start;
}
total -= jobs * overhead; // overhead of measurement
duration_type total = clock_type::now() - start;
total -= overhead_clock(); // overhead of measurement
total /= jobs; // loops
total /= 2; // 2x jump_fcontext
@ -61,16 +61,15 @@ duration_type measure_time_void( duration_type overhead)
duration_type measure_time_int( duration_type overhead)
{
int i = 3;
duration_type total = duration_type::zero();
boost::coroutines::symmetric_coroutine< int >::call_type c( fn_int,
boost::coroutines::attributes( preserve_fpu) );
time_point_type start( clock_type::now() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< int >::call_type c( fn_int,
boost::coroutines::attributes( preserve_fpu) );
time_point_type start( clock_type::now() );
c( i);
total += clock_type::now() - start;
}
total -= jobs * overhead; // overhead of measurement
duration_type total = clock_type::now() - start;
total -= overhead_clock(); // overhead of measurement
total /= jobs; // loops
total /= 2; // 2x jump_fcontext
@ -79,16 +78,16 @@ duration_type measure_time_int( duration_type overhead)
duration_type measure_time_x( duration_type overhead)
{
boost::coroutines::symmetric_coroutine< X >::call_type c( fn_x,
boost::coroutines::attributes( preserve_fpu) );
X x("abc");
duration_type total = duration_type::zero();
time_point_type start( clock_type::now() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< X >::call_type c( fn_x,
boost::coroutines::attributes( preserve_fpu) );
time_point_type start( clock_type::now() );
c( x);
total += clock_type::now() - start;
}
total -= jobs * overhead; // overhead of measurement
duration_type total = clock_type::now() - start;
total -= overhead_clock(); // overhead of measurement
total /= jobs; // loops
total /= 2; // 2x jump_fcontext
@ -98,15 +97,15 @@ duration_type measure_time_x( duration_type overhead)
# ifdef BOOST_CONTEXT_CYCLE
cycle_type measure_cycles_void( cycle_type overhead)
{
cycle_type total = 0;
boost::coroutines::symmetric_coroutine< void >::call_type c( fn_void,
boost::coroutines::attributes( preserve_fpu) );
cycle_type start( cycles() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< void >::call_type c( fn_void,
boost::coroutines::attributes( preserve_fpu) );
cycle_type start( cycles() );
c();
total += cycles() - start;
}
total -= jobs * overhead; // overhead of measurement
cycle_type total = cycles() - start;
total -= overhead; // overhead of measurement
total /= jobs; // loops
total /= 2; // 2x jump_fcontext
@ -115,16 +114,15 @@ cycle_type measure_cycles_void( cycle_type overhead)
cycle_type measure_cycles_int( cycle_type overhead)
{
int i = 3;
cycle_type total = 0;
boost::coroutines::symmetric_coroutine< int >::call_type c( fn_int,
boost::coroutines::attributes( preserve_fpu) );
cycle_type start( cycles() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< int >::call_type c( fn_int,
boost::coroutines::attributes( preserve_fpu) );
cycle_type start( cycles() );
c( i);
total += cycles() - start;
}
total -= jobs * overhead; // overhead of measurement
cycle_type total = cycles() - start;
total -= overhead; // overhead of measurement
total /= jobs; // loops
total /= 2; // 2x jump_fcontext
@ -133,16 +131,16 @@ cycle_type measure_cycles_int( cycle_type overhead)
cycle_type measure_cycles_x( cycle_type overhead)
{
boost::coroutines::symmetric_coroutine< X >::call_type c( fn_x,
boost::coroutines::attributes( preserve_fpu) );
X x("abc");
cycle_type total = 0;
cycle_type start( cycles() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< X >::call_type c( fn_x,
boost::coroutines::attributes( preserve_fpu) );
cycle_type start( cycles() );
c( x);
total += cycles() - start;
}
total -= jobs * overhead; // overhead of measurement
cycle_type total = cycles() - start;
total -= overhead; // overhead of measurement
total /= jobs; // loops
total /= 2; // 2x jump_fcontext
@ -154,12 +152,11 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false;
bool preserve = false, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
@ -178,6 +175,7 @@ int main( int argc, char * argv[])
}
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;

13
performance/symmetric/segmented/performance_create_segmented.cpp
View File

@ -18,6 +18,7 @@
#include "../../cycle.hpp"
boost::coroutines::flag_fpu_t preserve_fpu = boost::coroutines::fpu_not_preserved;
boost::coroutines::flag_unwind_t unwind_stack = boost::coroutines::stack_unwind;
boost::uint64_t jobs = 1000;
void fn( boost::coroutines::symmetric_coroutine< void >::yield_type &) {}
@ -27,7 +28,7 @@ duration_type measure_time( duration_type overhead)
time_point_type start( clock_type::now() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< void >::call_type c( fn,
boost::coroutines::attributes( preserve_fpu) );
boost::coroutines::attributes( unwind_stack, preserve_fpu) );
}
duration_type total = clock_type::now() - start;
total -= overhead; // overhead of measurement
@ -42,7 +43,7 @@ cycle_type measure_cycles( cycle_type overhead)
cycle_type start( cycles() );
for ( std::size_t i = 0; i < jobs; ++i) {
boost::coroutines::symmetric_coroutine< void >::call_type c( fn,
boost::coroutines::attributes( preserve_fpu) );
boost::coroutines::attributes( unwind_stack, preserve_fpu) );
}
cycle_type total = cycles() - start;
total -= overhead; // overhead of measurement
@ -56,13 +57,13 @@ int main( int argc, char * argv[])
{
try
{
bind_to_processor( 0);
bool preserve = false;
bool preserve = false, unwind = true, bind = false;
boost::program_options::options_description desc("allowed options");
desc.add_options()
("help", "help message")
("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
("unwind,u", boost::program_options::value< bool >( & unwind), "unwind coroutine-stack")
("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
boost::program_options::variables_map vm;
@ -80,6 +81,8 @@ int main( int argc, char * argv[])
}
if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
if ( ! unwind) unwind_stack = boost::coroutines::no_stack_unwind;
if ( bind) bind_to_processor( 0);
duration_type overhead_c = overhead_clock();
std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;