xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

TD-1912

This commit is contained in:
Shengliang Guan 2020-11-03 23:12:54 +08:00
parent ff25a2c4a5
commit d4ff13d9b1
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/os/src/detail/osFile.c
View File

@ -110,6 +110,10 @@ int64_t taosWrite(int32_t fd, void *buf, int64_t n) {
return n; return n;
} }
int64_t taosLSeek(int32_t fd, int64_t offset, int32_t whence) {
return lseek(fd, offset, whence);
}
#ifndef TAOS_OS_FUNC_FILE_SENDIFLE #ifndef TAOS_OS_FUNC_FILE_SENDIFLE
int64_t taosSendFile(int32_t dfd, int32_t sfd, int64_t *offset, int64_t size) { int64_t taosSendFile(int32_t dfd, int32_t sfd, int64_t *offset, int64_t size) {

2
src/wal/src/walWrite.c
View File

@ -203,7 +203,7 @@ static int32_t walSkipCorruptedRecord(SWal *pWal, SWalHead *pHead, int32_t fd, i
while (1) { while (1) {
pos++; pos++;
if (lseek(fd, pos, SEEK_SET) < 0) { if (taosLSeek(fd, pos, SEEK_SET) < 0) {
wError("vgId:%d, failed to seek from corrupted wal file since %s", pWal->vgId, strerror(errno)); wError("vgId:%d, failed to seek from corrupted wal file since %s", pWal->vgId, strerror(errno));
return TSDB_CODE_WAL_FILE_CORRUPTED; return TSDB_CODE_WAL_FILE_CORRUPTED;
} }