X-Git-Url: https://ruderich.org/simon/gitweb/?p=safcm%2Fsafcm.git;a=blobdiff_plain;f=remote%2Fsync%2Ffiles.go;h=937f0e1f2df8820381d55951630a7c422e5dbb9d;hp=edf81bd2cc795a2630f4b775eca25786ad838c61;hb=9f7f26593d35a34e71da584278345732216d84d3;hpb=2804606f9f8dc5078c38580bac363b47eb638620 diff --git a/remote/sync/files.go b/remote/sync/files.go index edf81bd..937f0e1 100644 --- a/remote/sync/files.go +++ b/remote/sync/files.go @@ -456,6 +456,14 @@ reopen: unix.Unlinkat(parentFd, tmpBase, 0) return err } + // To guarantee durability fsync must be called on a parent directory + // after adding, renaming or removing files therein. + // + // Calling sync on the files itself is not enough according to POSIX; + // man 2 fsync: "Calling fsync() does not necessarily ensure that the + // entry in the directory containing the file has also reached disk. + // For that an explicit fsync() on a file descriptor for the directory + // is also needed." err = unix.Fsync(parentFd) if err != nil { return err @@ -695,24 +703,3 @@ retry: return os.NewFile(uintptr(fd), ""), tmpBase, nil } - -// SyncPath syncs path, which should be a directory. To guarantee durability -// it must be called on a parent directory after adding, renaming or removing -// files therein. -// -// Calling sync on the files itself is not enough according to POSIX; man 2 -// fsync: "Calling fsync() does not necessarily ensure that the entry in the -// directory containing the file has also reached disk. For that an explicit -// fsync() on a file descriptor for the directory is also needed." -func SyncPath(path string) error { - x, err := os.Open(path) - if err != nil { - return err - } - err = x.Sync() - closeErr := x.Close() - if err != nil { - return err - } - return closeErr -}