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

TD-2276

This commit is contained in:
Shengliang Guan 2020-11-30 05:10:22 +00:00
parent 98a86b3cb9
commit dede7188b9
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/util/src/tfile.c
View File

@ -93,17 +93,23 @@ int64_t tfRead(int64_t tfd, void *buf, int64_t count) {
return ret; return ret;
} }
int64_t tfFsync(int64_t tfd) { int32_t tfFsync(int64_t tfd) {
void *p = taosAcquireRef(tsFileRsetId, tfd); void *p = taosAcquireRef(tsFileRsetId, tfd);
if (p == NULL) return -1; if (p == NULL) return -1;
int32_t fd = (int32_t)(uintptr_t)p; int32_t fd = (int32_t)(uintptr_t)p;
return fsync(fd); int32_t code = fsync(fd);
taosReleaseRef(tsFileRsetId, tfd);
return code;
} }
bool tfValid(int64_t tfd) { bool tfValid(int64_t tfd) {
void *p = taosAcquireRef(tsFileRsetId, tfd); void *p = taosAcquireRef(tsFileRsetId, tfd);
return p != NULL; if (p == NULL) return false;
taosReleaseRef(tsFileRsetId, tfd);
return true;
} }
int64_t tfLseek(int64_t tfd, int64_t offset, int32_t whence) { int64_t tfLseek(int64_t tfd, int64_t offset, int32_t whence) {
@ -111,7 +117,10 @@ int64_t tfLseek(int64_t tfd, int64_t offset, int32_t whence) {
if (p == NULL) return -1; if (p == NULL) return -1;
int32_t fd = (int32_t)(uintptr_t)p; int32_t fd = (int32_t)(uintptr_t)p;
return taosLSeek(fd, offset, whence); int64_t ret = taosLSeek(fd, offset, whence);
taosReleaseRef(tsFileRsetId, tfd);
return ret;
} }
int32_t tfFtruncate(int64_t tfd, int64_t length) { int32_t tfFtruncate(int64_t tfd, int64_t length) {
@ -119,5 +128,8 @@ int32_t tfFtruncate(int64_t tfd, int64_t length) {
if (p == NULL) return -1; if (p == NULL) return -1;
int32_t fd = (int32_t)(uintptr_t)p; int32_t fd = (int32_t)(uintptr_t)p;
return taosFtruncate(fd, length); int32_t code = taosFtruncate(fd, length);
taosReleaseRef(tsFileRsetId, tfd);
return code;
} }