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 20:27:07 +08:00
parent a82ac7de39
commit 38c28f1cb6
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/os/inc/osFile.h
View File

@ -20,10 +20,10 @@
extern "C" { extern "C" {
#endif #endif
#define treadfile(fd, buf, count) read(fd, buf, count) #define tread(fd, buf, count) read(fd, buf, count)
#define twritefile(fd, buf, count) write(fd, buf, count) #define twrite(fd, buf, count) write(fd, buf, count)
#define tlseekfile(fd, offset, whence) lseek(fd, offset, whence) #define tlseek(fd, offset, whence) lseek(fd, offset, whence)
#define tclosefile(fd) \ #define tclose(fd) \
{ \ { \
if (FD_VALID(x)) { \ if (FD_VALID(x)) { \
close(x); \ close(x); \

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

@ -37,7 +37,7 @@ int32_t walRenew(void *handle) {
pthread_mutex_lock(&pWal->mutex); pthread_mutex_lock(&pWal->mutex);
if (pWal->fd >= 0) { if (pWal->fd >= 0) {
close(pWal->fd); tclose(pWal->fd);
wDebug("vgId:%d, file:%s, it is closed", pWal->vgId, pWal->name); wDebug("vgId:%d, file:%s, it is closed", pWal->vgId, pWal->name);
} }
@ -310,7 +310,7 @@ static int32_t walRestoreWalFile(SWal *pWal, void *pVnode, FWalWrite writeFp, ch
(*writeFp)(pVnode, pHead, TAOS_QTYPE_WAL); (*writeFp)(pVnode, pHead, TAOS_QTYPE_WAL);
} }
close(fd); tclose(fd);
tfree(buffer); tfree(buffer);
return code; return code;