Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 9 additions & 15 deletions libcontainer/intelrdt/intelrdt.go
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ type Manager struct {
config *configs.Config
id string
path string
directoryCreated bool
shouldCleanupDir bool
}

// NewManager returns a new instance of Manager, or nil if the Intel RDT
Expand Down Expand Up @@ -187,10 +187,9 @@ func NewManager(config *configs.Config, id, path string) *Manager {
// is actually available. Used by unit tests that mock intelrdt paths.
func newManager(config *configs.Config, id, path string) *Manager {
return &Manager{
config: config,
id: id,
path: path,
directoryCreated: false,
config: config,
id: id,
path: path,
}
}

Expand Down Expand Up @@ -462,15 +461,10 @@ func (m *Manager) Apply(pid int) (err error) {
}
}

// If the directory doesn't exist we need to create it -> it means we also need
// to clean it up afterwards. Make a note to the manager.
if _, err := os.Stat(path); err != nil {
if errors.Is(err, os.ErrNotExist) {
m.directoryCreated = true
}
}

if err := os.Mkdir(path, 0o755); err != nil && !errors.Is(err, os.ErrExist) {
if err := os.Mkdir(path, 0o755); err == nil || errors.Is(err, os.ErrExist) {
// Only clean up the directory if we actually created it.
m.shouldCleanupDir = err == nil
Comment thread
rata marked this conversation as resolved.
} else {
return newLastCmdError(err)
}

Expand Down Expand Up @@ -501,7 +495,7 @@ func (m *Manager) Destroy() error {
// group is likely externally managed, i.e. by some other entity than us.
// There are probably other containers/tasks sharing the same group. Also
// only remove the directory if it was created by us.
if m.config.IntelRdt.ClosID == "" && m.directoryCreated {
if m.config.IntelRdt.ClosID == "" && m.shouldCleanupDir {
m.mu.Lock()
defer m.mu.Unlock()
if err := os.Remove(m.GetPath()); err != nil && !errors.Is(err, os.ErrNotExist) {
Expand Down