boost/fiber
2
0
Fork 0
mirror of https://github.com/boostorg/fiber.git synced 2026-02-12 12:02:54 +00:00
Code Issues Projects Releases Wiki Activity
Files
ba80101f47e37606186a6bde75465e13d9bc3b39
fiber/test/test_bounded_channel.cpp
Oliver Kowalke ba80101f47 enhance test for bounded_channel 
- note implementation of waiting_queue does not preserve order
  therefore unit test for bounded_channel fails
2015-08-03 17:33:04 +02:00

799 lines
27 KiB
C++
Raw Blame History

// Copyright Oliver Kowalke 2013.
// Distributed under the Boost Software License, Version 1.0.
// (See accompanying file LICENSE_1_0.txt or copy at
// http://www.boost.org/LICENSE_1_0.txt)
#include <chrono>
#include <sstream>
#include <string>
#include <vector>
#include <boost/assert.hpp>
#include <boost/test/unit_test.hpp>
#include <boost/fiber/all.hpp>
struct moveable {
bool state;
int value;
moveable() :
state( false),
value( -1)
{}
moveable( int v) :
state( true),
value( v)
{}
moveable( moveable && other) :
state( other.state),
value( other.value)
{
other.state = false;
other.value = -1;
}
moveable & operator=( moveable && other)
{
if ( this == & other) return * this;
state = other.state;
other.state = false;
value = other.value;
other.value = -1;
return * this;
}
};
void test_zero_wm_1()
{
bool thrown = false;
try {
boost::fibers::bounded_channel< int > c( 0);
} catch ( boost::fibers::fiber_exception const&) {
thrown = true;
}
BOOST_CHECK( thrown);
}
void test_zero_wm_2()
{
bool thrown = false;
try {
boost::fibers::bounded_channel< int > c( 0, 0);
} catch ( boost::fibers::fiber_exception const&) {
thrown = true;
}
BOOST_CHECK( thrown);
}
void test_hwm_less_lwm()
{
bool thrown = false;
try {
boost::fibers::bounded_channel< int > c( 2, 3);
} catch ( boost::fibers::fiber_exception const&) {
thrown = true;
}
BOOST_CHECK( thrown);
}
void test_push()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 1) );
BOOST_CHECK( ! c.is_empty() );
}
void test_push_closed()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.push( 1) );
}
void test_try_push()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 1) );
BOOST_CHECK( ! c.is_empty() );
}
void test_try_push_closed()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_push( 1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.try_push( 2) );
}
void test_try_push_full()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_push( 1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::full == c.try_push( 2) );
}
void test_push_wait_for()
{
boost::fibers::bounded_channel< int > c( 2);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push_wait_for( 1, std::chrono::seconds( 1) ) );
BOOST_CHECK( ! c.is_empty() );
}
void test_push_wait_for_closed()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.push_wait_for( 1, std::chrono::seconds( 1) ) );
}
void test_push_wait_for_timeout()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push_wait_for( 1, std::chrono::seconds( 1) ) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::timeout == c.push_wait_for( 1, std::chrono::seconds( 1) ) );
}
void test_push_wait_until()
{
boost::fibers::bounded_channel< int > c( 2);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push_wait_until( 1,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
BOOST_CHECK( ! c.is_empty() );
}
void test_push_wait_until_closed()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.push_wait_until( 1,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
}
void test_push_wait_until_timeout()
{
boost::fibers::bounded_channel< int > c( 1);
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push_wait_until( 1,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::timeout == c.push_wait_until( 1,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
}
void test_pop()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop( v2) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_pop_closed()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop( v2) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.pop( v2) );
}
void test_pop_success()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
boost::fibers::fiber f1([&c,&v2](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop( v2) );
BOOST_CHECK( c.is_empty() );
});
boost::fibers::fiber f2([&c,v1](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
});
f1.join();
BOOST_CHECK( c.is_empty() );
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_value_pop()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
v2 = c.value_pop();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_value_pop_closed()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
v2 = c.value_pop();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
bool thrown = false;
try {
c.value_pop();
} catch ( boost::fibers::fiber_exception const&) {
thrown = true;
}
BOOST_CHECK( thrown);
}
void test_value_pop_success()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
boost::fibers::fiber f1([&c,&v2](){
v2 = c.value_pop();
BOOST_CHECK( c.is_empty() );
});
boost::fibers::fiber f2([&c,v1](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
});
f1.join();
BOOST_CHECK( c.is_empty() );
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_try_pop()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_pop( v2) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_try_pop_closed()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_pop( v2) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.try_pop( v2) );
}
void test_try_pop_success()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
boost::fibers::fiber f1([&c,&v2](){
while ( boost::fibers::channel_op_status::success != c.try_pop( v2) );
BOOST_CHECK( c.is_empty() );
});
boost::fibers::fiber f2([&c,v1](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
});
f1.join();
BOOST_CHECK( c.is_empty() );
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_pop_wait_for()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop_wait_for( v2, std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_pop_wait_for_closed()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop_wait_for( v2, std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.pop_wait_for( v2, std::chrono::seconds( 1) ) );
}
void test_pop_wait_for_success()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
boost::fibers::fiber f1([&c,&v2](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop_wait_for( v2, std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
});
boost::fibers::fiber f2([&c,v1](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
});
f1.join();
BOOST_CHECK( c.is_empty() );
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_pop_wait_for_timeout()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v = 0;
boost::fibers::fiber f([&c,&v](){
BOOST_CHECK( boost::fibers::channel_op_status::timeout == c.pop_wait_for( v, std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
});
f.join();
}
void test_pop_wait_until()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop_wait_until( v2,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_pop_wait_until_closed()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( ! c.is_closed() );
c.close();
BOOST_CHECK( c.is_closed() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop_wait_until( v2,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
BOOST_CHECK( boost::fibers::channel_op_status::closed == c.pop_wait_until( v2,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
}
void test_pop_wait_until_success()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v1 = 2, v2 = 0;
boost::fibers::fiber f1([&c,&v2](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop_wait_until( v2,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
});
boost::fibers::fiber f2([&c,v1](){
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( v1) );
BOOST_CHECK( ! c.is_empty() );
});
f1.join();
BOOST_CHECK( c.is_empty() );
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK_EQUAL( v1, v2);
}
void test_pop_wait_until_timeout()
{
boost::fibers::bounded_channel< int > c( 10);
BOOST_CHECK( c.is_empty() );
int v = 0;
boost::fibers::fiber f([&c,&v](){
BOOST_CHECK( boost::fibers::channel_op_status::timeout == c.pop_wait_until( v,
std::chrono::system_clock::now() + std::chrono::seconds( 1) ) );
BOOST_CHECK( c.is_empty() );
});
f.join();
}
void test_wm_1()
{
boost::fibers::bounded_channel< int > c( 2);
BOOST_CHECK( c.is_empty() );
std::vector< boost::fibers::fiber::id > ids;
boost::fibers::fiber f1([&c,&ids](){
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 1) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 2) );
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
// would be blocked because channel is full
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 3) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber f2([&c,&ids](){
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 1 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 2 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
// would block because channel is empty
BOOST_CHECK( 3 == c.value_pop() );
BOOST_CHECK( c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber::id id1 = f1.get_id();
boost::fibers::fiber::id id2 = f2.get_id();
f1.join();
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( 8 == ids.size() );
BOOST_CHECK_EQUAL( id1, ids[0]);
BOOST_CHECK_EQUAL( id1, ids[1]);
BOOST_CHECK_EQUAL( id1, ids[2]);
BOOST_CHECK_EQUAL( id2, ids[3]);
BOOST_CHECK_EQUAL( id2, ids[4]);
BOOST_CHECK_EQUAL( id2, ids[5]);
BOOST_CHECK_EQUAL( id1, ids[6]);
BOOST_CHECK_EQUAL( id2, ids[7]);
}
void test_wm_2()
{
boost::fibers::bounded_channel< int > c( 2, 1);
BOOST_CHECK( c.is_empty() );
std::vector< boost::fibers::fiber::id > ids;
boost::fibers::fiber f1([&c,&ids](){
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 1) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 2) );
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
// would be blocked because channel is full
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 3) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber f2([&c,&ids](){
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 1 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 2 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
// would block because channel is empty
BOOST_CHECK( 3 == c.value_pop() );
BOOST_CHECK( c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber::id id1 = f1.get_id();
boost::fibers::fiber::id id2 = f2.get_id();
f1.join();
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( 8 == ids.size() );
BOOST_CHECK_EQUAL( id1, ids[0]);
BOOST_CHECK_EQUAL( id1, ids[1]);
BOOST_CHECK_EQUAL( id1, ids[2]);
BOOST_CHECK_EQUAL( id2, ids[3]);
BOOST_CHECK_EQUAL( id2, ids[4]);
BOOST_CHECK_EQUAL( id2, ids[5]);
BOOST_CHECK_EQUAL( id1, ids[6]);
BOOST_CHECK_EQUAL( id2, ids[7]);
}
void test_wm_3()
{
boost::fibers::bounded_channel< int > c( 3);
BOOST_CHECK( c.is_empty() );
std::vector< boost::fibers::fiber::id > ids;
boost::fibers::fiber f1([&c,&ids](){
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 1) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 2) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 3) );
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( c.is_full() );
// would be blocked because channel is full
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 4) );
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( ! c.is_empty() );
// would be blocked because channel is full
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 5) );
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber f2([&c,&ids](){
// value '1' should be in channel
BOOST_CHECK( c.is_full() );
BOOST_CHECK( ! c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
c.value_pop();
//BOOST_CHECK( 1 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
// let potential other fibers run
boost::this_fiber::yield();
// value '2' should be in channel
BOOST_CHECK( c.is_full() );
BOOST_CHECK( ! c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 2 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
// let potential other fibers run
boost::this_fiber::yield();
// value '3' should be in channel
BOOST_CHECK( c.is_full() );
BOOST_CHECK( ! c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 3 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
// let potential other fibers run
boost::this_fiber::yield();
// value '4' should be in channel
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
// would block because channel is empty
BOOST_CHECK( 4 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
// let potential other fibers run
boost::this_fiber::yield();
// value '5' should be in channel
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
// would block because channel is empty
BOOST_CHECK( 5 == c.value_pop() );
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( c.is_empty() );
// let potential other fibers run
boost::this_fiber::yield();
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber::id id1 = f1.get_id();
boost::fibers::fiber::id id2 = f2.get_id();
f1.join();
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( 12 == ids.size() );
BOOST_CHECK_EQUAL( id1, ids[0]);
BOOST_CHECK_EQUAL( id1, ids[1]);
BOOST_CHECK_EQUAL( id1, ids[2]);
BOOST_CHECK_EQUAL( id1, ids[3]);
BOOST_CHECK_EQUAL( id2, ids[4]);
BOOST_CHECK_EQUAL( id1, ids[5]);
BOOST_CHECK_EQUAL( id2, ids[6]);
BOOST_CHECK_EQUAL( id1, ids[7]);
BOOST_CHECK_EQUAL( id2, ids[8]);
BOOST_CHECK_EQUAL( id2, ids[9]);
BOOST_CHECK_EQUAL( id2, ids[10]);
BOOST_CHECK_EQUAL( id2, ids[11]);
}
void test_wm_4()
{
boost::fibers::bounded_channel< int > c( 3, 1);
BOOST_CHECK( c.is_empty() );
std::vector< boost::fibers::fiber::id > ids;
boost::fibers::fiber f1([&c,&ids](){
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 1) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 2) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 3) );
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
// would be blocked because channel is full
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( 4) );
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber f2([&c,&ids](){
BOOST_CHECK( c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 1 == c.value_pop() );
// let potential other fibers run
boost::this_fiber::yield();
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 2 == c.value_pop() );
// let potential other fibers run
boost::this_fiber::yield();
BOOST_CHECK( ! c.is_full() );
ids.push_back( boost::this_fiber::get_id() );
BOOST_CHECK( 3 == c.value_pop() );
// let potential other fibers run
boost::this_fiber::yield();
// value '4' should be in channel
BOOST_CHECK( ! c.is_full() );
BOOST_CHECK( ! c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
// would block because channel is empty
BOOST_CHECK( 4 == c.value_pop() );
BOOST_CHECK( c.is_empty() );
ids.push_back( boost::this_fiber::get_id() );
});
boost::fibers::fiber::id id1 = f1.get_id();
boost::fibers::fiber::id id2 = f2.get_id();
f1.join();
f2.join();
BOOST_CHECK( c.is_empty() );
BOOST_CHECK( 10 == ids.size() );
BOOST_CHECK_EQUAL( id1, ids[0]);
BOOST_CHECK_EQUAL( id1, ids[1]);
BOOST_CHECK_EQUAL( id1, ids[2]);
BOOST_CHECK_EQUAL( id1, ids[3]);
BOOST_CHECK_EQUAL( id2, ids[4]);
BOOST_CHECK_EQUAL( id2, ids[5]);
BOOST_CHECK_EQUAL( id1, ids[6]);
BOOST_CHECK_EQUAL( id2, ids[7]);
BOOST_CHECK_EQUAL( id2, ids[8]);
BOOST_CHECK_EQUAL( id2, ids[9]);
}
void test_moveable()
{
boost::fibers::bounded_channel< moveable > c( 10);
BOOST_CHECK( c.is_empty() );
moveable m1( 3), m2;
BOOST_CHECK( m1.state);
BOOST_CHECK( ! m2.state);
BOOST_CHECK( boost::fibers::channel_op_status::success == c.push( std::move( m1) ) );
BOOST_CHECK( ! m1.state);
BOOST_CHECK( ! m2.state);
BOOST_CHECK( ! c.is_empty() );
BOOST_CHECK( boost::fibers::channel_op_status::success == c.pop( m2) );
BOOST_CHECK( ! m1.state);
BOOST_CHECK( m2.state);
BOOST_CHECK_EQUAL( 3, m2.value);
BOOST_CHECK( c.is_empty() );
}
boost::unit_test::test_suite * init_unit_test_suite( int, char* [])
{
boost::unit_test::test_suite * test =
BOOST_TEST_SUITE("Boost.Fiber: bounded_channel test suite");
test->add( BOOST_TEST_CASE( & test_zero_wm_1) );
test->add( BOOST_TEST_CASE( & test_zero_wm_2) );
test->add( BOOST_TEST_CASE( & test_hwm_less_lwm) );
test->add( BOOST_TEST_CASE( & test_push) );
test->add( BOOST_TEST_CASE( & test_push_closed) );
test->add( BOOST_TEST_CASE( & test_try_push) );
test->add( BOOST_TEST_CASE( & test_try_push_closed) );
test->add( BOOST_TEST_CASE( & test_try_push_full) );
test->add( BOOST_TEST_CASE( & test_push_wait_for) );
test->add( BOOST_TEST_CASE( & test_push_wait_for_closed) );
test->add( BOOST_TEST_CASE( & test_push_wait_for_timeout) );
test->add( BOOST_TEST_CASE( & test_push_wait_until) );
test->add( BOOST_TEST_CASE( & test_push_wait_until_closed) );
test->add( BOOST_TEST_CASE( & test_push_wait_until_timeout) );
test->add( BOOST_TEST_CASE( & test_pop) );
test->add( BOOST_TEST_CASE( & test_pop_closed) );
test->add( BOOST_TEST_CASE( & test_pop_success) );
test->add( BOOST_TEST_CASE( & test_value_pop) );
test->add( BOOST_TEST_CASE( & test_value_pop_closed) );
test->add( BOOST_TEST_CASE( & test_value_pop_success) );
test->add( BOOST_TEST_CASE( & test_try_pop) );
test->add( BOOST_TEST_CASE( & test_try_pop_closed) );
test->add( BOOST_TEST_CASE( & test_try_pop_success) );
test->add( BOOST_TEST_CASE( & test_pop_wait_for) );
test->add( BOOST_TEST_CASE( & test_pop_wait_for_closed) );
test->add( BOOST_TEST_CASE( & test_pop_wait_for_success) );
test->add( BOOST_TEST_CASE( & test_pop_wait_for_timeout) );
test->add( BOOST_TEST_CASE( & test_pop_wait_until) );
test->add( BOOST_TEST_CASE( & test_pop_wait_until_closed) );
test->add( BOOST_TEST_CASE( & test_pop_wait_until_success) );
test->add( BOOST_TEST_CASE( & test_pop_wait_until_timeout) );
test->add( BOOST_TEST_CASE( & test_wm_1) );
test->add( BOOST_TEST_CASE( & test_wm_2) );
test->add( BOOST_TEST_CASE( & test_wm_3) );
test->add( BOOST_TEST_CASE( & test_wm_4) );
test->add( BOOST_TEST_CASE( & test_moveable) );
return test;
}
Reference in New Issue View Git Blame Copy Permalink