Skip to content

T
TDengine

taosdata / TDengine
大约 2 年 前同步成功

通知 1193
Star 22018
Fork 4786
T
TDengine
提交 2c595832 编写于 作者: A Alex Duan
浏览文件
操作

fix(wal): wal corrupted build error1

上级 f7ad7918
显示空白变更内容
内联 并排
Showing with 2 addition and 2 deletion
src/sync/src/syncRetrieve.c
浏览文件 @ 2c595832
...@@ -216,7 +216,7 @@ static int32_t syncReadOneWalRecord(int32_t sfd, SWalHead *pHead) { ...@@ -216,7 +216,7 @@ static int32_t syncReadOneWalRecord(int32_t sfd, SWalHead *pHead) {
} }
// check wal head valid // check wal head valid
if (pHead->sver == 0 && !walValidateChecksum(pHead)) { if (pHead->sver == 0 && !syncValidateChecksum(pHead)) {
sError("sfd:%d, old wal head cksum is messed up, sver=%d version:%" PRIu64 " len:%d", sfd, pHead->sver, pHead->version, pHead->len); sError("sfd:%d, old wal head cksum is messed up, sver=%d version:%" PRIu64 " len:%d", sfd, pHead->sver, pHead->version, pHead->len);
code = syncSkipCorruptedRecord(pHead, sfd); code = syncSkipCorruptedRecord(pHead, sfd);
if (code != TSDB_CODE_SUCCESS) { if (code != TSDB_CODE_SUCCESS) {
...@@ -246,7 +246,7 @@ static int32_t syncReadOneWalRecord(int32_t sfd, SWalHead *pHead) { ...@@ -246,7 +246,7 @@ static int32_t syncReadOneWalRecord(int32_t sfd, SWalHead *pHead) {
return -1; return -1;
} }
if (pHead->sver != 0 && !walValidateChecksum(pHead)) { if (pHead->sver != 0 && !syncValidateChecksum(pHead)) {
sError("sfd:%d, wal check sum failed, sver=%d version:%" PRIu64 " len:%d", sfd, pHead->sver, pHead->version, pHead->len); sError("sfd:%d, wal check sum failed, sver=%d version:%" PRIu64 " len:%d", sfd, pHead->sver, pHead->version, pHead->len);
code = syncSkipCorruptedRecord(pHead, sfd); code = syncSkipCorruptedRecord(pHead, sfd);
if (code != TSDB_CODE_SUCCESS) { if (code != TSDB_CODE_SUCCESS) {
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或