aboutsummaryrefslogtreecommitdiff
path: root/src/backend/access/transam/transam.c
diff options
context:
space:
mode:
authorVadim B. Mikheev <vadim4o@yahoo.com>1998-12-16 11:53:55 +0000
committerVadim B. Mikheev <vadim4o@yahoo.com>1998-12-16 11:53:55 +0000
commitc13a64d7fb3002f437fdf9ab28120c00d0853d04 (patch)
tree42ec5fe73650bbe5d844b90ecd5d3755361ba2e7 /src/backend/access/transam/transam.c
parent54c3e6524217e8fbd5680e212407b98117829c53 (diff)
downloadpostgresql-c13a64d7fb3002f437fdf9ab28120c00d0853d04.tar.gz
postgresql-c13a64d7fb3002f437fdf9ab28120c00d0853d04.zip
Serialized mode works!
Diffstat (limited to 'src/backend/access/transam/transam.c')
-rw-r--r--src/backend/access/transam/transam.c28
1 files changed, 9 insertions, 19 deletions
diff --git a/src/backend/access/transam/transam.c b/src/backend/access/transam/transam.c
index b68b6ab6691..478afbbcca6 100644
--- a/src/backend/access/transam/transam.c
+++ b/src/backend/access/transam/transam.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/access/transam/transam.c,v 1.20 1998/12/15 12:45:30 vadim Exp $
+ * $Header: /cvsroot/pgsql/src/backend/access/transam/transam.c,v 1.21 1998/12/16 11:53:44 vadim Exp $
*
* NOTES
* This file contains the high level access-method interface to the
@@ -172,12 +172,8 @@ TransactionLogTest(TransactionId transactionId, /* transaction id to test */
if (!fail)
{
- /* must not cache status of running xaction !!! */
- if (xidstatus != XID_INPROGRESS)
- {
- TransactionIdStore(transactionId, &cachedTestXid);
- cachedTestXidStatus = xidstatus;
- }
+ TransactionIdStore(transactionId, &cachedTestXid);
+ cachedTestXidStatus = xidstatus;
return (bool)
(status == xidstatus);
}
@@ -230,11 +226,8 @@ TransactionLogUpdate(TransactionId transactionId, /* trans id to update */
*
* What's the hell ?! Why != XID_COMMIT ?!
*/
- if (status != XID_INPROGRESS)
- {
- TransactionIdStore(transactionId, &cachedTestXid);
- cachedTestXidStatus = status;
- }
+ TransactionIdStore(transactionId, &cachedTestXid);
+ cachedTestXidStatus = status;
}
@@ -588,14 +581,11 @@ TransactionIdAbort(TransactionId transactionId)
TransactionLogUpdate(transactionId, XID_ABORT);
}
-#ifdef NOT_USED
void
-TransactionIdSetInProgress(TransactionId transactionId)
+TransactionIdFlushCache()
{
- if (AMI_OVERRIDE)
- return;
- TransactionLogUpdate(transactionId, XID_INPROGRESS);
-}
+ TransactionIdStore(AmiTransactionId, &cachedTestXid);
+ cachedTestXidStatus = XID_COMMIT;
-#endif
+}