diff options
author | Robert Haas <rhaas@postgresql.org> | 2011-11-25 08:02:10 -0500 |
---|---|---|
committer | Robert Haas <rhaas@postgresql.org> | 2011-11-25 08:02:10 -0500 |
commit | ed0b409d22346b1b027a4c2099ca66984d94b6dd (patch) | |
tree | 3d9942b4131ffa73cbf83735c3965b4c1fc7e307 /src/backend/access/transam/varsup.c | |
parent | 9ed439a9c07b69c2617cc98596611fdbdc22472c (diff) | |
download | postgresql-ed0b409d22346b1b027a4c2099ca66984d94b6dd.tar.gz postgresql-ed0b409d22346b1b027a4c2099ca66984d94b6dd.zip |
Move "hot" members of PGPROC into a separate PGXACT array.
This speeds up snapshot-taking and reduces ProcArrayLock contention.
Also, the PGPROC (and PGXACT) structures used by two-phase commit are
now allocated as part of the main array, rather than in a separate
array, and we keep ProcArray sorted in pointer order. These changes
are intended to minimize the number of cache lines that must be pulled
in to take a snapshot, and testing shows a substantial increase in
performance on both read and write workloads at high concurrencies.
Pavan Deolasee, Heikki Linnakangas, Robert Haas
Diffstat (limited to 'src/backend/access/transam/varsup.c')
-rw-r--r-- | src/backend/access/transam/varsup.c | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/backend/access/transam/varsup.c b/src/backend/access/transam/varsup.c index 61dcfedad43..443e5e4ea66 100644 --- a/src/backend/access/transam/varsup.c +++ b/src/backend/access/transam/varsup.c @@ -54,7 +54,7 @@ GetNewTransactionId(bool isSubXact) if (IsBootstrapProcessingMode()) { Assert(!isSubXact); - MyProc->xid = BootstrapTransactionId; + MyPgXact->xid = BootstrapTransactionId; return BootstrapTransactionId; } @@ -208,20 +208,21 @@ GetNewTransactionId(bool isSubXact) * TransactionId and int fetch/store are atomic. */ volatile PGPROC *myproc = MyProc; + volatile PGXACT *mypgxact = MyPgXact; if (!isSubXact) - myproc->xid = xid; + mypgxact->xid = xid; else { - int nxids = myproc->subxids.nxids; + int nxids = mypgxact->nxids; if (nxids < PGPROC_MAX_CACHED_SUBXIDS) { myproc->subxids.xids[nxids] = xid; - myproc->subxids.nxids = nxids + 1; + mypgxact->nxids = nxids + 1; } else - myproc->subxids.overflowed = true; + mypgxact->overflowed = true; } } |