diff options
| author | Bruce Momjian <bruce@momjian.us> | 2013-01-09 08:57:47 -0500 |
|---|---|---|
| committer | Bruce Momjian <bruce@momjian.us> | 2013-01-09 08:57:47 -0500 |
| commit | a89c46f9bc314ed549245d888da09b8c5cace104 (patch) | |
| tree | 7b6ed8dc5ea0bbd6426c8e5452a24ce5f5bd5a77 /contrib/pg_upgrade/tablespace.c | |
| parent | c00dc337b8752ec959e27bfdc58e13f3d305154a (diff) | |
| download | postgresql-a89c46f9bc314ed549245d888da09b8c5cace104.tar.gz postgresql-a89c46f9bc314ed549245d888da09b8c5cace104.zip | |
Allow parallel copy/link in pg_upgrade
This patch implements parallel copying/linking of files by tablespace
using the --jobs option in pg_upgrade.
Diffstat (limited to 'contrib/pg_upgrade/tablespace.c')
| -rw-r--r-- | contrib/pg_upgrade/tablespace.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/contrib/pg_upgrade/tablespace.c b/contrib/pg_upgrade/tablespace.c index a93c51768a5..321738dabc7 100644 --- a/contrib/pg_upgrade/tablespace.c +++ b/contrib/pg_upgrade/tablespace.c @@ -23,7 +23,7 @@ init_tablespaces(void) set_tablespace_directory_suffix(&old_cluster); set_tablespace_directory_suffix(&new_cluster); - if (os_info.num_tablespaces > 0 && + if (os_info.num_old_tablespaces > 0 && strcmp(old_cluster.tablespace_suffix, new_cluster.tablespace_suffix) == 0) pg_log(PG_FATAL, "Cannot upgrade to/from the same system catalog version when\n" @@ -57,16 +57,16 @@ get_tablespace_paths(void) res = executeQueryOrDie(conn, "%s", query); - if ((os_info.num_tablespaces = PQntuples(res)) != 0) - os_info.tablespaces = (char **) pg_malloc( - os_info.num_tablespaces * sizeof(char *)); + if ((os_info.num_old_tablespaces = PQntuples(res)) != 0) + os_info.old_tablespaces = (char **) pg_malloc( + os_info.num_old_tablespaces * sizeof(char *)); else - os_info.tablespaces = NULL; + os_info.old_tablespaces = NULL; i_spclocation = PQfnumber(res, "spclocation"); - for (tblnum = 0; tblnum < os_info.num_tablespaces; tblnum++) - os_info.tablespaces[tblnum] = pg_strdup( + for (tblnum = 0; tblnum < os_info.num_old_tablespaces; tblnum++) + os_info.old_tablespaces[tblnum] = pg_strdup( PQgetvalue(res, tblnum, i_spclocation)); PQclear(res); |