import (
"bufio"
+ "fmt"
"hash"
"io"
"os"
}
fd, err := TempFile(jobsPath, "")
if err == nil {
- ctx.LogD("tmp", LEs{{"Src", fd.Name()}}, "created")
+ ctx.LogD("tmp", LEs{{"Src", fd.Name()}}, func(les LEs) string {
+ return "Temporary file created: " + fd.Name()
+ })
}
return fd, err
}
return err
}
checksum := tmp.Checksum()
- tmp.ctx.LogD("tmp", LEs{{"Src", tmp.Fd.Name()}, {"Dst", checksum}}, "commit")
+ tmp.ctx.LogD(
+ "tmp-rename",
+ LEs{{"Src", tmp.Fd.Name()}, {"Dst", checksum}},
+ func(les LEs) string {
+ return fmt.Sprintf("Temporary file: %s -> %s", tmp.Fd.Name(), checksum)
+ },
+ )
if err = os.Rename(tmp.Fd.Name(), filepath.Join(dir, checksum)); err != nil {
return err
}