Global compose lock

Signed-off-by: apostasie <[email protected]>
containerd · Oct 15, 2024 · 2c3deb8 · 2c3deb8
1 parent 62a8286
commit 2c3deb8
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/pkg/cmd/compose/compose.go b/pkg/cmd/compose/compose.go
@@ -35,14 +35,24 @@ import (
  "github.com/containerd/nerdctl/v2/pkg/composer/serviceparser"
  "github.com/containerd/nerdctl/v2/pkg/imgutil"
  "github.com/containerd/nerdctl/v2/pkg/ipfs"
+ "github.com/containerd/nerdctl/v2/pkg/lockutil"
  "github.com/containerd/nerdctl/v2/pkg/netutil"
  "github.com/containerd/nerdctl/v2/pkg/referenceutil"
  "github.com/containerd/nerdctl/v2/pkg/signutil"
  "github.com/containerd/nerdctl/v2/pkg/strutil"
 )
 
+//nolint:unused
+var locked *os.File
+
 // New returns a new *composer.Composer.
 func New(client *containerd.Client, globalOptions types.GlobalCommandOptions, options composer.Options, stdout, stderr io.Writer) (*composer.Composer, error) {
+ var err error
+ locked, err = lockutil.Lock(globalOptions.DataRoot)
+ if err != nil {
+ return nil, err
+ }
+
  cniEnv, err := netutil.NewCNIEnv(globalOptions.CNIPath, globalOptions.CNINetConfPath, netutil.WithNamespace(globalOptions.Namespace), netutil.WithDefaultNetwork())
  if err != nil {
  return nil, err