Method Stop

pkg/tools/lifecycle/supervisor.go:402–436

Stop tears the supervisor down. Idempotent. Blocks until the underlying session is closed.

(ctx context.Context)

// Stop tears the supervisor down. Idempotent. Blocks until the underlying
// session is closed.
func (s *Supervisor) Stop(ctx context.Context) error {
	s.mu.Lock()
	if s.stopping {
		watchDone := s.watchDone
		s.mu.Unlock()
		return waitForWatcher(ctx, watchDone)
	}
	s.stopping = true
	sess := s.session
	s.session = nil
	watchDone := s.watchDone
	pending := s.inflightConnect
	s.inflightConnect = nil
	s.mu.Unlock()

	s.tracker.Set(StateStopped)
	s.signalDone()

	// Reap a Connect left in flight by a startup timeout so its eventual
	// session is closed rather than leaked. Runs in the background: a wedged
	// handshake must not block Stop.
	if pending != nil {
		go s.reapPendingConnect(context.WithoutCancel(ctx), pending)
	}

	var closeErr error
	if sess != nil {
		closeErr = sess.Close(context.WithoutCancel(ctx))
	}
	waitErr := waitForWatcher(ctx, watchDone)
	if closeErr != nil && ctx.Err() == nil {
		return closeErr
	}
	return waitErr
}

func waitForWatcher(ctx context.Context, done <-chan struct{}) error {
	if done == nil {