database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-12-10 22:42:30 +03:00
Code Activity

Added assertions around the file deletes in syncwithjournal.

Browse Source
This commit is contained in:
Patrick LeBlanc
2019-05-21 16:05:27 -05:00
parent 88de938913
commit 0dcbc10b5e
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/Synchronizer.cpp
View File

@@ -491,7 +491,11 @@ void Synchronizer::synchronizeWithJournal(const string &sourceFile, list<string>
count += err; count += err;
} }
cache->rename(key, newKey, size - bf::file_size(oldCachePath)); cache->rename(key, newKey, size - bf::file_size(oldCachePath));
replicator->remove(oldCachePath.string().c_str()); #ifndef NDEBUG
assert(replicator->remove(oldCachePath) == 0);
#else
replicator->remove(oldCachePath);
#endif
} }
// update the metadata for the source file // update the metadata for the source file
@@ -504,7 +508,11 @@ void Synchronizer::synchronizeWithJournal(const string &sourceFile, list<string>
// delete the old object & journal file // delete the old object & journal file
cache->deletedJournal(bf::file_size(journalName)); cache->deletedJournal(bf::file_size(journalName));
replicator->remove(journalName.c_str()); #ifndef NDEBUG
assert(replicator->remove(journalName) == 0);
#else
replicator->remove(journalName);
#endif
cs->deleteObject(key); cs->deleteObject(key);
} }