octoleo/syncthing
1
0
Fork 0
mirror of https://github.com/octoleo/syncthing.git synced 2024-12-23 11:28:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2346 from calmh/dststatdir

Browse Source 
Create missing directories
This commit is contained in:
Audrius Butkevicius 2015-10-01 10:47:16 +01:00
commit 7e8b76e8ea
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lib/model/sharedpullerstate.go
View File

@ -86,8 +86,24 @@ func (s *sharedPullerState) tempFile() (io.WriterAt, error) {
// here. // here.
dir := filepath.Dir(s.tempName) dir := filepath.Dir(s.tempName)
if info, err := os.Stat(dir); err != nil { if info, err := os.Stat(dir); err != nil {
if os.IsNotExist(err) {
// XXX: This works around a bug elsewhere, a race condition when
// things are deleted while being synced. However that happens, we
// end up with a directory for "foo" with the delete bit, but a
// file "foo/bar" that we want to sync. We never create the
// directory, and hence fail to create the file and end up looping
// forever on it. This breaks that by creating the directory; on
// next scan it'll be found and the delete bit on it is removed.
// The user can then clean up as they like...
l.Infoln("Resurrecting directory", dir)
if err := os.MkdirAll(dir, 0755); err != nil {
s.failLocked("resurrect dir", err)
return nil, err
}
} else {
s.failLocked("dst stat dir", err) s.failLocked("dst stat dir", err)
return nil, err return nil, err
}
} else if info.Mode()&0200 == 0 { } else if info.Mode()&0200 == 0 {
err := os.Chmod(dir, 0755) err := os.Chmod(dir, 0755)
if !s.ignorePerms && err == nil { if !s.ignorePerms && err == nil {