Method releaseWorkerSocket

controlplane/worker_mgr.go:287–305

releaseWorkerSocket returns a pre-bound socket to the pool for reuse, or closes the listener and removes the socket file for non-pre-bound sockets. Safe to call multiple times; only the first call takes effect. This prevents a race between ShutdownAll and HealthCheckLoop both calling this on the sam

(w *ManagedWorker)

func (p *FlightWorkerPool) returnPrebound(ps *preboundSocket) {
	p.preboundMu.Lock()
	defer p.preboundMu.Unlock()
	p.prebound = append(p.prebound, ps)
}

// releaseWorkerSocket returns a pre-bound socket to the pool for reuse, or
// closes the listener and removes the socket file for non-pre-bound sockets.
// Safe to call multiple times; only the first call takes effect. This prevents
// a race between ShutdownAll and HealthCheckLoop both calling this on the same
// worker, which could otherwise return a pre-bound socket to the pool twice.
func (p *FlightWorkerPool) releaseWorkerSocket(w *ManagedWorker) {
	w.releaseOnce.Do(func() {
		if w.prebound != nil {
			// Verify the socket file still exists before returning to the pool.
			// After an upgrade, the bind mount may be gone and the file missing.
			if _, err := os.Stat(w.prebound.socketPath); err != nil {
				_ = w.prebound.listener.Close()
			} else {
				p.returnPrebound(w.prebound)
			}
			w.prebound = nil
		} else {
			if w.parentListener != nil {