/*
This file is a part of libcds - Concurrent Data Structures library
- (C) Copyright Maxim Khizhinsky (libcds.dev@gmail.com) 2006-2016
+ (C) Copyright Maxim Khizhinsky (libcds.dev@gmail.com) 2006-2017
Source code repo: http://github.com/khizmax/libcds/
Download: http://sourceforge.net/projects/libcds/files/
else
m_FlatCombining.combine( op_push, pRec, *this );
- assert( pRec->is_done() );
+ assert( pRec->is_done());
m_FlatCombining.release_record( pRec );
m_FlatCombining.internal_statistics().onPush();
return true;
else
m_FlatCombining.combine( op_pop, pRec, *this );
- assert( pRec->is_done() );
+ assert( pRec->is_done());
m_FlatCombining.release_record( pRec );
m_FlatCombining.internal_statistics().onPop( pRec->bEmpty );
else
m_FlatCombining.combine( bDispose ? op_clear_and_dispose : op_clear, pRec, *this );
- assert( pRec->is_done() );
+ assert( pRec->is_done());
m_FlatCombining.release_record( pRec );
}
return m_FlatCombining.statistics();
}
-
public: // flat combining cooperation, not for direct use!
//@cond
/// Flat combining supporting function. Do not call it directly!
{
assert( pRec );
- // this function is called under FC mutex, so switch TSan off
- CDS_TSAN_ANNOTATE_IGNORE_RW_BEGIN;
- switch ( pRec->op() ) {
+ switch ( pRec->op()) {
case op_push:
assert( pRec->pVal );
- m_Stack.push_front( *(pRec->pVal ) );
+ m_Stack.push_front( *(pRec->pVal ));
break;
case op_pop:
pRec->bEmpty = m_Stack.empty();
m_Stack.clear();
break;
case op_clear_and_dispose:
- m_Stack.clear_and_dispose( disposer() );
+ m_Stack.clear_and_dispose( disposer());
break;
default:
assert(false);
break;
}
- CDS_TSAN_ANNOTATE_IGNORE_RW_END;
}
/// Batch-processing flat combining
void fc_process( typename fc_kernel::iterator itBegin, typename fc_kernel::iterator itEnd )
{
- // this function is called under FC mutex, so switch TSan off
- CDS_TSAN_ANNOTATE_IGNORE_RW_BEGIN;
-
typedef typename fc_kernel::iterator fc_iterator;
for ( fc_iterator it = itBegin, itPrev = itEnd; it != itEnd; ++it ) {
- switch ( it->op() ) {
+ switch ( it->op( atomics::memory_order_acquire )) {
case op_push:
case op_pop:
if ( itPrev != itEnd && collide( *itPrev, *it ))
break;
}
}
- CDS_TSAN_ANNOTATE_IGNORE_RW_END;
}
//@endcond
//@cond
bool collide( fc_record& rec1, fc_record& rec2 )
{
- switch ( rec1.op() ) {
+ switch ( rec1.op()) {
case op_push:
if ( rec2.op() == op_pop ) {
assert(rec1.pVal);