瀏覽代碼

LCOW: Add platform to image store

Signed-off-by: John Howard <jhoward@microsoft.com>
John Howard 8 年之前
父節點
當前提交
6c33684987
共有 5 個文件被更改,包括 21 次插入7 次删除
  1. 3 1
      daemon/daemon.go
  2. 9 0
      image/image.go
  3. 3 1
      image/store.go
  4. 3 2
      image/store_test.go
  5. 3 3
      migrate/v1/migratev1_test.go

+ 3 - 1
daemon/daemon.go

@@ -656,7 +656,9 @@ func NewDaemon(config *config.Config, registryService registry.Service, containe
 		return nil, err
 		return nil, err
 	}
 	}
 
 
-	d.imageStore, err = image.NewImageStore(ifs, d.layerStore)
+	// TODO LCOW @jhowardmsft. For now assume it's the runtime OS. This will be modified
+	// as the stores are split in a follow-up commit.
+	d.imageStore, err = image.NewImageStore(ifs, runtime.GOOS, d.layerStore)
 	if err != nil {
 	if err != nil {
 		return nil, err
 		return nil, err
 	}
 	}

+ 9 - 0
image/image.go

@@ -96,6 +96,15 @@ func (img *Image) RunConfig() *container.Config {
 	return img.Config
 	return img.Config
 }
 }
 
 
+// Platform returns the image's operating system. If not populated, defaults to the host runtime OS.
+func (img *Image) Platform() string {
+	os := img.OS
+	if os == "" {
+		os = runtime.GOOS
+	}
+	return os
+}
+
 // MarshalJSON serializes the image to JSON. It sorts the top-level keys so
 // MarshalJSON serializes the image to JSON. It sorts the top-level keys so
 // that JSON that's been manipulated by a push/pull cycle with a legacy
 // that JSON that's been manipulated by a push/pull cycle with a legacy
 // registry won't end up with a different key order.
 // registry won't end up with a different key order.

+ 3 - 1
image/store.go

@@ -42,15 +42,17 @@ type store struct {
 	images    map[ID]*imageMeta
 	images    map[ID]*imageMeta
 	fs        StoreBackend
 	fs        StoreBackend
 	digestSet *digestset.Set
 	digestSet *digestset.Set
+	platform  string
 }
 }
 
 
 // NewImageStore returns new store object for given layer store
 // NewImageStore returns new store object for given layer store
-func NewImageStore(fs StoreBackend, ls LayerGetReleaser) (Store, error) {
+func NewImageStore(fs StoreBackend, platform string, ls LayerGetReleaser) (Store, error) {
 	is := &store{
 	is := &store{
 		ls:        ls,
 		ls:        ls,
 		images:    make(map[ID]*imageMeta),
 		images:    make(map[ID]*imageMeta),
 		fs:        fs,
 		fs:        fs,
 		digestSet: digestset.NewSet(),
 		digestSet: digestset.NewSet(),
+		platform:  platform,
 	}
 	}
 
 
 	// load all current images and retain layers
 	// load all current images and retain layers

+ 3 - 2
image/store_test.go

@@ -1,6 +1,7 @@
 package image
 package image
 
 
 import (
 import (
+	"runtime"
 	"testing"
 	"testing"
 
 
 	"github.com/docker/docker/layer"
 	"github.com/docker/docker/layer"
@@ -25,7 +26,7 @@ func TestRestore(t *testing.T) {
 	err = fs.SetMetadata(id2, "parent", []byte(id1))
 	err = fs.SetMetadata(id2, "parent", []byte(id1))
 	assert.NoError(t, err)
 	assert.NoError(t, err)
 
 
-	is, err := NewImageStore(fs, &mockLayerGetReleaser{})
+	is, err := NewImageStore(fs, runtime.GOOS, &mockLayerGetReleaser{})
 	assert.NoError(t, err)
 	assert.NoError(t, err)
 
 
 	assert.Len(t, is.Map(), 2)
 	assert.Len(t, is.Map(), 2)
@@ -142,7 +143,7 @@ func TestParentReset(t *testing.T) {
 func defaultImageStore(t *testing.T) (Store, func()) {
 func defaultImageStore(t *testing.T) (Store, func()) {
 	fsBackend, cleanup := defaultFSStoreBackend(t)
 	fsBackend, cleanup := defaultFSStoreBackend(t)
 
 
-	store, err := NewImageStore(fsBackend, &mockLayerGetReleaser{})
+	store, err := NewImageStore(fsBackend, runtime.GOOS, &mockLayerGetReleaser{})
 	assert.NoError(t, err)
 	assert.NoError(t, err)
 
 
 	return store, cleanup
 	return store, cleanup

+ 3 - 3
migrate/v1/migratev1_test.go

@@ -94,7 +94,7 @@ func TestMigrateContainers(t *testing.T) {
 		t.Fatal(err)
 		t.Fatal(err)
 	}
 	}
 
 
-	is, err := image.NewImageStore(ifs, ls)
+	is, err := image.NewImageStore(ifs, runtime.GOOS, ls)
 	if err != nil {
 	if err != nil {
 		t.Fatal(err)
 		t.Fatal(err)
 	}
 	}
@@ -172,12 +172,12 @@ func TestMigrateImages(t *testing.T) {
 		t.Fatal(err)
 		t.Fatal(err)
 	}
 	}
 
 
-	is, err := image.NewImageStore(ifs, ls)
+	is, err := image.NewImageStore(ifs, runtime.GOOS, ls)
 	if err != nil {
 	if err != nil {
 		t.Fatal(err)
 		t.Fatal(err)
 	}
 	}
 
 
-	ms, err := metadata.NewFSMetadataStore(filepath.Join(tmpdir, "distribution"))
+	ms, err := metadata.NewFSMetadataStore(filepath.Join(tmpdir, "distribution"), runtime.GOOS)
 	if err != nil {
 	if err != nil {
 		t.Fatal(err)
 		t.Fatal(err)
 	}
 	}