Method execute

handlers/stream/handler.go:94–143

execute handles the actual streaming logic

()

// execute handles the actual streaming logic
func (s *request) execute() *server.Error {
	s.Monitoring().Stats().IncImagesInProgress()
	defer s.Monitoring().Stats().DecImagesInProgress()

	ctx, cancelSpan := s.Monitoring().StartSpan(s.imageRequest.Context(), "Streaming image", nil)
	defer cancelSpan()

	// Passthrough request headers from the original request
	requestHeaders := s.getImageRequestHeaders()
	cookieJar, err := s.getCookieJar()
	if err != nil {
		return s.wrapError(err)
	}

	// Build the request to fetch the image
	r, err := s.Fetcher().BuildRequest(ctx, s.imageURL, requestHeaders, cookieJar)
	if r != nil {
		defer r.Cancel()
	}
	if err != nil {
		return s.wrapError(err)
	}

	// Send the request to fetch the image
	res, err := r.Send()
	if res != nil {
		defer res.Body.Close()
	}
	if err != nil {
		return s.wrapError(err)
	}

	// Output streaming response headers
	s.rw.SetOriginHeaders(res.Header)
	s.rw.Passthrough(s.handler.config.PassthroughResponseHeaders...) // NOTE: priority? This is lowest as it was
	s.rw.SetContentLength(int(res.ContentLength))
	s.rw.SetCanonical(s.imageURL)
	s.rw.SetExpires(s.opts.GetTime(keys.Expires))

	// Set the Content-Disposition header
	s.setContentDisposition(r.URL().Path, res)

	// Copy the status code from the original response
	s.rw.WriteHeader(res.StatusCode)

	// Write the actual data
	s.streamData(res)

	return nil
}

// getCookieJar returns non-empty cookie jar if cookie passthrough is enabled
func (s *request) getCookieJar() (http.CookieJar, error) {