Avoid O(N^2) behavior when the standby process releases many locks.

tglsfdc · tglsfdc · commit df238aed1090 · 2021-10-31T15:31:44.000-04:00
When replaying a transaction that held many exclusive locks on the primary, a standby server's startup process would expend O(N^2) effort on manipulating the list of locks. This code was fine when written, but commit 1cff1b9 made repetitive list_delete_first() calls inefficient, as explained in its commit message. Fix by just iterating the list normally, and releasing storage only when done. (This'd be inadequate if we needed to recover from an error occurring partway through; but we don't.) Back-patch to v13 where 1cff1b9 came in. Nathan Bossart Discussion: https://postgr.es/m/CD2F0E7F-9822-45EC-A411-AE56F14DEA9F@amazon.com
diff --git a/src/backend/storage/ipc/standby.c b/src/backend/storage/ipc/standby.c
@@ -791,9 +791,11 @@ StandbyAcquireAccessExclusiveLock(TransactionId xid, Oid dbOid, Oid relOid)
 static void
 StandbyReleaseLockList(List *locks)
 {
-	while (locks)
+	ListCell   *lc;
+
+	foreach(lc, locks)
 	{
-		xl_standby_lock *lock = (xl_standby_lock *) linitial(locks);
+		xl_standby_lock *lock = (xl_standby_lock *) lfirst(lc);
 		LOCKTAG		locktag;
 
 		elog(trace_recovery(DEBUG4),
@@ -807,9 +809,9 @@ StandbyReleaseLockList(List *locks)
 				 lock->xid, lock->dbOid, lock->relOid);
 			Assert(false);
 		}
-		pfree(lock);
-		locks = list_delete_first(locks);
 	}
+
+	list_free_deep(locks);
 }
 
 static void

Original file line number	Diff line number	Diff line change
`@@ -791,9 +791,11 @@ StandbyAcquireAccessExclusiveLock(TransactionId xid, Oid dbOid, Oid relOid)`
`791`	`791`	`static void`
`792`	`792`	`StandbyReleaseLockList(List *locks)`
`793`	`793`	`{`
`794`		`- while (locks)`
	`794`	`+ ListCell *lc;`
	`795`	`+`
	`796`	`+ foreach(lc, locks)`
`795`	`797`	`{`
`796`		`- xl_standby_lock lock = (xl_standby_lock ) linitial(locks);`
	`798`	`+ xl_standby_lock lock = (xl_standby_lock ) lfirst(lc);`
`797`	`799`	`LOCKTAG locktag;`
`798`	`800`
`799`	`801`	`elog(trace_recovery(DEBUG4),`
`@@ -807,9 +809,9 @@ StandbyReleaseLockList(List *locks)`
`807`	`809`	`lock->xid, lock->dbOid, lock->relOid);`
`808`	`810`	`Assert(false);`
`809`	`811`	`}`
`810`		`- pfree(lock);`
`811`		`- locks = list_delete_first(locks);`
`812`	`812`	`}`
	`813`	`+`
	`814`	`+ list_free_deep(locks);`
`813`	`815`	`}`
`814`	`816`
`815`	`817`	`static void`