database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-01 06:46:55 +03:00
Code Activity

MCOL-1847. Now parsing NumBlocksPct with Config::fromText().

Browse Source
This commit is contained in:
Patrick LeBlanc
2018-11-20 13:49:04 -06:00
parent de9dc56f21
commit 63bdf451c5
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
primitives/primproc/primproc.cpp
View File

@ -391,7 +391,7 @@ int main(int argc, char* argv[])
int serverQueueSize = 10; int serverQueueSize = 10;
int processorWeight = 8 * 1024; int processorWeight = 8 * 1024;
int processorQueueSize = 10 * 1024; int processorQueueSize = 10 * 1024;
int BRPBlocksPct = 70; int64_t BRPBlocksPct = 70;
uint32_t BRPBlocks = 1887437; uint32_t BRPBlocks = 1887437;
int BRPThreads = 16; int BRPThreads = 16;
int cacheCount = 1; int cacheCount = 1;
@ -526,20 +526,19 @@ int main(int argc, char* argv[])
} }
#else #else
bool cacheInMB = false; bool absCache = false;
if (temp > 0) { if (temp > 0) {
BRPBlocksPct = temp; BRPBlocksPct = temp;
/* MCOL-1847. Did the user specify this in MB or GB? */ /* MCOL-1847. Did the user specify this as an absolute? */
int len = strBlockPct.length(); int len = strBlockPct.length();
if (strBlockPct[len-1] == 'g' || strBlockPct[len-1] == 'm') if ((strBlockPct[len-1] >= 'a' && strBlockPct[len-1] <= 'z') ||
{ (strBlockPct[len-1] >= 'A' && strBlockPct[len-1] <= 'Z')) {
if (strBlockPct[len-1] == 'g') absCache = true;
BRPBlocksPct *= 1024; BRPBlocksPct = Config::fromText(strBlockPct);
cacheInMB = true;
} }
} }
if (cacheInMB) if (absCache)
BRPBlocks = BRPBlocksPct * 128; // 128 blocks per MB BRPBlocks = BRPBlocksPct / 8192;
else else
BRPBlocks = ((BRPBlocksPct / 100.0) * (double) cg.getTotalMemory()) / 8192; BRPBlocks = ((BRPBlocksPct / 100.0) * (double) cg.getTotalMemory()) / 8192;
#endif #endif