db_sync: fix synced_pos overwrite in SYNC_DONE — use max to preserve total_processed advance
This commit is contained in:
1 parent
34404403ef
commit
c9436219a0
1 file changed
+1
-1
+1
-1
@@ -1052,7 +1052,7 @@ static void db_handle_send_data(struct DB_SYNC_INSTANCE* si, uint64_t src, const
|
||||
uint8_t sd[13];
|
||||
sd[0] = DB_MSG_SYNC_DONE; memcpy(sd + 1, &mc, 4); memcpy(sd + 5, &lch8, 8);
|
||||
db_sync_send(si, src, sd, 13);
|
||||
if (sp) { sp->synced_pos = mc > 0 ? mc - 1 : 0; sp->sync_state = 2; sp->sync_start_tb = 0; }
|
||||
if (sp) { uint32_t nsp = mc > 0 ? mc - 1 : 0; if (sp->synced_pos < nsp) sp->synced_pos = nsp; sp->sync_state = 2; sp->sync_start_tb = 0; }
|
||||
DEBUG_INFO(DEBUG_CATEGORY_DB_SYNC, "sync [%s:%04llX] → SYNC_DONE: fc=%u ch8=%016llX synced=%u⇥2",
|
||||
SI_SHRT(si), (unsigned long long)(src >> 16), mc, lch8, sp ? sp->synced_pos : 0);
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user