aboutsummaryrefslogtreecommitdiff
path: root/src/backend/commands/async.c
diff options
context:
space:
mode:
authorTom Lane <tgl@sss.pgh.pa.us>2009-02-13 17:12:04 +0000
committerTom Lane <tgl@sss.pgh.pa.us>2009-02-13 17:12:04 +0000
commitca5646fc824abe606e2cc78dff89631b0e875e27 (patch)
treeb9b9678de7f8b6687effadec2d6987f21cef6c14 /src/backend/commands/async.c
parent30735adfe4a6682a35545b5b830263740655c923 (diff)
downloadpostgresql-ca5646fc824abe606e2cc78dff89631b0e875e27.tar.gz
postgresql-ca5646fc824abe606e2cc78dff89631b0e875e27.zip
Fix UNLISTEN to fall out quickly if the current backend has never executed
any LISTEN command. This is more important than it used to be because DISCARD ALL invokes UNLISTEN. Connection-pooled applications making heavy use of DISCARD ALL were seeing significant contention for pg_listener, as reported by Matteo Beccati. It seems unlikely that clients using LISTEN would use pooled connections, so this simple tweak seems sufficient, especially since the pg_listener implementation is slated to go away soon anyway. Back-patch to 8.3, where DISCARD ALL was introduced.
Diffstat (limited to 'src/backend/commands/async.c')
-rw-r--r--src/backend/commands/async.c10
1 files changed, 9 insertions, 1 deletions
diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c
index 5e38ec154b6..745f4558537 100644
--- a/src/backend/commands/async.c
+++ b/src/backend/commands/async.c
@@ -7,7 +7,7 @@
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $PostgreSQL: pgsql/src/backend/commands/async.c,v 1.145 2009/01/01 17:23:37 momjian Exp $
+ * $PostgreSQL: pgsql/src/backend/commands/async.c,v 1.146 2009/02/13 17:12:04 tgl Exp $
*
*-------------------------------------------------------------------------
*/
@@ -277,6 +277,10 @@ Async_Unlisten(const char *relname)
if (Trace_notify)
elog(DEBUG1, "Async_Unlisten(%s,%d)", relname, MyProcPid);
+ /* If we couldn't possibly be listening, no need to queue anything */
+ if (pendingActions == NIL && !unlistenExitRegistered)
+ return;
+
queue_listen(LISTEN_UNLISTEN, relname);
}
@@ -291,6 +295,10 @@ Async_UnlistenAll(void)
if (Trace_notify)
elog(DEBUG1, "Async_UnlistenAll(%d)", MyProcPid);
+ /* If we couldn't possibly be listening, no need to queue anything */
+ if (pendingActions == NIL && !unlistenExitRegistered)
+ return;
+
queue_listen(LISTEN_UNLISTEN_ALL, "");
}