summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Haas2014-09-26 15:21:35 +0000
committerRobert Haas2014-09-26 15:43:56 +0000
commitbbe3c069a24850430a65ab2821f1e762428c79fb (patch)
tree58563afca2a2a1a0fec483f0074bc41c6e157875
parentfc4314a237d71a5a02e7907037e0e1b9c5b02157 (diff)
Fix identify_locking_dependencies for schema-only dumps.
Without this fix, parallel restore of a schema-only dump can deadlock, because when the dump is schema-only, the dependency will still be pointing at the TABLE item rather than the TABLE DATA item. Robert Haas and Tom Lane
-rw-r--r--src/bin/pg_dump/pg_backup_archiver.c16
1 files changed, 10 insertions, 6 deletions
diff --git a/src/bin/pg_dump/pg_backup_archiver.c b/src/bin/pg_dump/pg_backup_archiver.c
index d3f12430dd3..a0011dc9be1 100644
--- a/src/bin/pg_dump/pg_backup_archiver.c
+++ b/src/bin/pg_dump/pg_backup_archiver.c
@@ -4085,11 +4085,14 @@ identify_locking_dependencies(TocEntry *te)
return;
/*
- * We assume the item requires exclusive lock on each TABLE DATA item
- * listed among its dependencies. (This was originally a dependency on
- * the TABLE, but fix_dependencies repointed it to the data item. Note
- * that all the entry types we are interested in here are POST_DATA, so
- * they will all have been changed this way.)
+ * We assume the entry requires exclusive lock on each TABLE or TABLE DATA
+ * item listed among its dependencies. Originally all of these would have
+ * been TABLE items, but repoint_table_dependencies would have repointed
+ * them to the TABLE DATA items if those are present (which they might not
+ * be, eg in a schema-only dump). Note that all of the entries we are
+ * processing here are POST_DATA; otherwise there might be a significant
+ * difference between a dependency on a table and a dependency on its
+ * data, so that closer analysis would be needed here.
*/
lockids = (DumpId *) malloc(te->nDeps * sizeof(DumpId));
nlockids = 0;
@@ -4098,7 +4101,8 @@ identify_locking_dependencies(TocEntry *te)
DumpId depid = te->dependencies[i];
if (depid <= maxDumpId && tocsByDumpId[depid - 1] &&
- strcmp(tocsByDumpId[depid - 1]->desc, "TABLE DATA") == 0)
+ ((strcmp(tocsByDumpId[depid - 1]->desc, "TABLE DATA") == 0) ||
+ strcmp(tocsByDumpId[depid - 1]->desc, "TABLE") == 0))
lockids[nlockids++] = depid;
}