minor changes
This commit is contained in:
parent
5f72c178fd
commit
34fd49c7f7
|
@ -86,19 +86,19 @@ static int32_t mndRestoreWal(SMnode *pMnode) {
|
||||||
|
|
||||||
mndTransPullup(pMnode);
|
mndTransPullup(pMnode);
|
||||||
|
|
||||||
if (walBeginSnapshot(pWal, sdbVer) < 0) {
|
|
||||||
goto WAL_RESTORE_OVER;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (sdbVer != lastSdbVer) {
|
if (sdbVer != lastSdbVer) {
|
||||||
mInfo("sdb restored from %" PRId64 " to %" PRId64 ", write file", lastSdbVer, sdbVer);
|
mInfo("sdb restored from %" PRId64 " to %" PRId64 ", write file", lastSdbVer, sdbVer);
|
||||||
if (sdbWriteFile(pSdb) != 0) {
|
if (sdbWriteFile(pSdb) != 0) {
|
||||||
goto WAL_RESTORE_OVER;
|
goto WAL_RESTORE_OVER;
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
if (walEndSnapshot(pWal) < 0) {
|
if (walBeginSnapshot(pWal, sdbVer) < 0) {
|
||||||
goto WAL_RESTORE_OVER;
|
goto WAL_RESTORE_OVER;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (walEndSnapshot(pWal) < 0) {
|
||||||
|
goto WAL_RESTORE_OVER;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
code = 0;
|
code = 0;
|
||||||
|
|
Loading…
Reference in New Issue