浏览代码

Merge pull request #45557 from crazy-max/fix-worker-id

build: use daemon id as worker id for the graph driver controller
Bjorn Neergaard 2 年之前
父节点
当前提交
ccd834ea25
共有 4 个文件被更改,包括 8 次插入2 次删除
  1. 1 0
      builder/builder-next/builder.go
  2. 1 2
      builder/builder-next/controller.go
  3. 1 0
      cmd/dockerd/daemon.go
  4. 5 0
      daemon/daemon.go

+ 1 - 0
builder/builder-next/builder.go

@@ -78,6 +78,7 @@ var cacheFields = map[string]bool{
 type Opt struct {
 type Opt struct {
 	SessionManager      *session.Manager
 	SessionManager      *session.Manager
 	Root                string
 	Root                string
+	EngineID            string
 	Dist                images.DistributionServices
 	Dist                images.DistributionServices
 	ImageTagger         mobyexporter.ImageTagger
 	ImageTagger         mobyexporter.ImageTagger
 	NetworkController   *libnetwork.Controller
 	NetworkController   *libnetwork.Controller

+ 1 - 2
builder/builder-next/controller.go

@@ -16,7 +16,6 @@ import (
 	"github.com/docker/docker/builder/builder-next/adapters/containerimage"
 	"github.com/docker/docker/builder/builder-next/adapters/containerimage"
 	"github.com/docker/docker/builder/builder-next/adapters/localinlinecache"
 	"github.com/docker/docker/builder/builder-next/adapters/localinlinecache"
 	"github.com/docker/docker/builder/builder-next/adapters/snapshot"
 	"github.com/docker/docker/builder/builder-next/adapters/snapshot"
-	"github.com/docker/docker/builder/builder-next/exporter"
 	"github.com/docker/docker/builder/builder-next/exporter/mobyexporter"
 	"github.com/docker/docker/builder/builder-next/exporter/mobyexporter"
 	"github.com/docker/docker/builder/builder-next/imagerefchecker"
 	"github.com/docker/docker/builder/builder-next/imagerefchecker"
 	mobyworker "github.com/docker/docker/builder/builder-next/worker"
 	mobyworker "github.com/docker/docker/builder/builder-next/worker"
@@ -312,7 +311,7 @@ func newGraphDriverController(ctx context.Context, rt http.RoundTripper, opt Opt
 	}
 	}
 
 
 	wopt := mobyworker.Opt{
 	wopt := mobyworker.Opt{
-		ID:                exporter.Moby,
+		ID:                opt.EngineID,
 		ContentStore:      store,
 		ContentStore:      store,
 		CacheManager:      cm,
 		CacheManager:      cm,
 		GCPolicy:          gcPolicy,
 		GCPolicy:          gcPolicy,

+ 1 - 0
cmd/dockerd/daemon.go

@@ -351,6 +351,7 @@ func newRouterOptions(ctx context.Context, config *config.Config, d *daemon.Daem
 	bk, err := buildkit.New(ctx, buildkit.Opt{
 	bk, err := buildkit.New(ctx, buildkit.Opt{
 		SessionManager:      sm,
 		SessionManager:      sm,
 		Root:                filepath.Join(config.Root, "buildkit"),
 		Root:                filepath.Join(config.Root, "buildkit"),
+		EngineID:            d.ID(),
 		Dist:                d.DistributionServices(),
 		Dist:                d.DistributionServices(),
 		ImageTagger:         d.ImageService(),
 		ImageTagger:         d.ImageService(),
 		NetworkController:   d.NetworkController(),
 		NetworkController:   d.NetworkController(),

+ 5 - 0
daemon/daemon.go

@@ -131,6 +131,11 @@ type Daemon struct {
 	mdDB *bbolt.DB
 	mdDB *bbolt.DB
 }
 }
 
 
+// ID returns the daemon id
+func (daemon *Daemon) ID() string {
+	return daemon.id
+}
+
 // StoreHosts stores the addresses the daemon is listening on
 // StoreHosts stores the addresses the daemon is listening on
 func (daemon *Daemon) StoreHosts(hosts []string) {
 func (daemon *Daemon) StoreHosts(hosts []string) {
 	if daemon.hosts == nil {
 	if daemon.hosts == nil {