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

Sync::deleteObjects() was not always processing the whole list it

Browse Source 
was given.
This commit is contained in:
Patrick LeBlanc
2019-05-30 17:01:32 -05:00
parent 80cd06909d
commit 193c95f043
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/Synchronizer.cpp
View File

@@ -116,12 +116,9 @@ void Synchronizer::deletedObjects(const vector<string> &keys)
{ {
auto it = pendingOps.find(key); auto it = pendingOps.find(key);
if (it != pendingOps.end()) if (it != pendingOps.end())
{
it->second->opFlags |= DELETE; it->second->opFlags |= DELETE;
return; else
} pendingOps[key] = boost::shared_ptr<PendingOps>(new PendingOps(DELETE));
//makeJob(key);
pendingOps[key] = boost::shared_ptr<PendingOps>(new PendingOps(DELETE));
} }
// would be good to signal to the things in opsInProgress that these were deleted. That would // would be good to signal to the things in opsInProgress that these were deleted. That would
// quiet down the logging somewhat. How to do that efficiently, and w/o gaps or deadlock... // quiet down the logging somewhat. How to do that efficiently, and w/o gaps or deadlock...