boostorg/unordered
1
0
Fork 1
mirror of https://github.com/boostorg/unordered.git synced 2025-08-02 04:44:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

monitored wasted nodes

Browse Source
This commit is contained in:
joaquintides
2024-01-27 11:53:48 +01:00
parent 363ef61cf0
commit 99cee83c57
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -56,7 +56,7 @@
#include <iostream> #include <iostream>
#endif #endif
std::atomic<std::size_t> garbage_vector_full=0; std::atomic<std::size_t> nodes_wasted=0;
namespace boost{ namespace boost{
namespace unordered{ namespace unordered{
@@ -521,7 +521,7 @@ public:
} }
} }
garbage_vector_full=0; nodes_wasted=0;
#endif #endif
} }
@@ -572,12 +572,12 @@ public:
} }
std::cout std::cout
<<"version: 2024/01/26 11:15; " <<"version: 2024/01/27 11:50; "
<<"lf: "<<(double)size()/capacity()<<"; " <<"lf: "<<(double)size()/capacity()<<"; "
<<"capacity: "<<capacity()<<"; " <<"capacity: "<<capacity()<<"; "
<<"rehashes: "<<rehashes<<"; " <<"rehashes: "<<rehashes<<"; "
<<"max probe:"<<max_probe<<", " <<"max probe:"<<max_probe<<", "
<<"garbage vector full:"<<garbage_vector_full<<"\n"; <<"nodes wasted:"<<nodes_wasted<<"\n";
} }
#else #else
~concurrent_table()=default; ~concurrent_table()=default;
@@ -2064,6 +2064,7 @@ private:
if(e.epoch.compare_exchange_strong(expected,retired_element::reserved_)){ if(e.epoch.compare_exchange_strong(expected,retired_element::reserved_)){
p=e.p.exchange(p); p=e.p.exchange(p);
if(p){ if(p){
++nodes_wasted;
element_type x{p}; element_type x{p};
this->destroy_element(&x); this->destroy_element(&x);
++v.apos; ++v.apos;
@@ -2077,7 +2078,6 @@ private:
if(expected==retired_element::reserved_){ /* other thread wrote */ if(expected==retired_element::reserved_){ /* other thread wrote */
} }
else{ /* vector full */ else{ /* vector full */
++garbage_vector_full;
garbage_collect(v,max_safe_epoch()); garbage_collect(v,max_safe_epoch());
} }
} }