Source code repo: http://github.com/khizmax/libcds/
Download: http://sourceforge.net/projects/libcds/files/
-
+
Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are met:
std::vector<size_t>& arrData = fixture.m_arrData;
for ( size_t i = 0; i < arrData.size(); ++i ) {
- if ( rSet.insert( key_type( arrData[i], id() )))
+ if ( rSet.insert( key_type( arrData[i], id())))
++m_nInsertSuccess;
else
++m_nInsertFailed;
update_functor f;
for ( size_t i = arrData.size() - 1; i > 0; --i ) {
if ( arrData[i] & 1 )
- rSet.update( key_type( arrData[i], id() ), f, true );
+ rSet.update( key_type( arrData[i], id()), f, true );
}
fixture.m_nInsThreadCount.fetch_sub( 1, atomics::memory_order_release );
struct eraser {
static bool erase( SetType& s, size_t key, size_t /*thread*/)
{
- return s.erase_with( key, key_less() );
+ return s.erase_with( key, key_less());
}
};
size_t nExtractFailed = 0;
for ( size_t i = 0; i < pool.size(); ++i ) {
cds_test::thread& thr = pool.get( i );
- switch ( thr.type() ) {
+ switch ( thr.type()) {
case inserter_thread:
{
insert_thread& inserter = static_cast<insert_thread&>( thr );
check_before_clear( testSet );
testSet.clear();
- EXPECT_TRUE( testSet.empty() ) << "set.size=" << testSet.size();
+ EXPECT_TRUE( testSet.empty()) << "set.size=" << testSet.size();
additional_check( testSet );
print_stat( propout(), testSet );