feedc0de/boost_unordered
1
0
Fork 0
forked from boostorg/unordered
Code Pull Requests Activity

protected visitation against spurious insertion sentinels

Browse Source
This commit is contained in:
joaquintides
2023-12-27 13:34:34 +01:00
parent 71e9d35ab2
commit 0aab436707
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
include/boost/unordered/detail/foa/concurrent_table.hpp
View File

@@ -1296,6 +1296,20 @@ private:
{f(cast_for(access_mode,type_policy::value_from(*p)));}); {f(cast_for(access_mode,type_policy::value_from(*p)));});
} }
/* check occupation with previous unsynced match */
#if defined(BOOST_UNORDERED_LATCH_FREE)
static bool is_occupied(group_type* pg,std::size_t pos)
{
return reinterpret_cast<std::atomic<unsigned char>*>(pg)[pos]>1;
}
#else
static bool is_occupied(group_type* pg,std::size_t pos)
{
return pg->is_occupied(pos);
}
#endif
#if defined(BOOST_MSVC) #if defined(BOOST_MSVC)
/* warning: forcing value to bool 'true' or 'false' in bool(pred()...) */ /* warning: forcing value to bool 'true' or 'false' in bool(pred()...) */
#pragma warning(push) #pragma warning(push)
@@ -1319,7 +1333,7 @@ private:
do{ do{
auto n=unchecked_countr_zero(mask); auto n=unchecked_countr_zero(mask);
if(BOOST_LIKELY( if(BOOST_LIKELY(
pg->is_occupied(n)&&bool(this->pred()(x,this->key_from(p[n]))))){ is_occupied(pg,n)&&bool(this->pred()(x,this->key_from(p[n]))))){
f(pg,n,p+n); f(pg,n,p+n);
return 1; return 1;
} }
@@ -1378,7 +1392,7 @@ private:
do{ do{
auto n=unchecked_countr_zero(mask); auto n=unchecked_countr_zero(mask);
if(BOOST_LIKELY( if(BOOST_LIKELY(
pg->is_occupied(n)&& is_occupied(pg,n)&&
bool(this->pred()(*it,this->key_from(p[n]))))){ bool(this->pred()(*it,this->key_from(p[n]))))){
f(cast_for(access_mode,type_policy::value_from(p[n]))); f(cast_for(access_mode,type_policy::value_from(p[n])));
++res; ++res;