database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-07 03:22:57 +03:00
Code Activity

fix(rowstorage): SplitMix64 PRNG implementation to replace stdlib MT PRNG that uses /dev/urandom guarded by spinlock (#3050)

Browse Source
This commit is contained in:
drrtuy
2023-12-05 17:30:31 +02:00
committed by GitHub
parent 58e18eeb56
commit 63b032e3fd
2 changed files with 19 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
utils/rowgroup/rowstorage.cpp
View File

@@ -1495,9 +1495,7 @@ RowAggStorage::RowAggStorage(const std::string& tmpDir, RowGroup* rowGroupOut, R
, fTmpDir(tmpDir)
, fRowGroupOut(rowGroupOut)
, fKeysRowGroup(keysRowGroup)
, fRD()
, fRandGen(fRD())
, fRandDistr(0, 100)
, fRandom(reinterpret_cast<std::uintptr_t>(this))
{
char suffix[PATH_MAX];
snprintf(suffix, sizeof(suffix), "/p%u-t%p/", getpid(), this);
@@ -1683,7 +1681,7 @@ void RowAggStorage::dump()
break;
}
int64_t totalMem = fMM->getConfigured();
const int64_t totalMem = fMM->getConfigured();
// If the generations are allowed and there are less than half of
// rowgroups in memory, then we start a new generation
if (fAllowGenerations && fStorage->fLRU->size() < fStorage->fRGDatas.size() / 2 &&
@@ -1691,7 +1689,7 @@ void RowAggStorage::dump()
{
startNewGeneration();
}
else if (fAllowGenerations && freeMem < totalMem / 10 * 3 && fRandDistr(fRandGen) < 30)
else if (fAllowGenerations && freeMem < totalMem / 10 * 3 && nextRandDistib() < 30)
{
startNewGeneration();
}