render_coordinator_support.go RawHistoryFolder

1package daemon
2
3// Small coordinator accessors stay separate from scheduling and lifecycle
4// transitions, keeping the coordinator state file focused on ownership.
5
6// burstMetricsSnapshot returns a consistent read-only metric view for
7// benchmark reporting without exposing coordinator policy outside this package.
8func (c *renderCoordinator) burstMetricsSnapshot() renderCoordinatorBurstMetricsSnapshot {
9	return renderCoordinatorBurstMetricsSnapshot{
10		invalidations: c.metrics.invalidations.Load(),
11		wakes:         c.metrics.wakes.Load(),
12		coalesced:     c.metrics.coalesced.Load(),
13	}
14}
15
16// attachmentRenderCoordinator returns the coordinator installed for the exact
17// attachment-session identity.
18func attachmentRenderCoordinator(entry *session) *renderCoordinator {
19	if entry == nil || entry.core() == nil {
20		return nil
21	}
22	return entry.core().coordinator.Load()
23}
24
25// installAttachmentRenderCoordinator publishes rc for the exact
26// attachment-session identity.
27func installAttachmentRenderCoordinator(entry *session, rc *renderCoordinator) {
28	if entry == nil || entry.core() == nil {
29		return
30	}
31	entry.core().coordinator.Store(rc)
32}
33
34// renderCoordinator retains the local-only method used by PTY and tab owners.
35func (s *session) renderCoordinator() *renderCoordinator {
36	return attachmentRenderCoordinator(s)
37}
38
39// installRenderCoordinator retains the local-only setup seam used by tests.
40func (s *session) installRenderCoordinator(rc *renderCoordinator) {
41	installAttachmentRenderCoordinator(s, rc)
42}
43
44func (c *renderCoordinator) fireCurrent(watchdog bool) {
45	c.mu.Lock()
46	gen := c.normalLane.generation
47	c.mu.Unlock()
48	c.fire(gen, watchdog, watchdog)
49}