(recursive bool, tType string)
| 526 | } |
| 527 | |
| 528 | func (c *Manager) getTasks(recursive bool, tType string) ([]uint64, error) { |
| 529 | var tasks []uint64 |
| 530 | err := filepath.Walk(c.path, func(p string, info fs.FileInfo, err error) error { |
| 531 | if err != nil { |
| 532 | return err |
| 533 | } |
| 534 | if !recursive && info.IsDir() { |
| 535 | if p == c.path { |
| 536 | return nil |
| 537 | } |
| 538 | return filepath.SkipDir |
| 539 | } |
| 540 | _, name := filepath.Split(p) |
| 541 | if name != tType { |
| 542 | return nil |
| 543 | } |
| 544 | curTasks, err := parseCgroupTasksFile(p) |
| 545 | if err != nil { |
| 546 | return err |
| 547 | } |
| 548 | tasks = append(tasks, curTasks...) |
| 549 | return nil |
| 550 | }) |
| 551 | return tasks, err |
| 552 | } |
| 553 | |
| 554 | func (c *Manager) Procs(recursive bool) ([]uint64, error) { |
| 555 | return c.getTasks(recursive, cgroupProcs) |
no test coverage detected