Merge pull request moby#4088 from tonistiigi/v0.12.1-picks

[v0.12.1] cherry-picks

Author: tonistiigi

cmd/buildkitd/main.go

@@ -663,7 +663,8 @@ func newController(c *cli.Context, cfg *config.Config) (*control.Controller, err
 	if tc != nil {
 		traceSocket = traceSocketPath(cfg.Root)
 		if err := runTraceController(traceSocket, tc); err != nil {
-			return nil, err
+			logrus.Warnf("failed set up otel-grpc controller: %v", err)
+			traceSocket = ""
 		}
 	}
 

executor/resources/monitor.go

@@ -56,6 +56,10 @@ func (r *cgroupRecord) Start() {
 	r.closeSampler = s.Close
 }
 
+func (r *cgroupRecord) Close() {
+	r.close()
+}
+
 func (r *cgroupRecord) CloseAsync(next func(context.Context) error) error {
 	go func() {
 		r.close()
@@ -160,6 +164,9 @@ func (r *nopRecord) Samples() (*types.Samples, error) {
 	return nil, nil
 }
 
+func (r *nopRecord) Close() {
+}
+
 func (r *nopRecord) CloseAsync(next func(context.Context) error) error {
 	return next(context.TODO())
 }

executor/resources/types/types.go

@@ -9,6 +9,7 @@ import (
 
 type Recorder interface {
 	Start()
+	Close()
 	CloseAsync(func(context.Context) error) error
 	Wait() error
 	Samples() (*Samples, error)

executor/runcexecutor/executor.go

@@ -335,6 +335,9 @@ func (w *runcExecutor) Run(ctx context.Context, id string, root executor.Mount,
 
 	err = exitError(ctx, err)
 	if err != nil {
+		if rec != nil {
+			rec.Close()
+		}
 		releaseContainer(context.TODO())
 		return nil, err
 	}