mirror of https://github.com/docker/docs.git
70 lines
1.8 KiB
Go
70 lines
1.8 KiB
Go
// +build windows
|
|
|
|
package distribution
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"os"
|
|
|
|
"github.com/docker/distribution"
|
|
"github.com/docker/distribution/context"
|
|
"github.com/docker/distribution/manifest/schema1"
|
|
"github.com/docker/distribution/manifest/schema2"
|
|
"github.com/docker/distribution/registry/client/transport"
|
|
"github.com/docker/docker/image"
|
|
)
|
|
|
|
func detectBaseLayer(is image.Store, m *schema1.Manifest, rootFS *image.RootFS) error {
|
|
v1img := &image.V1Image{}
|
|
if err := json.Unmarshal([]byte(m.History[len(m.History)-1].V1Compatibility), v1img); err != nil {
|
|
return err
|
|
}
|
|
if v1img.Parent == "" {
|
|
return fmt.Errorf("Last layer %q does not have a base layer reference", v1img.ID)
|
|
}
|
|
// There must be an image that already references the baselayer.
|
|
for _, img := range is.Map() {
|
|
if img.RootFS.Type == image.TypeLayersWithBase && img.RootFS.BaseLayerID() == v1img.Parent {
|
|
rootFS.BaseLayer = img.RootFS.BaseLayer
|
|
rootFS.Type = image.TypeLayersWithBase
|
|
return nil
|
|
}
|
|
}
|
|
return fmt.Errorf("Invalid base layer %q", v1img.Parent)
|
|
}
|
|
|
|
var _ distribution.Describable = &v2LayerDescriptor{}
|
|
|
|
func (ld *v2LayerDescriptor) Descriptor() distribution.Descriptor {
|
|
if ld.src.MediaType == schema2.MediaTypeForeignLayer && len(ld.src.URLs) > 0 {
|
|
return ld.src
|
|
}
|
|
return distribution.Descriptor{}
|
|
}
|
|
|
|
func (ld *v2LayerDescriptor) open(ctx context.Context) (distribution.ReadSeekCloser, error) {
|
|
if len(ld.src.URLs) == 0 {
|
|
blobs := ld.repo.Blobs(ctx)
|
|
return blobs.Open(ctx, ld.digest)
|
|
}
|
|
|
|
var (
|
|
err error
|
|
rsc distribution.ReadSeekCloser
|
|
)
|
|
|
|
// Find the first URL that results in a 200 result code.
|
|
for _, url := range ld.src.URLs {
|
|
rsc = transport.NewHTTPReadSeeker(http.DefaultClient, url, nil)
|
|
_, err = rsc.Seek(0, os.SEEK_SET)
|
|
if err == nil {
|
|
break
|
|
}
|
|
rsc.Close()
|
|
rsc = nil
|
|
}
|
|
return rsc, err
|
|
}
|