do not rebroadcast diff sync

drpcorg · Nov 29, 2024 · 2f84806 · 2f84806
1 parent 6d96062
commit 2f84806
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sync.go b/sync.go
@@ -562,19 +562,21 @@ func (sync *Syncer) Drain(ctx context.Context, recs protocol.Records) (err error
 		fallthrough
 
 	case SendDiff:
+		broadcast := false
 		lit := LastLit(recs)
 		if lit != 'D' && lit != 'V' {
 			if lit == 'B' {
 				sync.SetDrainState(ctx, SendNone)
 			} else {
+				broadcast = true
 				sync.SetDrainState(ctx, SendLive)
 			}
 		}
 		if sync.Mode&SyncLive != 0 {
 			sync.resetPingTimer()
 		}
 		err = sync.Host.Drain(sync.logCtx(ctx), recs)
-		if err == nil {
+		if err == nil && broadcast {
 			sync.Host.Broadcast(sync.logCtx(ctx), recs, sync.Name)
 		}