From 340efc879d01ff0bccc7eb66d6aadc23ead5cd96 Mon Sep 17 00:00:00 2001 From: Diptanu Choudhury Date: Wed, 14 Sep 2016 22:56:02 -0700 Subject: [PATCH] Adding cpu resource limits --- client/driver/lxc.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/client/driver/lxc.go b/client/driver/lxc.go index 8eac9d574..5b9d7c7de 100644 --- a/client/driver/lxc.go +++ b/client/driver/lxc.go @@ -182,6 +182,9 @@ func (d *LxcDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, e if err := c.SetMemoryLimit(lxc.ByteSize(task.Resources.MemoryMB) * lxc.MB); err != nil { return nil, fmt.Errorf("unable to set memory limits: %v", err) } + if err := c.SetCgroupItem("cpu.shares", strconv.Itoa(task.Resources.CPU)); err != nil { + return nil, fmt.Errorf("unable to set cpu shares: %v", err) + } handle := lxcDriverHandle{ container: c,