suyiiyii/yq
1
0
Fork 0
mirror of https://github.com/mikefarah/yq.git synced 2025-02-26 09:42:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed writing inplace from docker

Browse Source
This commit is contained in:
Mike Farah 2018-06-27 12:06:31 +10:00
parent b3532e0a61
commit c86f8b426b
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
yq.go
View File

@ -509,11 +509,35 @@ func marshalContext(context interface{}) (string, error) {
} }
func safelyRenameFile(from string, to string) { func safelyRenameFile(from string, to string) {
if err := os.Rename(from, to); err != nil { if renameError := os.Rename(from, to); renameError != nil {
log.Errorf("Error renaming from %v to %v", from, to) log.Warningf("Error renaming from %v to %v, attemting to copy contents", from, to)
log.Error(err.Error()) log.Warning(renameError.Error())
// can't do this rename when running in docker to a file targeted in a mounted volume,
// so gracefully degrade to copying the entire contents.
if copyError := copyFileContents(from, to); copyError != nil {
log.Errorf("Failed copying from %v to %v", from, to)
log.Errorf(copyError.Error())
} }
} }
}
// thanks https://stackoverflow.com/questions/21060945/simple-way-to-copy-a-file-in-golang
func copyFileContents(src, dst string) (err error) {
in, err := os.Open(src)
if err != nil {
return err
}
defer safelyCloseFile(in)
out, err := os.Create(dst)
if err != nil {
return err
}
defer safelyCloseFile(out)
if _, err = io.Copy(out, in); err != nil {
return err
}
return out.Sync()
}
func safelyFlush(writer *bufio.Writer) { func safelyFlush(writer *bufio.Writer) {
if err := writer.Flush(); err != nil { if err := writer.Flush(); err != nil {