pane_sync_owner.go RawHistoryFolder

1package daemon
2
3// migratePaneSyncOwnerLocked transfers synchronized-output coordination after
4// an ownership commit. The caller must hold p.mu and pass the exact leases
5// returned by publishOwnerLocked. Holding the pane parsing fence keeps PTY
6// writes from observing a coordinator between owners.
7//
8// The returned cleanup must be finished after releasing pane and coordinator
9// locks. It stops detached timers but never joins their workers.
10func (d *Daemon) migratePaneSyncOwnerLocked(p *pane, oldOwner, newOwner paneEffectLease) syncTimerCleanup {
11	var cleanup syncTimerCleanup
12	if p == nil || oldOwner.pane != p || newOwner.pane != p || newOwner.owner == nil || p.owner.Load() != newOwner.owner {
13		return cleanup
14	}
15
16	oldGeneration := p.syncGen
17	if oldOwner.owner != nil && oldOwner.owner.session != nil {
18		if coordinator := oldOwner.owner.session.renderCoordinator(); coordinator != nil {
19			cleanup.append(coordinator.detachSyncBatchGeneration(p, oldGeneration))
20		}
21	}
22	p.syncGen = 0
23	if p.screen == nil || !p.screen.SyncUpdateActive() || newOwner.owner.session == nil || newOwner.owner.tab == nil {
24		return cleanup
25	}
26
27	generation := newOwner.owner.session.syncGen.Add(1)
28	p.syncGen = generation
29	coordinator := newOwner.owner.session.renderCoordinator()
30	if coordinator == nil {
31		return cleanup
32	}
33
34	lease := newOwner
35	renderable := func() bool {
36		return lease.Current() && d.paneRenderable(lease.owner.session, lease.owner.tab, p)
37	}
38	forceEnd := func() {
39		p.mu.Lock()
40		if p.owner.Load() == lease.owner && p.syncGen == generation && p.screen.SyncUpdateActive() {
41			p.screen.ForceSyncEnd()
42		}
43		p.mu.Unlock()
44	}
45	cleanup.append(coordinator.beginSyncBatchWithRenderability(p, generation, renderable, forceEnd))
46	return cleanup
47}