diff options
author | Andrew Dunstan <andrew@dunslane.net> | 2017-02-01 17:52:35 -0500 |
---|---|---|
committer | Andrew Dunstan <andrew@dunslane.net> | 2017-02-01 17:59:53 -0500 |
commit | 13752743bf7010f7cbf07bdf2a0087c3960121c5 (patch) | |
tree | d0e44e9805b08ad31cbf6e8f295eb25fcf4cb23a /src/backend/storage/ipc/procarray.c | |
parent | eb5e9d90df7536d0cf5c0d669d874f91b7be36d6 (diff) |
Don't count background workers against a user's connection limit.
Doing so doesn't seem to be within the purpose of the per user
connection limits, and has particularly unfortunate effects in
conjunction with parallel queries.
Backpatch to 9.6 where parallel queries were introduced.
David Rowley, reviewed by Robert Haas and Albe Laurenz.
Diffstat (limited to 'src/backend/storage/ipc/procarray.c')
-rw-r--r-- | src/backend/storage/ipc/procarray.c | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/src/backend/storage/ipc/procarray.c b/src/backend/storage/ipc/procarray.c index 4adb286d5b5..651c561dfd5 100644 --- a/src/backend/storage/ipc/procarray.c +++ b/src/backend/storage/ipc/procarray.c @@ -2752,6 +2752,38 @@ CountDBBackends(Oid databaseid) } /* + * CountDBConnections --- counts database backends ignoring any background + * worker processes + */ +int +CountDBConnections(Oid databaseid) +{ + ProcArrayStruct *arrayP = procArray; + int count = 0; + int index; + + LWLockAcquire(ProcArrayLock, LW_SHARED); + + for (index = 0; index < arrayP->numProcs; index++) + { + int pgprocno = arrayP->pgprocnos[index]; + volatile PGPROC *proc = &allProcs[pgprocno]; + + if (proc->pid == 0) + continue; /* do not count prepared xacts */ + if (proc->isBackgroundWorker) + continue; /* do not count background workers */ + if (!OidIsValid(databaseid) || + proc->databaseId == databaseid) + count++; + } + + LWLockRelease(ProcArrayLock); + + return count; +} + +/* * CancelDBBackends --- cancel backends that are using specified database */ void @@ -2810,6 +2842,8 @@ CountUserBackends(Oid roleid) if (proc->pid == 0) continue; /* do not count prepared xacts */ + if (proc->isBackgroundWorker) + continue; /* do not count background workers */ if (proc->roleId == roleid) count++; } |