Directly use go cni bandwidth options and expose them with ctr args

Signed-off-by: Yakul Garg <2000yeshu@gmail.com>
neverinstall · Mar 28, 2024 · 5101b94 · 5101b94
1 parent 70024e7
commit 5101b94
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 4 deletions.
diff --git a/cmd/ctr/commands/cni.go b/cmd/ctr/commands/cni.go
@@ -38,7 +38,8 @@ const (
 
 // ctr pass cni network metadata to containerd if ctr run use option of --cni
 type NetworkMetaData struct {
-	EnableCni bool
+	EnableCni            bool
+	CniBandwidthConfFile string
 }
 
 func FullID(ctx context.Context, c containerd.Container) string {

diff --git a/cmd/ctr/commands/run/run.go b/cmd/ctr/commands/run/run.go
@@ -123,6 +123,10 @@ var Command = cli.Command{
 			Name:  "cni",
 			Usage: "Enable cni networking for the container",
 		},
+		cli.Uint64Flag{
+			Name:  "cni-bandwidth-conf",
+			Usage: "Cni conf for bandwidth plugin",
+		},
 	}, append(platformRunFlags,
 		append(append(commands.SnapshotterFlags, []cli.Flag{commands.SnapshotterLabels}...),
 			commands.ContainerFlags...)...)...),
@@ -182,7 +186,7 @@ var Command = cli.Command{
 		}
 		var network gocni.CNI
 		if enableCNI {
-			if network, err = gocni.New(gocni.WithDefaultConf); err != nil {
+			if network, err = gocni.New(gocni.WithDefaultConf, gocni.WithConfFile(context.String("cni-bandwidth-conf"))); err != nil {
 				return err
 			}
 		}

diff --git a/cmd/ctr/commands/run/run_unix.go b/cmd/ctr/commands/run/run_unix.go
@@ -245,6 +245,9 @@ func NewContainer(ctx gocontext.Context, client *containerd.Client, context *cli
 
 		if context.Bool("cni") {
 			cniMeta := &commands.NetworkMetaData{EnableCni: true}
+
+			cniMeta.CniBandwidthConfFile = context.String("cni-bandwidth-conf")
+
 			cOpts = append(cOpts, containerd.WithContainerExtension(commands.CtrCniMetadataExtension, cniMeta))
 		}
 		if caps := context.StringSlice("cap-add"); len(caps) > 0 {

diff --git a/cmd/ctr/commands/tasks/kill.go b/cmd/ctr/commands/tasks/kill.go
@@ -50,9 +50,16 @@ func RemoveCniNetworkIfExist(ctx context.Context, container containerd.Container
 
 	var network gocni.CNI
 	if networkMetaData.EnableCni {
-		if network, err = gocni.New(gocni.WithDefaultConf); err != nil {
-			return err
+		if networkMetaData.CniBandwidthConfFile == "" {
+			if network, err = gocni.New(gocni.WithDefaultConf); err != nil {
+				return err
+			}
+		} else {
+			if network, err = gocni.New(gocni.WithDefaultConf, gocni.WithConfFile(networkMetaData.CniBandwidthConfFile)); err != nil {
+				return err
+			}
 		}
+
 		if err := network.Remove(ctx, commands.FullID(ctx, container), ""); err != nil {
 			logrus.WithError(err).Error("network remove error")
 			return err