Merge pull request #10435 from taosdata/fix/ZhiqiangWang/TD-13062-file-system-write-fsync-error

[TD-13062]<fix>: file system write fsync error

source/libs/sync/test/syncTest.cpp

@@ -2,6 +2,7 @@
 #include "syncIO.h"
 #include "syncInt.h"
 #include "syncRaftStore.h"
+#include "gtest/gtest.h"
 
 void *pingFunc(void *param) {
   SSyncIO *io = (SSyncIO *)param;
@@ -26,32 +27,32 @@ int main() {
   sFatal("sync log test: fatal");
 
   SRaftStore *pRaftStore = raftStoreOpen("./raft_store.json");
-  assert(pRaftStore != NULL);
+  // assert(pRaftStore != NULL);
 
-  raftStorePrint(pRaftStore);
+  // raftStorePrint(pRaftStore);
 
-  pRaftStore->currentTerm = 100;
-  pRaftStore->voteFor.addr = 200;
-  pRaftStore->voteFor.vgId = 300;
+  // pRaftStore->currentTerm = 100;
+  // pRaftStore->voteFor.addr = 200;
+  // pRaftStore->voteFor.vgId = 300;
 
-  raftStorePrint(pRaftStore);
+  // raftStorePrint(pRaftStore);
 
-  raftStorePersist(pRaftStore);
+  // raftStorePersist(pRaftStore);
 
-  sDebug("sync test");
+  // sDebug("sync test");
 
-  SSyncIO *syncIO = syncIOCreate();
-  assert(syncIO != NULL);
+  // SSyncIO *syncIO = syncIOCreate();
+  // assert(syncIO != NULL);
 
-  syncIO->start(syncIO);
+  // syncIO->start(syncIO);
 
-  sleep(2);
+  // sleep(2);
 
-  pthread_t tid;
-  pthread_create(&tid, NULL, pingFunc, syncIO);
+  // pthread_t tid;
+  // pthread_create(&tid, NULL, pingFunc, syncIO);
 
-  while (1) {
-    sleep(1);
-  }
+  // while (1) {
+  //   sleep(1);
+  // }
   return 0;
 }

source/os/src/osFile.c

@@ -240,6 +240,7 @@ int64_t taosCloseFile(TdFilePtr *ppFile) {
     return 0;
   }
   fflush((*ppFile)->fp);
+  fsync((*ppFile)->fd);
   close((*ppFile)->fd);
   (*ppFile)->fd = -1;
   (*ppFile)->fp = NULL;
@@ -295,12 +296,16 @@ int64_t taosWriteFile(TdFilePtr pFile, const void *buf, int64_t count) {
       if (errno == EINTR) {
         continue;
       }
+      fflush(pFile->fp);
+      fsync(pFile->fd);
       return -1;
     }
     nleft -= nwritten;
     tbuf += nwritten;
   }
 
+  fflush(pFile->fp);
+  fsync(pFile->fd);
   return count;
 }