diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-09-06 22:30:08 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-09-06 22:30:08 +0900 |
| commit | 323d132c40a74c5ac7a91731a0c43def2a8be7f1 (patch) | |
| tree | ad68a8f2ec743e6a92efd0ff759e413cc857dc36 /system/mkdir.go | |
| parent | 6cc2b406a45dee7c3fcb686036efdccc1776368d (diff) | |
system/mkdir: use syscall dispatcher
This enables mkdir op methods to be instrumented.
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'system/mkdir.go')
| -rw-r--r-- | system/mkdir.go | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/system/mkdir.go b/system/mkdir.go index 64b02496..97673f08 100644 --- a/system/mkdir.go +++ b/system/mkdir.go @@ -28,32 +28,31 @@ type mkdirOp struct { func (m *mkdirOp) Type() Enablement { return m.et } -func (m *mkdirOp) apply(*I) error { - msg.Verbose("ensuring directory", m) +func (m *mkdirOp) apply(sys *I) error { + sys.verbose("ensuring directory", m) - // create directory - if err := os.Mkdir(m.path, m.perm); err != nil { + if err := sys.mkdir(m.path, m.perm); err != nil { if !errors.Is(err, os.ErrExist) { return newOpError("mkdir", err, false) } // directory exists, ensure mode - return newOpError("mkdir", os.Chmod(m.path, m.perm), false) + return newOpError("mkdir", sys.chmod(m.path, m.perm), false) } else { return nil } } -func (m *mkdirOp) revert(_ *I, ec *Criteria) error { +func (m *mkdirOp) revert(sys *I, ec *Criteria) error { if !m.ephemeral { // skip non-ephemeral dir and do not log anything return nil } if ec.hasType(m.Type()) { - msg.Verbose("destroying ephemeral directory", m) - return newOpError("mkdir", os.Remove(m.path), true) + sys.verbose("destroying ephemeral directory", m) + return newOpError("mkdir", sys.remove(m.path), true) } else { - msg.Verbose("skipping ephemeral directory", m) + sys.verbose("skipping ephemeral directory", m) return nil } } |
