Commit 2583d715 authored by neverlord's avatar neverlord

fixed sequential_send benchmark

parent 66190667
...@@ -31,7 +31,7 @@ long the_test(int msg_count) ...@@ -31,7 +31,7 @@ long the_test(int msg_count)
auto msg = make_tuple(atom("AddCount"), val); auto msg = make_tuple(atom("AddCount"), val);
for (int i = 0; i < msg_count; ++i) for (int i = 0; i < msg_count; ++i)
{ {
counter->enqueue(msg); send_tuple(counter, msg);
//send(counter, atom("AddCount"), val); //send(counter, atom("AddCount"), val);
} }
send(counter, atom("Get"), self()); send(counter, atom("Get"), self());
...@@ -43,7 +43,7 @@ long the_test(int msg_count) ...@@ -43,7 +43,7 @@ long the_test(int msg_count)
result = value; result = value;
} }
); );
send(counter, atom(":Exit"), self(), exit_reason::user_defined); send(counter, atom(":Exit"), exit_reason::user_defined);
return result; return result;
} }
...@@ -54,7 +54,7 @@ void run_test(int msg_count) ...@@ -54,7 +54,7 @@ void run_test(int msg_count)
auto elapsed = t0.elapsed(); auto elapsed = t0.elapsed();
cout << "Count is " << count << endl cout << "Count is " << count << endl
<< "Test took " << elapsed << " seconds" << endl << "Test took " << elapsed << " seconds" << endl
<< "Throughput = " << (msg_count / elapsed) << "Throughput = " << static_cast<unsigned long>(msg_count / elapsed)
<< " per sec" << endl; << " per sec" << endl;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment