From 4ef64c425dbcda151c9f163aadff982343808e09 Mon Sep 17 00:00:00 2001 From: Michael Paquier Date: Mon, 26 Jul 2021 11:13:37 +0900 Subject: Fix a couple of memory leaks in src/bin/pg_basebackup/ These have been introduced by 7fbe0c8, and could happen for pg_basebackup and pg_receivewal. Per report from Coverity for the ones in walmethods.c, I have spotted the ones in receivelog.c after more review. Backpatch-through: 10 --- src/bin/pg_basebackup/walmethods.c | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'src/bin/pg_basebackup/walmethods.c') diff --git a/src/bin/pg_basebackup/walmethods.c b/src/bin/pg_basebackup/walmethods.c index 09b071b6a4f..8695647db43 100644 --- a/src/bin/pg_basebackup/walmethods.c +++ b/src/bin/pg_basebackup/walmethods.c @@ -94,6 +94,7 @@ dir_open_for_write(const char *pathname, const char *temp_suffix, size_t pad_to_ filename = dir_get_file_name(pathname, temp_suffix); snprintf(tmppath, sizeof(tmppath), "%s/%s", dir_data->basedir, filename); + pg_free(filename); /* * Open a file for non-compressed as well as compressed files. Tracking @@ -254,11 +255,13 @@ dir_close(Walfile f, WalCloseMethod method) filename = dir_get_file_name(df->pathname, df->temp_suffix); snprintf(tmppath, sizeof(tmppath), "%s/%s", dir_data->basedir, filename); + pg_free(filename); /* permanent name, so no need for the prefix */ filename2 = dir_get_file_name(df->pathname, NULL); snprintf(tmppath2, sizeof(tmppath2), "%s/%s", dir_data->basedir, filename2); + pg_free(filename2); r = durable_rename(tmppath, tmppath2); } else if (method == CLOSE_UNLINK) @@ -269,6 +272,7 @@ dir_close(Walfile f, WalCloseMethod method) filename = dir_get_file_name(df->pathname, df->temp_suffix); snprintf(tmppath, sizeof(tmppath), "%s/%s", dir_data->basedir, filename); + pg_free(filename); r = unlink(tmppath); } else @@ -625,11 +629,14 @@ tar_open_for_write(const char *pathname, const char *temp_suffix, size_t pad_to_ if (tarCreateHeader(tar_data->currentfile->header, tmppath, NULL, 0, S_IRUSR | S_IWUSR, 0, 0, time(NULL)) != TAR_OK) { pg_free(tar_data->currentfile); + pg_free(tmppath); tar_data->currentfile = NULL; tar_set_error("could not create tar header"); return NULL; } + pg_free(tmppath); + #ifdef HAVE_LIBZ if (tar_data->compression) { -- cgit v1.2.3