Method open

util/sourcemeta/resolver.go:160–214

(ctx context.Context)

}

func (r *Resolver) open(ctx context.Context) (gatewayResolver, error) {
	r.startOnce.Do(func() {
		r.started.Store(true)
		buildCtx, cancel := context.WithCancelCause(context.Background())
		r.cancel = cancel

		go func() {
			r.doneErr = r.run(buildCtx, r.ready)
			close(r.done)
		}()
	})

	for {
		r.mu.Lock()
		if r.metaResolver != nil {
			mr := r.metaResolver
			r.mu.Unlock()
			return mr, nil
		}
		if r.openErr != nil {
			err := r.openErr
			r.mu.Unlock()
			return nil, err
		}
		r.mu.Unlock()

		select {
		case mr := <-r.ready:
			r.mu.Lock()
			if r.metaResolver == nil {
				r.metaResolver = mr
				r.openOnce.Do(func() {
					close(r.opened)
				})
			}
			r.mu.Unlock()
		case <-r.done:
			r.mu.Lock()
			if r.metaResolver == nil && r.openErr == nil {
				err := r.doneErr
				if err == nil {
					err = errors.New("gateway build finished without a source metadata resolver")
				}
				r.openErr = err
				r.openOnce.Do(func() {
					close(r.opened)
				})
			}
			r.mu.Unlock()
		case <-r.opened:
		case <-ctx.Done():
			return nil, context.Cause(ctx)
		}
	}
}