Method CloseOutChan

pkg/agent/proxy/syncMock/syncMock.go:543–562

CloseOutChan flushes any still-attributable buffered mocks and then closes the outgoing mock channel under the writer lock so an in-flight sendToOutChan cannot race the close. Idempotent; safe to call with outChan still nil. The final FlushOwnedWindows is the shutdown twin of the periodic flush tic

()

// connection handlers have drained, so no new mocks enter the buffer
// between the flush and the close.
func (m *SyncMockManager) CloseOutChan() {
	if m == nil {
		return
	}
	// Graceful-stop drain: flush every still-attributable buffered mock
	// before sealing the channel. The periodic flush ticker stops one step
	// earlier in shutdown, so a late-decoded teardown mock would otherwise be
	// discarded here and orphan its test case.
	m.FlushOwnedWindows()

	m.outChanMu.Lock()
	defer m.outChanMu.Unlock()
	if m.outChanClosed {
		return
	}
	if m.outChan != nil {
		close(m.outChan)
	}
	m.outChanClosed = true
}

// FlushOwnedWindows forwards every buffered mock that can be attributed
// right now — session/connection mocks (reusable, never window-bound) and