LocalFile: Integrate fsync.

Signed-off-by: Pascal Spörri <[email protected]>

Author: pspoerri

src/libgeds/LocalFile.cpp

@@ -10,6 +10,7 @@
 #include <cstddef>
 #include <cstdint>
 #include <cstdio>
+#include <cstring>
 #include <fcntl.h>
 #include <ios>
 #include <stdexcept>
@@ -67,6 +68,20 @@ void LocalFile::notifyUnused() {
   // NOOP.
 }
 
+absl::Status LocalFile::fsync() {
+  CHECK_FILE_OPEN
+
+  int e = 0;
+  do {
+    e = ::fsync(_fd);
+  } while (e != 0 && errno == EINTR);
+  if (e != 0) {
+    int err = errno;
+    return absl::UnknownError("Unable to fsync " + _path + ": " + strerror(err));
+  }
+  return absl::OkStatus();
+}
+
 absl::StatusOr<size_t> LocalFile::fileSize() const {
   CHECK_FILE_OPEN
 

src/libgeds/LocalFile.h

@@ -49,6 +49,8 @@ class LocalFile {
 
   void notifyUnused();
 
+  absl::Status fsync();
+
   [[nodiscard]] size_t size() const { return _size; }
   [[nodiscard]] size_t localStorageSize() const { return _size; }
   [[nodiscard]] size_t localMemorySize() const { return 0; }