Add fsync calls to reduce probability of unexpected state after a crash.

2 files changed, 19 insertions, 0 deletions

diff --git a/vespalib/src/vespa/vespalib/io/fileutil.cpp b/vespalib/src/vespa/vespalib/io/fileutil.cpp
index e360c84f569..5ab5fb99a0d 100644
--- a/vespalib/src/vespa/vespalib/io/fileutil.cpp
+++ b/vespalib/src/vespa/vespalib/io/fileutil.cpp
@@ -408,6 +408,15 @@ File::sync()
     }
 }
 
+void
+File::sync(vespalib::stringref path)
+{
+    File file(path);
+    file.open(READONLY);
+    file.sync();
+    file.close();
+}
+
 bool
 File::close()
 {
diff --git a/vespalib/src/vespa/vespalib/io/fileutil.h b/vespalib/src/vespa/vespalib/io/fileutil.h
index 187939ed412..1b493a9ebf1 100644
--- a/vespalib/src/vespa/vespalib/io/fileutil.h
+++ b/vespalib/src/vespa/vespalib/io/fileutil.h
@@ -190,6 +190,16 @@ public:
      */
     static vespalib::string readAll(vespalib::stringref path);
 
+    /**
+     * Sync file or directory.
+     *
+     * This is a convenience function for the member functions open() and
+     * sync(), see there for more details.
+     *
+     * @throw IoException If we failed to sync the file.
+     */
+    static void sync(vespalib::stringref path);
+
     virtual void sync();
     virtual bool close();
     virtual bool unlink();