Function waitForDaemonStart

internal/cli/daemon.go:191–241

(ctx context.Context, deps commandDeps, child daemonProcess)

}

func waitForDaemonStart(ctx context.Context, deps commandDeps, child daemonProcess) (DaemonStatus, error) {
	if child == nil {
		return DaemonStatus{}, errors.New("cli: detached daemon process is required")
	}
	childPID := child.PID()
	if childPID <= 0 {
		return DaemonStatus{}, errors.New("cli: detached daemon process pid is required")
	}
	waitCtx := ctx
	if waitCtx == nil {
		waitCtx = context.Background()
	}
	if _, hasDeadline := waitCtx.Deadline(); !hasDeadline {
		var cancel context.CancelFunc
		waitCtx, cancel = context.WithTimeout(waitCtx, deps.startTimeout)
		defer cancel()
	}

	client, err := clientFromDeps(deps)
	if err != nil {
		return DaemonStatus{}, err
	}

	processAlive := deps.processAlive
	if processAlive == nil {
		processAlive = procutil.Alive
	}

	ticker := time.NewTicker(deps.pollInterval)
	defer ticker.Stop()

	for {
		select {
		case <-child.Done():
			if err := child.Wait(); err != nil {
				return DaemonStatus{}, fmt.Errorf("cli: detached daemon exited before readiness: %w", err)
			}
			return DaemonStatus{}, errors.New("cli: detached daemon exited before readiness")
		case <-waitCtx.Done():
			return DaemonStatus{}, fmt.Errorf("cli: daemon did not become ready before timeout: %w", waitCtx.Err())
		case <-ticker.C:
			status, statusErr := client.DaemonStatus(waitCtx)
			if statusErr == nil && status.PID == childPID {
				return status, nil
			}
			if !processAlive(childPID) {
				return DaemonStatus{}, errors.New("cli: detached daemon exited before readiness")
			}
		}
	}
}

func waitForDaemonStop(
	ctx context.Context,