in pkg/containerd/handler.go [118:138]
func (r *Registry) handleBlob(c pcontext.Context, dgst digest.Digest) {
size, err := r.containerdStore.Size(c, dgst)
if err != nil {
//nolint
c.AbortWithError(http.StatusNotFound, err)
return
}
c.Header(contentLengthHeader, strconv.FormatInt(size, 10))
c.Header(dockerContentDigestHeader, dgst.String())
if c.Request.Method == http.MethodHead {
return
}
err = r.containerdStore.Write(c, c.Writer, dgst)
if err != nil {
//nolint
c.AbortWithError(http.StatusInternalServerError, err)
return
}
}