broadcast diffs and handshakes

drpcorg · Dec 27, 2024 · 5cf44ed · 5cf44ed
1 parent d963e32
commit 5cf44ed
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sync.go b/sync.go
@@ -629,13 +629,13 @@ func (sync *Syncer) Drain(ctx context.Context, recs protocol.Records) (err error
 		fallthrough
 
 	case SendDiff:
-		broadcast := false
+		broadcast := true
 		lit := LastLit(recs)
 		if lit != 'D' && lit != 'V' {
 			if lit == 'B' {
+				broadcast = false
 				sync.SetDrainState(ctx, SendNone)
 			} else {
-				broadcast = true
 				sync.SetDrainState(ctx, SendLive)
 			}
 		}