Function waitForWorkerTCP

controlplane/k8s_pool_spawn.go:492–494

waitForWorkerTCP connects to a worker over TCP and verifies its health.

(addr, bearerToken string, serverCertPEM []byte, timeout time.Duration)

		p.mu.Unlock()
		// The slot row (if any) stays in spawning state; the janitor's
		// stale-spawning sweep reconciles it, same as a failed spawn below.
		return nil, fmt.Errorf("pool is shutting down")
	}
	p.spawning++
	p.mu.Unlock()
	err = p.spawnWorker(ctx, id, assignment.Image, profile, false)