finish vnode snapshot
This commit is contained in:
parent
592c6991a0
commit
ff07377fa3
|
@ -641,14 +641,15 @@ static int32_t tsdbSnapWriteTableDataImpl(STsdbSnapWriter* pWriter) {
|
||||||
|
|
||||||
ASSERT(c);
|
ASSERT(c);
|
||||||
|
|
||||||
if (c < 0) break;
|
if (c > 0) {
|
||||||
|
pWriter->pBlockData = &pWriter->bDataR;
|
||||||
|
code =
|
||||||
|
tsdbReadBlockData(pWriter->pDataFReader, pWriter->pBlockIdx, &block, pWriter->pBlockData, NULL, NULL);
|
||||||
|
if (code) goto _err;
|
||||||
|
pWriter->iRow = 0;
|
||||||
|
|
||||||
pWriter->pBlockData = &pWriter->bDataR;
|
pWriter->iBlock++;
|
||||||
code = tsdbReadBlockData(pWriter->pDataFReader, pWriter->pBlockIdx, &block, pWriter->pBlockData, NULL, NULL);
|
}
|
||||||
if (code) goto _err;
|
|
||||||
pWriter->iRow = 0;
|
|
||||||
|
|
||||||
pWriter->iBlock++;
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -684,6 +685,8 @@ static int32_t tsdbSnapWriteTableDataImpl(STsdbSnapWriter* pWriter) {
|
||||||
return code;
|
return code;
|
||||||
|
|
||||||
_err:
|
_err:
|
||||||
|
tsdbError("vgId:%d vnode snapshot tsdb write table data impl failed since %s", TD_VID(pWriter->pTsdb->pVnode),
|
||||||
|
tstrerror(code));
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue