Заменены \n на реальный символ переноса
This commit is contained in:
@@ -13,10 +13,12 @@ start
|
||||
|
||||
:Группа Storage (≥ 2 UUID из DbStorageSyncGroup);
|
||||
:Захват блокировок sync (lease);
|
||||
:Параллельно: flush + readSyncJournal\nдля каждого Storage;
|
||||
:Параллельно: flush + readSyncJournal
|
||||
для каждого Storage;
|
||||
|
||||
partition "Слияние (StorageSyncJournalMerge)" {
|
||||
:Для каждого пути — запись\nс максимальной ревизией;
|
||||
:Для каждого пути — запись
|
||||
с максимальной ревизией;
|
||||
note right
|
||||
compare: sequence → actorId → createdAt
|
||||
end note
|
||||
@@ -25,14 +27,18 @@ partition "Слияние (StorageSyncJournalMerge)" {
|
||||
while (Есть необработанный путь?) is (да)
|
||||
:winnerEntry = победитель по пути;
|
||||
:sourceStorage = findSourceStorage(winnerEntry);
|
||||
if (operation == UPSERT\nи source == null?) then (да)
|
||||
if (operation == UPSERT
|
||||
и source == null?) then (да)
|
||||
:пропуск пути;
|
||||
else (нет)
|
||||
while (Есть target Storage?) is (да)
|
||||
if (ревизия target ≥ winner?) then (да)
|
||||
:пропуск target;
|
||||
else (нет)
|
||||
:applyEntry:\nUPSERT — copy stream\nDELETE/TRASH — на target\n(recordSyncJournal = false);
|
||||
:applyEntry:
|
||||
UPSERT — copy stream
|
||||
DELETE/TRASH — на target
|
||||
(recordSyncJournal = false);
|
||||
endif
|
||||
endwhile (нет)
|
||||
endif
|
||||
|
||||
Reference in New Issue
Block a user