Merge pull request #3432 from crosbymichael/stress-size

Add new shims for checking binary sizes and concurrent exec

cmd/containerd-stress/exec_worker.go

@@ -18,6 +18,7 @@ package main
 
 import (
 	"context"
+	"fmt"
 	"strings"
 	"syscall"
 	"time"
@@ -38,8 +39,9 @@ func (w *execWorker) exec(ctx, tctx context.Context) {
 		w.wg.Done()
 		logrus.Infof("worker %d finished", w.id)
 	}()
-	c, err := w.client.NewContainer(ctx, "exec-container",
+	id := fmt.Sprintf("exec-container-%d", w.id)
-		containerd.WithNewSnapshot("exec-container", w.image),
+	c, err := w.client.NewContainer(ctx, id,
+		containerd.WithNewSnapshot(id, w.image),
 		containerd.WithNewSpec(oci.WithImageConfig(w.image), oci.WithUsername("games"), oci.WithProcessArgs("sleep", "30d")),
 	)
 	if err != nil {

cmd/containerd-stress/main.go

@@ -257,10 +257,11 @@ func test(c config) error {
 	}
 	var exec *execWorker
 	if c.Exec {
+		for i := c.Concurrency; i < c.Concurrency+c.Concurrency; i++ {
 			wg.Add(1)
 			exec = &execWorker{
 				worker: worker{
-				id:     c.Concurrency,
+					id:     i,
 					wg:     &wg,
 					image:  image,
 					client: client,
@@ -269,6 +270,7 @@ func test(c config) error {
 			}
 			go exec.exec(ctx, tctx)
 		}
+	}
 
 	// start the timer and run the worker
 	r.start()

cmd/containerd-stress/size.go

@@ -27,6 +27,8 @@ var binaries = []string{
 	"ctr",
 	"containerd",
 	"containerd-shim",
+	"containerd-shim-runc-v1",
+	"containerd-shim-runc-v2",
 }
 
 // checkBinarySizes checks and reports the binary sizes for the containerd compiled binaries to prometheus