1
2 // Copyright Oliver Kowalke 2009.
3 // Distributed under the Boost Software License, Version 1.0.
4 // (See accompanying file LICENSE_1_0.txt or copy at
5 // http://www.boost.org/LICENSE_1_0.txt)
6
7 #include <cstdlib>
8 #include <iostream>
9 #include <stdexcept>
10 #include <string>
11
12 #include <boost/chrono.hpp>
13 #include <boost/coroutine/all.hpp>
14 #include <boost/cstdint.hpp>
15 #include <boost/program_options.hpp>
16
17 #include "../bind_processor.hpp"
18 #include "../clock.hpp"
19 #include "../cycle.hpp"
20
21 boost::coroutines::flag_fpu_t preserve_fpu = boost::coroutines::fpu_not_preserved;
22 boost::uint64_t jobs = 1000;
23
24 struct X
25 {
26 std::string str;
27
XX28 X( std::string const& str_) :
29 str( str_)
30 {}
31 };
32
33 const X x("abc");
34
fn_void(boost::coroutines::asymmetric_coroutine<void>::push_type & c)35 void fn_void( boost::coroutines::asymmetric_coroutine< void >::push_type & c)
36 { while ( true) c(); }
37
fn_int(boost::coroutines::asymmetric_coroutine<int>::push_type & c)38 void fn_int( boost::coroutines::asymmetric_coroutine< int >::push_type & c)
39 { while ( true) c( 7); }
40
fn_x(boost::coroutines::asymmetric_coroutine<X>::push_type & c)41 void fn_x( boost::coroutines::asymmetric_coroutine< X >::push_type & c)
42 {
43 while ( true) c( x);
44 }
45
measure_time_void(duration_type overhead)46 duration_type measure_time_void( duration_type overhead)
47 {
48 boost::coroutines::asymmetric_coroutine< void >::pull_type c( fn_void,
49 boost::coroutines::attributes( preserve_fpu) );
50
51 time_point_type start( clock_type::now() );
52 for ( std::size_t i = 0; i < jobs; ++i) {
53 c();
54 }
55 duration_type total = clock_type::now() - start;
56 total -= overhead_clock(); // overhead of measurement
57 total /= jobs; // loops
58 total /= 2; // 2x jump_fcontext
59
60 return total;
61 }
62
measure_time_int(duration_type overhead)63 duration_type measure_time_int( duration_type overhead)
64 {
65 boost::coroutines::asymmetric_coroutine< int >::pull_type c( fn_int,
66 boost::coroutines::attributes( preserve_fpu) );
67
68 time_point_type start( clock_type::now() );
69 for ( std::size_t i = 0; i < jobs; ++i) {
70 c();
71 }
72 duration_type total = clock_type::now() - start;
73 total -= overhead_clock(); // overhead of measurement
74 total /= jobs; // loops
75 total /= 2; // 2x jump_fcontext
76
77 return total;
78 }
79
measure_time_x(duration_type overhead)80 duration_type measure_time_x( duration_type overhead)
81 {
82 boost::coroutines::asymmetric_coroutine< X >::pull_type c( fn_x,
83 boost::coroutines::attributes( preserve_fpu) );
84
85 time_point_type start( clock_type::now() );
86 for ( std::size_t i = 0; i < jobs; ++i) {
87 c();
88 }
89 duration_type total = clock_type::now() - start;
90 total -= overhead_clock(); // overhead of measurement
91 total /= jobs; // loops
92 total /= 2; // 2x jump_fcontext
93
94 return total;
95 }
96
97 # ifdef BOOST_CONTEXT_CYCLE
measure_cycles_void(cycle_type overhead)98 cycle_type measure_cycles_void( cycle_type overhead)
99 {
100 boost::coroutines::asymmetric_coroutine< void >::pull_type c( fn_void,
101 boost::coroutines::attributes( preserve_fpu) );
102
103 cycle_type start( cycles() );
104 for ( std::size_t i = 0; i < jobs; ++i) {
105 c();
106 }
107 cycle_type total = cycles() - start;
108 total -= overhead; // overhead of measurement
109 total /= jobs; // loops
110 total /= 2; // 2x jump_fcontext
111
112 return total;
113 }
114
measure_cycles_int(cycle_type overhead)115 cycle_type measure_cycles_int( cycle_type overhead)
116 {
117 boost::coroutines::asymmetric_coroutine< int >::pull_type c( fn_int,
118 boost::coroutines::attributes( preserve_fpu) );
119
120 cycle_type start( cycles() );
121 for ( std::size_t i = 0; i < jobs; ++i) {
122 c();
123 }
124 cycle_type total = cycles() - start;
125 total -= overhead; // overhead of measurement
126 total /= jobs; // loops
127 total /= 2; // 2x jump_fcontext
128
129 return total;
130 }
131
measure_cycles_x(cycle_type overhead)132 cycle_type measure_cycles_x( cycle_type overhead)
133 {
134 boost::coroutines::asymmetric_coroutine< X >::pull_type c( fn_x,
135 boost::coroutines::attributes( preserve_fpu) );
136
137 cycle_type start( cycles() );
138 for ( std::size_t i = 0; i < jobs; ++i) {
139 c();
140 }
141 cycle_type total = cycles() - start;
142 total -= overhead; // overhead of measurement
143 total /= jobs; // loops
144 total /= 2; // 2x jump_fcontext
145
146 return total;
147 }
148 # endif
149
main(int argc,char * argv[])150 int main( int argc, char * argv[])
151 {
152 try
153 {
154 bool preserve = false, bind = false;
155 boost::program_options::options_description desc("allowed options");
156 desc.add_options()
157 ("help", "help message")
158 ("bind,b", boost::program_options::value< bool >( & bind), "bind thread to CPU")
159 ("fpu,f", boost::program_options::value< bool >( & preserve), "preserve FPU registers")
160 ("jobs,j", boost::program_options::value< boost::uint64_t >( & jobs), "jobs to run");
161
162 boost::program_options::variables_map vm;
163 boost::program_options::store(
164 boost::program_options::parse_command_line(
165 argc,
166 argv,
167 desc),
168 vm);
169 boost::program_options::notify( vm);
170
171 if ( vm.count("help") ) {
172 std::cout << desc << std::endl;
173 return EXIT_SUCCESS;
174 }
175
176 if ( preserve) preserve_fpu = boost::coroutines::fpu_preserved;
177 if ( bind) bind_to_processor( 0);
178
179 duration_type overhead_c = overhead_clock();
180 std::cout << "overhead " << overhead_c.count() << " nano seconds" << std::endl;
181 boost::uint64_t res = measure_time_void( overhead_c).count();
182 std::cout << "void: average of " << res << " nano seconds" << std::endl;
183 res = measure_time_int( overhead_c).count();
184 std::cout << "int: average of " << res << " nano seconds" << std::endl;
185 res = measure_time_x( overhead_c).count();
186 std::cout << "X: average of " << res << " nano seconds" << std::endl;
187 #ifdef BOOST_CONTEXT_CYCLE
188 cycle_type overhead_y = overhead_cycle();
189 std::cout << "overhead " << overhead_y << " cpu cycles" << std::endl;
190 res = measure_cycles_void( overhead_y);
191 std::cout << "void: average of " << res << " cpu cycles" << std::endl;
192 res = measure_cycles_int( overhead_y);
193 std::cout << "int: average of " << res << " cpu cycles" << std::endl;
194 res = measure_cycles_x( overhead_y);
195 std::cout << "X: average of " << res << " cpu cycles" << std::endl;
196 #endif
197
198 return EXIT_SUCCESS;
199 }
200 catch ( std::exception const& e)
201 { std::cerr << "exception: " << e.what() << std::endl; }
202 catch (...)
203 { std::cerr << "unhandled exception" << std::endl; }
204 return EXIT_FAILURE;
205 }
206