luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

atomic write service state and checks files, fixes #1221

This commit is contained in:
Cameron Davison 2016-08-03 10:32:21 -05:00
parent 94c14275c0
commit 40d1c279dd
No known key found for this signature in database
GPG Key ID: 17A7D2891F5D67E6
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
command/agent/agent.go
View File

@ -675,12 +675,11 @@ func (a *Agent) persistService(service *structs.NodeService) error {
if err := os.MkdirAll(filepath.Dir(svcPath), 0700); err != nil {
return err
}
fh, err := os.OpenFile(svcPath, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0600)
if err != nil {
tempSvcPath := svcPath + ".tmp"
if err := ioutil.WriteFile(tempSvcPath, encoded, 0600); err != nil {
return err
}
defer fh.Close()
if _, err := fh.Write(encoded); err != nil {
if err := os.Rename(tempSvcPath, svcPath); err != nil {
return err
}
return nil
@ -1092,8 +1091,14 @@ func (a *Agent) persistCheckState(check *CheckTTL, status, output string) error
// Write the state to the file
file := filepath.Join(dir, checkIDHash(check.CheckID))
if err := ioutil.WriteFile(file, buf, 0600); err != nil {
return fmt.Errorf("failed writing file %q: %s", file, err)
// Create temp file in same folder, to make more likely atomic
tempFile := file + ".tmp"
if err := ioutil.WriteFile(tempFile, buf, 0600); err != nil {
return fmt.Errorf("failed writing temp file %q: %s", tempFile, err)
}
if err := os.Rename(tempFile, file); err != nil {
return fmt.Errorf("failed to rename temp file from %q to %q: %s", tempFile, file, err)
}
return nil