Do not lose flusher queue entries when an "older object rescan" happens in parallel with flushing of an older version of another object

2021-07-18 01:20:54 +03:00
parent e74af9745e
commit 148ff04aa8
1 changed files with 6 additions and 1 deletions
@@ -377,7 +377,12 @@ stop_flusher:
                        else
                        {
                            repeat_it = flusher->sync_to_repeat.find(cur.oid);
-                            if (repeat_it == flusher->sync_to_repeat.end())
+                            if (repeat_it != flusher->sync_to_repeat.end())
+                            {
+                                if (repeat_it->second < cur.version)
+                                    repeat_it->second = cur.version;
+                            }
+                            else
                            {
                                flusher->sync_to_repeat[cur.oid] = 0;
                                break;