提交 1e17bfa6 编写于 作者: wafwerar's avatar wafwerar

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

上级 c4a1bae7
...@@ -2,6 +2,7 @@ ...@@ -2,6 +2,7 @@
#include "syncIO.h" #include "syncIO.h"
#include "syncInt.h" #include "syncInt.h"
#include "syncRaftStore.h" #include "syncRaftStore.h"
#include "gtest/gtest.h"
void *pingFunc(void *param) { void *pingFunc(void *param) {
SSyncIO *io = (SSyncIO *)param; SSyncIO *io = (SSyncIO *)param;
...@@ -26,32 +27,32 @@ int main() { ...@@ -26,32 +27,32 @@ int main() {
sFatal("sync log test: fatal"); sFatal("sync log test: fatal");
SRaftStore *pRaftStore = raftStoreOpen("./raft_store.json"); SRaftStore *pRaftStore = raftStoreOpen("./raft_store.json");
assert(pRaftStore != NULL); // assert(pRaftStore != NULL);
raftStorePrint(pRaftStore); // raftStorePrint(pRaftStore);
pRaftStore->currentTerm = 100; // pRaftStore->currentTerm = 100;
pRaftStore->voteFor.addr = 200; // pRaftStore->voteFor.addr = 200;
pRaftStore->voteFor.vgId = 300; // pRaftStore->voteFor.vgId = 300;
raftStorePrint(pRaftStore); // raftStorePrint(pRaftStore);
raftStorePersist(pRaftStore); // raftStorePersist(pRaftStore);
sDebug("sync test"); // sDebug("sync test");
SSyncIO *syncIO = syncIOCreate(); // SSyncIO *syncIO = syncIOCreate();
assert(syncIO != NULL); // assert(syncIO != NULL);
syncIO->start(syncIO); // syncIO->start(syncIO);
sleep(2); // sleep(2);
pthread_t tid; // pthread_t tid;
pthread_create(&tid, NULL, pingFunc, syncIO); // pthread_create(&tid, NULL, pingFunc, syncIO);
while (1) { // while (1) {
sleep(1); // sleep(1);
} // }
return 0; return 0;
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册