提交 52f58895 编写于 作者: Y yihaoDeng

add checkpoint

上级 04ab8e19
...@@ -242,11 +242,8 @@ int32_t streamSnapRead(SStreamSnapReader* pReader, uint8_t** ppData, int64_t* si ...@@ -242,11 +242,8 @@ int32_t streamSnapRead(SStreamSnapReader* pReader, uint8_t** ppData, int64_t* si
return 0; return 0;
} }
item = taosArrayGet(pHandle->pFileList, pHandle->currFileIdx); item = taosArrayGet(pHandle->pFileList, pHandle->currFileIdx);
pHandle->offset = 0;
pHandle->fd = taosOpenFile(item->name, TD_FILE_READ); pHandle->fd = taosOpenFile(item->name, TD_FILE_READ);
// handle err later nread = taosPReadFile(pHandle->fd, buf + sizeof(SStreamSnapBlockHdr), kBlockSize, pHandle->offset);
nread = taosReadFile(pHandle->fd, buf + sizeof(SStreamSnapBlockHdr), kBlockSize);
pHandle->offset += nread; pHandle->offset += nread;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册