database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-05 16:15:50 +03:00
Code Activity

MCOL-5153 This increases the size of the multiplier in the guarding

Browse Source 
check in RowAggStorage::increaseSize() so that it doesn't throw w/o a
reason
This commit is contained in:
Roman Nozdrin
2022-07-07 08:56:20 +00:00
parent f866498d42
commit eabca67c8d
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
utils/rowgroup/rowstorage.cpp
View File

@@ -1814,7 +1814,10 @@ void RowAggStorage::increaseSize()
if (fCurData->fSize < maxSize && tryIncreaseInfo()) if (fCurData->fSize < maxSize && tryIncreaseInfo())
return; return;
if (fCurData->fSize * 2 < calcMaxSize(fCurData->fMask + 1)) constexpr size_t maxMaskMultiplierWoRehashing = 1U << (INIT_INFO_INC - 1);
// We don't check for the overflow here b/c it is impractical to has fSize so that multiplication
// overflows.
if (fCurData->fSize * maxMaskMultiplierWoRehashing < calcMaxSize(fCurData->fMask + 1))
{ {
// something strange happens... // something strange happens...
throw logging::IDBExcept(logging::IDBErrorInfo::instance()->errorMsg(logging::ERR_DISKAGG_ERROR), throw logging::IDBExcept(logging::IDBErrorInfo::instance()->errorMsg(logging::ERR_DISKAGG_ERROR),

2
utils/rowgroup/rowstorage.h
View File

@@ -321,6 +321,8 @@ class RowAggStorage
{ {
RowPosHashStoragePtr fHashes; RowPosHashStoragePtr fHashes;
std::unique_ptr<uint8_t[]> fInfo; std::unique_ptr<uint8_t[]> fInfo;
// This is a power of 2 that controls a potential number of hash buckets
// w/o rehashing.
size_t fSize{0}; size_t fSize{0};
size_t fMask{0}; size_t fMask{0};
size_t fMaxSize{0}; size_t fMaxSize{0};