X-Git-Url: https://ruderich.org/simon/gitweb/?p=nsscash%2Fnsscash.git;a=blobdiff_plain;f=state.go;h=59c885ae9cf17c9a15a2e980702926a24cf26339;hp=9b67d9a038d14f3b5e9708c0ffd3e5ca5a9a4895;hb=HEAD;hpb=6383e468f1d5b281159cd46d800204a1aa718cd2 diff --git a/state.go b/state.go index 9b67d9a..59c885a 100644 --- a/state.go +++ b/state.go @@ -1,6 +1,6 @@ // Read and write the state file used to keep data over multiple runs -// Copyright (C) 2019 Simon Ruderich +// Copyright (C) 2019-2021 Simon Ruderich // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by @@ -23,6 +23,8 @@ import ( "os" "path/filepath" "time" + + "github.com/google/renameio" ) type State struct { @@ -68,26 +70,19 @@ func WriteState(path string, state *State) error { return err } - // Write the file in an atomic fashion by creating a temporary file - // and renaming it over the target file - - dir := filepath.Dir(path) - name := filepath.Base(path) - - f, err := ioutil.TempFile(dir, "tmp-"+name+"-") + f, err := renameio.TempFile(filepath.Dir(path), path) if err != nil { return err } - defer os.Remove(f.Name()) - defer f.Close() + defer f.Cleanup() _, err = f.Write(x) if err != nil { return err } - err = f.Sync() + err = f.CloseAtomicallyReplace() if err != nil { return err } - return os.Rename(f.Name(), path) + return syncPath(filepath.Dir(path)) }