From 96f9db8bb8c0b68de3cebedc455f66422e560a0d Mon Sep 17 00:00:00 2001 From: bigeagle Date: Sun, 4 Dec 2016 22:43:59 +0800 Subject: [PATCH] fix(worker): extended rsync memory limit to 512MB --- worker/cgroup.go | 2 +- worker/cgroup_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/worker/cgroup.go b/worker/cgroup.go index a2d4072..6e3250b 100644 --- a/worker/cgroup.go +++ b/worker/cgroup.go @@ -58,7 +58,7 @@ func (c *cgroupHook) preExec() error { if c.provider.Type() == provRsync || c.provider.Type() == provTwoStageRsync { gname := fmt.Sprintf("%s/%s", c.baseGroup, c.provider.Name()) return sh.Command( - "cgset", "-r", "memory.limit_in_bytes=128M", gname, + "cgset", "-r", "memory.limit_in_bytes=512M", gname, ).Run() } return nil diff --git a/worker/cgroup_test.go b/worker/cgroup_test.go index 8706fac..ffefa8f 100644 --- a/worker/cgroup_test.go +++ b/worker/cgroup_test.go @@ -137,7 +137,7 @@ sleep 30 if cgSubsystem == "memory" { memoLimit, err := ioutil.ReadFile(filepath.Join(cg.basePath, "memory", cg.baseGroup, provider.Name(), "memory.limit_in_bytes")) So(err, ShouldBeNil) - So(strings.Trim(string(memoLimit), "\n"), ShouldEqual, strconv.Itoa(128*1024*1024)) + So(strings.Trim(string(memoLimit), "\n"), ShouldEqual, strconv.Itoa(512*1024*1024)) } cg.postExec() })