fix: fix csv file handle leaks
This commit is contained in:
parent
56ac7c9ef4
commit
0d630ecdf9
|
@ -448,7 +448,7 @@ static int csvExportCreateSql(CsvWriteMeta* write_meta) {
|
||||||
goto end;
|
goto end;
|
||||||
}
|
}
|
||||||
|
|
||||||
succPrint("Export create sql to file: %s successfully..\n", fullname);
|
succPrint("Export create sql to file: %s successfully.\n", fullname);
|
||||||
|
|
||||||
end:
|
end:
|
||||||
if (fp) {
|
if (fp) {
|
||||||
|
@ -827,6 +827,10 @@ static CsvIoError csvWrite(CsvFileHandle* fhdl, const char* buf, size_t size) {
|
||||||
|
|
||||||
|
|
||||||
static void csvClose(CsvFileHandle* fhdl) {
|
static void csvClose(CsvFileHandle* fhdl) {
|
||||||
|
if (!fhdl) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if (fhdl->compress_level == CSV_COMPRESS_NONE) {
|
if (fhdl->compress_level == CSV_COMPRESS_NONE) {
|
||||||
if (fhdl->handle.fp) {
|
if (fhdl->handle.fp) {
|
||||||
fclose(fhdl->handle.fp);
|
fclose(fhdl->handle.fp);
|
||||||
|
@ -838,6 +842,7 @@ static void csvClose(CsvFileHandle* fhdl) {
|
||||||
fhdl->handle.gf = NULL;
|
fhdl->handle.gf = NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
tmfree(fhdl);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue