From 34907892499d67a2086386cebcf418100b191ba3 Mon Sep 17 00:00:00 2001 From: Evgeny Date: Sat, 25 Jul 2026 16:49:46 +0300 Subject: [PATCH] =?UTF-8?q?db=5Fsync:=20skip=20SYNC=5FDONE=20in=20count>0?= =?UTF-8?q?=20handler=20when=20received=3D=3D0=20=E2=80=94=20breaks=20bad?= =?UTF-8?q?=5Fsig=20recv=E2=86=92send=20loop=20on=20client=20side?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/db_sync.c | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/db_sync.c b/src/db_sync.c index 1dc8d1f1..427a8685 100644 --- a/src/db_sync.c +++ b/src/db_sync.c @@ -1049,6 +1049,12 @@ static void db_handle_send_data(struct DB_SYNC_INSTANCE* si, uint64_t src, const } uint64_t lch8 = 0; if (mc > 0) db_chain_hash8_at(si, mc - 1, &lch8); + if (received == 0 && resp_count == 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] → SEND_DATA: 0 new records, skip SYNC_DONE (synced=%u)", + SI_SHRT(si), (unsigned long long)(src >> 16), sp ? sp->synced_pos : 0); + return; + } 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);