package worker import ( "bufio" "errors" "fmt" "os" "path/filepath" "strconv" "syscall" "time" "golang.org/x/sys/unix" "github.com/codeskyblue/go-sh" ) type cgroupHook struct { emptyHook basePath string baseGroup string created bool subsystem string memLimit string } func newCgroupHook(p mirrorProvider, basePath, baseGroup, subsystem, memLimit string) *cgroupHook { if basePath == "" { basePath = "/sys/fs/cgroup" } if baseGroup == "" { baseGroup = "tunasync" } if subsystem == "" { subsystem = "cpu" } return &cgroupHook{ emptyHook: emptyHook{ provider: p, }, basePath: basePath, baseGroup: baseGroup, subsystem: subsystem, } } func (c *cgroupHook) preExec() error { c.created = true if err := sh.Command("cgcreate", "-g", c.Cgroup()).Run(); err != nil { return err } if c.subsystem != "memory" { return nil } if c.memLimit != "" { gname := fmt.Sprintf("%s/%s", c.baseGroup, c.provider.Name()) return sh.Command( "cgset", "-r", fmt.Sprintf("memory.limit_in_bytes=%s", c.memLimit), gname, ).Run() } return nil } func (c *cgroupHook) postExec() error { err := c.killAll() if err != nil { logger.Errorf("Error killing tasks: %s", err.Error()) } c.created = false return sh.Command("cgdelete", c.Cgroup()).Run() } func (c *cgroupHook) Cgroup() string { name := c.provider.Name() return fmt.Sprintf("%s:%s/%s", c.subsystem, c.baseGroup, name) } func (c *cgroupHook) killAll() error { if !c.created { return nil } name := c.provider.Name() readTaskList := func() ([]int, error) { taskList := []int{} taskFile, err := os.Open(filepath.Join(c.basePath, c.subsystem, c.baseGroup, name, "tasks")) if err != nil { return taskList, err } defer taskFile.Close() scanner := bufio.NewScanner(taskFile) for scanner.Scan() { pid, err := strconv.Atoi(scanner.Text()) if err != nil { return taskList, err } taskList = append(taskList, pid) } return taskList, nil } for i := 0; i < 4; i++ { if i == 3 { return errors.New("Unable to kill all child tasks") } taskList, err := readTaskList() if err != nil { return err } if len(taskList) == 0 { return nil } for _, pid := range taskList { // TODO: deal with defunct processes logger.Debugf("Killing process: %d", pid) unix.Kill(pid, syscall.SIGKILL) } // sleep 10ms for the first round, and 1.01s, 2.01s, 3.01s for the rest time.Sleep(time.Duration(i)*time.Second + 10*time.Millisecond) } return nil }