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

Fixed a bug in the new extentmap saving code.

Browse Source
This commit is contained in:
Patrick LeBlanc
2019-06-14 11:50:47 -05:00
parent 9e42ddf72c
commit bcdd76adc0
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
versioning/BRM/extentmap.cpp
View File

@ -1493,7 +1493,7 @@ void ExtentMap::save(const string& filename)
} }
allocdSize = fEMShminfo->allocdSize / sizeof(EMEntry); allocdSize = fEMShminfo->allocdSize / sizeof(EMEntry);
const int emEntrySize = sizeof(EMEntry); //const int emEntrySize = sizeof(EMEntry);
int first = -1, last = -1, err; int first = -1, last = -1, err;
size_t progress, writeSize; size_t progress, writeSize;
@ -1504,7 +1504,7 @@ void ExtentMap::save(const string& filename)
else if (fExtentMap[i].range.size <= 0 && first != -1) else if (fExtentMap[i].range.size <= 0 && first != -1)
{ {
last = i; last = i;
writeSize = (last - first) * emEntrySize; writeSize = (last - first) * sizeof(EMEntry);
progress = 0; progress = 0;
char *writePos = (char *) &fExtentMap[first]; char *writePos = (char *) &fExtentMap[first];
while (progress < writeSize) while (progress < writeSize)
@ -1523,7 +1523,7 @@ void ExtentMap::save(const string& filename)
} }
if (first != -1) if (first != -1)
{ {
writeSize = (allocdSize - first) * emEntrySize; writeSize = (allocdSize - first) * sizeof(EMEntry);
progress = 0; progress = 0;
char *writePos = (char *) &fExtentMap[first]; char *writePos = (char *) &fExtentMap[first];
while (progress < writeSize) while (progress < writeSize)
@ -1539,14 +1539,15 @@ void ExtentMap::save(const string& filename)
} }
} }
allocdSize = fFLShminfo->allocdSize / sizeof(InlineLBIDRange); //allocdSize = fFLShminfo->allocdSize / sizeof(InlineLBIDRange);
//const int inlineLbidRangeSize = sizeof(InlineLBIDRange); //const int inlineLbidRangeSize = sizeof(InlineLBIDRange);
progress = 0; progress = 0;
writeSize = fFLShminfo->allocdSize;
char *writePos = (char *) fFreeList; char *writePos = (char *) fFreeList;
while (progress < (size_t) allocdSize) while (progress < writeSize)
{ {
err = out->write(writePos + progress, allocdSize - progress); err = out->write(writePos + progress, writeSize - progress);
if (err < 0) if (err < 0)
{ {
releaseFreeList(READ); releaseFreeList(READ);