fix file descriptor leakage
This commit is contained in:
parent
640ca45c2a
commit
b00b22bb3d
|
@ -163,8 +163,8 @@ int tsdbCloseHelperFile(SRWHelper *pHelper, bool hasError) {
|
||||||
if (pHelper->files.lastF.fd > 0) {
|
if (pHelper->files.lastF.fd > 0) {
|
||||||
if (helperType(pHelper) == TSDB_WRITE_HELPER) {
|
if (helperType(pHelper) == TSDB_WRITE_HELPER) {
|
||||||
fsync(pHelper->files.lastF.fd);
|
fsync(pHelper->files.lastF.fd);
|
||||||
close(pHelper->files.lastF.fd);
|
|
||||||
}
|
}
|
||||||
|
close(pHelper->files.lastF.fd);
|
||||||
pHelper->files.lastF.fd = -1;
|
pHelper->files.lastF.fd = -1;
|
||||||
}
|
}
|
||||||
if (helperType(pHelper) == TSDB_WRITE_HELPER) {
|
if (helperType(pHelper) == TSDB_WRITE_HELPER) {
|
||||||
|
|
Loading…
Reference in New Issue