aboutsummaryrefslogtreecommitdiff
path: root/src/backend/utils
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/utils')
-rw-r--r--src/backend/utils/adt/char.c9
-rw-r--r--src/backend/utils/cache/relcache.c5
-rw-r--r--src/backend/utils/init/globals.c3
-rw-r--r--src/backend/utils/time/tqual.c765
4 files changed, 61 insertions, 721 deletions
diff --git a/src/backend/utils/adt/char.c b/src/backend/utils/adt/char.c
index 588c052d0e7..cb715cd7c7f 100644
--- a/src/backend/utils/adt/char.c
+++ b/src/backend/utils/adt/char.c
@@ -12,7 +12,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/adt/char.c,v 1.13 1997/10/25 05:12:38 thomas Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/adt/char.c,v 1.14 1997/11/02 15:25:57 vadim Exp $
*
*-------------------------------------------------------------------------
*/
@@ -81,12 +81,7 @@ cidout(int32 c)
char *result;
CommandId c2;
- /*
- * cid is a number between 0 .. 2^16-1, therefore we need at most 6
- * chars for the string (5 digits + '\0') NOTE: print it as an
- * UNSIGNED int!
- */
- result = palloc(6);
+ result = palloc(12);
c2 = (CommandId) c;
sprintf(result, "%u", (unsigned) (c2));
return (result);
diff --git a/src/backend/utils/cache/relcache.c b/src/backend/utils/cache/relcache.c
index d1c253f95ca..90cb42d320c 100644
--- a/src/backend/utils/cache/relcache.c
+++ b/src/backend/utils/cache/relcache.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/cache/relcache.c,v 1.26 1997/10/25 05:38:52 thomas Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/cache/relcache.c,v 1.27 1997/11/02 15:26:06 vadim Exp $
*
*-------------------------------------------------------------------------
*/
@@ -80,7 +80,6 @@
#include "catalog/pg_variable.h"
#include "catalog/pg_log.h"
-#include "catalog/pg_time.h"
#include "catalog/pg_attrdef.h"
#include "catalog/pg_relcheck.h"
#include "catalog/indexing.h"
@@ -118,7 +117,6 @@ FormData_pg_attribute Desc_pg_proc[Natts_pg_proc] = {Schema_pg_proc};
FormData_pg_attribute Desc_pg_type[Natts_pg_type] = {Schema_pg_type};
FormData_pg_attribute Desc_pg_variable[Natts_pg_variable] = {Schema_pg_variable};
FormData_pg_attribute Desc_pg_log[Natts_pg_log] = {Schema_pg_log};
-FormData_pg_attribute Desc_pg_time[Natts_pg_time] = {Schema_pg_time};
/* ----------------
* global variables
@@ -1679,7 +1677,6 @@ RelationInitialize(void)
formrdesc(TypeRelationName, Natts_pg_type, Desc_pg_type);
formrdesc(VariableRelationName, Natts_pg_variable, Desc_pg_variable);
formrdesc(LogRelationName, Natts_pg_log, Desc_pg_log);
- formrdesc(TimeRelationName, Natts_pg_time, Desc_pg_time);
/*
* If this isn't initdb time, then we want to initialize some index
diff --git a/src/backend/utils/init/globals.c b/src/backend/utils/init/globals.c
index 7f2aefe3d6f..95e0abfd37a 100644
--- a/src/backend/utils/init/globals.c
+++ b/src/backend/utils/init/globals.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/init/globals.c,v 1.14 1997/09/18 14:33:46 vadim Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/init/globals.c,v 1.15 1997/11/02 15:26:12 vadim Exp $
*
* NOTES
* Globals used all over the place should be declared here and not
@@ -114,7 +114,6 @@ char *SharedSystemRelationNames[] = {
LogRelationName,
MagicRelationName,
ServerRelationName,
- TimeRelationName,
UserRelationName,
VariableRelationName,
0
diff --git a/src/backend/utils/time/tqual.c b/src/backend/utils/time/tqual.c
index aa2cd6398ba..756d3efff91 100644
--- a/src/backend/utils/time/tqual.c
+++ b/src/backend/utils/time/tqual.c
@@ -1,13 +1,13 @@
/*-------------------------------------------------------------------------
*
* tqual.c--
- * POSTGRES time qualification code.
+ * POSTGRES "time" qualification code.
*
* Copyright (c) 1994, Regents of the University of California
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/time/tqual.c,v 1.8 1997/09/12 04:08:57 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/time/tqual.c,v 1.9 1997/11/02 15:26:17 vadim Exp $
*
*-------------------------------------------------------------------------
*/
@@ -22,50 +22,11 @@
#include "access/transam.h"
#include "utils/elog.h"
#include "utils/palloc.h"
-#include "utils/nabstime.h"
#include "utils/tqual.h"
-static AbsoluteTime TimeQualGetEndTime(TimeQual qual);
-static AbsoluteTime TimeQualGetSnapshotTime(TimeQual qual);
-static AbsoluteTime TimeQualGetStartTime(TimeQual qual);
-static bool TimeQualIncludesNow(TimeQual qual);
-static bool TimeQualIndicatesDisableValidityChecking(TimeQual qual);
-static bool TimeQualIsLegal(TimeQual qual);
-#ifndef NO_ASSERT_CHECKING
-static bool TimeQualIsRanged(TimeQual qual);
-static bool TimeQualIsValid(TimeQual qual);
-#endif
-static bool TimeQualIsSnapshot(TimeQual qual);
-
-/*
- * TimeQualMode --
- * Mode indicator for treatment of time qualifications.
- */
-typedef uint16 TimeQualMode;
-
-#define TimeQualAt 0x1
-#define TimeQualNewer 0x2
-#define TimeQualOlder 0x4
-#define TimeQualAll 0x8
-
-#define TimeQualMask 0xf
-
-#define TimeQualEvery 0x0
-#define TimeQualRange (TimeQualNewer | TimeQualOlder)
-#define TimeQualAllAt (TimeQualAt | TimeQualAll)
-
-typedef struct TimeQualData
-{
- AbsoluteTime start;
- AbsoluteTime end;
- TimeQualMode mode;
-} TimeQualData;
-
-typedef TimeQualData *InternalTimeQual;
-
-static TimeQualData SelfTimeQualData;
-TimeQual SelfTimeQual = (Pointer) &SelfTimeQualData;
+static int4 SelfTimeQualData;
+TimeQual SelfTimeQual = (TimeQual) &SelfTimeQualData;
extern bool PostgresIsInitialized;
@@ -119,363 +80,6 @@ heapisoverride()
static bool HeapTupleSatisfiesItself(HeapTuple tuple);
static bool HeapTupleSatisfiesNow(HeapTuple tuple);
-static bool
-HeapTupleSatisfiesSnapshotInternalTimeQual(HeapTuple tuple,
- InternalTimeQual qual);
-static bool
-HeapTupleSatisfiesUpperBoundedInternalTimeQual(HeapTuple tuple,
- InternalTimeQual qual);
-static bool
-HeapTupleSatisfiesUpperUnboundedInternalTimeQual(HeapTuple tuple,
- InternalTimeQual qual);
-
-
-
-/*
- * TimeQualIsValid --
- * True iff time qualification is valid.
- */
-#ifndef NO_ASSERT_CHECKING
-static bool
-TimeQualIsValid(TimeQual qual)
-{
- bool hasStartTime;
-
- if (!PointerIsValid(qual) || qual == SelfTimeQual)
- {
- return (true);
- }
-
- if (((InternalTimeQual) qual)->mode & ~TimeQualMask)
- {
- return (false);
- }
-
- if (((InternalTimeQual) qual)->mode & TimeQualAt)
- {
- return (AbsoluteTimeIsBackwardCompatiblyValid(((InternalTimeQual) qual)->start));
- }
-
- hasStartTime = false;
-
- if (((InternalTimeQual) qual)->mode & TimeQualNewer)
- {
- if (!AbsoluteTimeIsBackwardCompatiblyValid(((InternalTimeQual) qual)->start))
- {
- return (false);
- }
- hasStartTime = true;
- }
-
- if (((InternalTimeQual) qual)->mode & TimeQualOlder)
- {
- if (!AbsoluteTimeIsBackwardCompatiblyValid(((InternalTimeQual) qual)->end))
- {
- return (false);
- }
- if (hasStartTime)
- {
- return ((bool) !AbsoluteTimeIsBefore(
- ((InternalTimeQual) qual)->end,
- ((InternalTimeQual) qual)->start));
- }
- }
- return (true);
-}
-#endif
-
-/*
- * TimeQualIsLegal --
- * True iff time qualification is legal.
- * I.e., true iff time qualification does not intersects the future,
- * relative to the transaction start time.
- *
- * Note:
- * Assumes time qualification is valid.
- */
-static bool
-TimeQualIsLegal(TimeQual qual)
-{
- Assert(TimeQualIsValid(qual));
-
- if (qual == NowTimeQual || qual == SelfTimeQual)
- {
- return (true);
- }
-
- /* TimeQualAt */
- if (((InternalTimeQual) qual)->mode & TimeQualAt)
- {
- AbsoluteTime a,
- b;
-
- a = ((InternalTimeQual) qual)->start;
- b = GetCurrentTransactionStartTime();
-
- if (AbsoluteTimeIsAfter(a, b))
- return (false);
- else
- return (true);
- }
-
- /* TimeQualOlder or TimeQualRange */
- if (((InternalTimeQual) qual)->mode & TimeQualOlder)
- {
- AbsoluteTime a,
- b;
-
- a = ((InternalTimeQual) qual)->end;
- b = GetCurrentTransactionStartTime();
-
- if (AbsoluteTimeIsAfter(a, b))
- return (false);
- else
- return (true);
- }
-
- /* TimeQualNewer */
- if (((InternalTimeQual) qual)->mode & TimeQualNewer)
- {
- AbsoluteTime a,
- b;
-
- a = ((InternalTimeQual) qual)->start;
- b = GetCurrentTransactionStartTime();
-
- if (AbsoluteTimeIsAfter(a, b))
- return (false);
- else
- return (true);
- }
-
- /* TimeQualEvery */
- return (true);
-}
-
-/*
- * TimeQualIncludesNow --
- * True iff time qualification includes "now."
- *
- * Note:
- * Assumes time qualification is valid.
- */
-static bool
-TimeQualIncludesNow(TimeQual qual)
-{
- Assert(TimeQualIsValid(qual));
-
- if (qual == NowTimeQual || qual == SelfTimeQual)
- {
- return (true);
- }
-
- if (((InternalTimeQual) qual)->mode & TimeQualAt)
- {
- return (false);
- }
- if (((InternalTimeQual) qual)->mode & TimeQualOlder &&
- !AbsoluteTimeIsAfter(
- ((InternalTimeQual) qual)->end,
- GetCurrentTransactionStartTime()))
- {
-
- return (false);
- }
- return (true);
-}
-
-/*
- * TimeQualIncludesPast --
- * True iff time qualification includes some time in the past.
- *
- * Note:
- * Assumes time qualification is valid.
- * XXX may not be needed?
- */
-#ifdef NOT_USED
-bool
-TimeQualIncludesPast(TimeQual qual)
-{
- Assert(TimeQualIsValid(qual));
-
- if (qual == NowTimeQual || qual == SelfTimeQual)
- {
- return (false);
- }
-
- /* otherwise, must check archive (setting locks as appropriate) */
- return (true);
-}
-
-#endif
-
-/*
- * TimeQualIsSnapshot --
- * True iff time qualification is a snapshot qualification.
- *
- * Note:
- * Assumes time qualification is valid.
- */
-static bool
-TimeQualIsSnapshot(TimeQual qual)
-{
- Assert(TimeQualIsValid(qual));
-
- if (qual == NowTimeQual || qual == SelfTimeQual)
- {
- return (false);
- }
-
- return ((bool) !!(((InternalTimeQual) qual)->mode & TimeQualAt));
-}
-
-/*
- * TimeQualIsRanged --
- * True iff time qualification is a ranged qualification.
- *
- * Note:
- * Assumes time qualification is valid.
- */
-#ifndef NO_ASSERT_CHECKING
-static bool
-TimeQualIsRanged(TimeQual qual)
-{
- Assert(TimeQualIsValid(qual));
-
- if (qual == NowTimeQual || qual == SelfTimeQual)
- {
- return (false);
- }
-
- return ((bool) !(((InternalTimeQual) qual)->mode & TimeQualAt));
-}
-#endif
-
-/*
- * TimeQualIndicatesDisableValidityChecking --
- * True iff time qualification indicates validity checking should be
- * disabled.
- *
- * Note:
- * XXX This should not be implemented since this does not make sense.
- */
-static bool
-TimeQualIndicatesDisableValidityChecking(TimeQual qual)
-{
- Assert(TimeQualIsValid(qual));
-
- if (qual == NowTimeQual || qual == SelfTimeQual)
- {
- return (false);
- }
-
- if (((InternalTimeQual) qual)->mode & TimeQualAll)
- {
- return (true);
- }
- return (false);
-}
-
-/*
- * TimeQualGetSnapshotTime --
- * Returns time for a snapshot time qual.
- *
- * Note:
- * Assumes time qual is valid snapshot time qual.
- */
-static AbsoluteTime
-TimeQualGetSnapshotTime(TimeQual qual)
-{
- Assert(TimeQualIsSnapshot(qual));
-
- return (((InternalTimeQual) qual)->start);
-}
-
-/*
- * TimeQualGetStartTime --
- * Returns start time for a ranged time qual.
- *
- * Note:
- * Assumes time qual is valid ranged time qual.
- */
-static AbsoluteTime
-TimeQualGetStartTime(TimeQual qual)
-{
- Assert(TimeQualIsRanged(qual));
-
- return (((InternalTimeQual) qual)->start);
-}
-
-/*
- * TimeQualGetEndTime --
- * Returns end time for a ranged time qual.
- *
- * Note:
- * Assumes time qual is valid ranged time qual.
- */
-static AbsoluteTime
-TimeQualGetEndTime(TimeQual qual)
-{
- Assert(TimeQualIsRanged(qual));
-
- return (((InternalTimeQual) qual)->end);
-}
-
-/*
- * TimeFormSnapshotTimeQual --
- * Returns snapshot time qual for a time.
- *
- * Note:
- * Assumes time is valid.
- */
-TimeQual
-TimeFormSnapshotTimeQual(AbsoluteTime time)
-{
- InternalTimeQual qual;
-
- Assert(AbsoluteTimeIsBackwardCompatiblyValid(time));
-
- qual = (InternalTimeQual) palloc(sizeof *qual);
-
- qual->start = time;
- qual->end = INVALID_ABSTIME;
- qual->mode = TimeQualAt;
-
- return ((TimeQual) qual);
-}
-
-/*
- * TimeFormRangedTimeQual --
- * Returns ranged time qual for a pair of times.
- *
- * Note:
- * If start time is invalid, it is regarded as the epoch.
- * If end time is invalid, it is regarded as "now."
- * Assumes start time is before (or the same as) end time.
- */
-TimeQual
-TimeFormRangedTimeQual(AbsoluteTime startTime,
- AbsoluteTime endTime)
-{
- InternalTimeQual qual;
-
- qual = (InternalTimeQual) palloc(sizeof *qual);
-
- qual->start = startTime;
- qual->end = endTime;
- qual->mode = TimeQualEvery;
-
- if (AbsoluteTimeIsBackwardCompatiblyValid(startTime))
- {
- qual->mode |= TimeQualNewer;
- }
- if (AbsoluteTimeIsBackwardCompatiblyValid(endTime))
- {
- qual->mode |= TimeQualOlder;
- }
-
- return ((TimeQual) qual);
-}
/*
* HeapTupleSatisfiesTimeQual --
@@ -484,16 +88,10 @@ TimeFormRangedTimeQual(AbsoluteTime startTime,
* Note:
* Assumes heap tuple is valid.
* Assumes time qual is valid.
- * XXX Many of the checks may be simplified and still remain correct.
- * XXX Partial answers to the checks may be cached in an ItemId.
*/
bool
HeapTupleSatisfiesTimeQual(HeapTuple tuple, TimeQual qual)
{
-/* extern TransactionId AmiTransactionId; */
-
- Assert(HeapTupleIsValid(tuple));
- Assert(TimeQualIsValid(qual));
if (TransactionIdEquals(tuple->t_xmax, AmiTransactionId))
return (false);
@@ -508,30 +106,9 @@ HeapTupleSatisfiesTimeQual(HeapTuple tuple, TimeQual qual)
return (HeapTupleSatisfiesNow(tuple));
}
- if (!TimeQualIsLegal(qual))
- {
- elog(WARN, "HeapTupleSatisfiesTimeQual: illegal time qual");
- }
-
- if (TimeQualIndicatesDisableValidityChecking(qual))
- {
- elog(WARN, "HeapTupleSatisfiesTimeQual: no disabled validity checking (yet)");
- }
-
- if (TimeQualIsSnapshot(qual))
- {
- return (HeapTupleSatisfiesSnapshotInternalTimeQual(tuple,
- (InternalTimeQual) qual));
- }
-
- if (TimeQualIncludesNow(qual))
- {
- return (HeapTupleSatisfiesUpperUnboundedInternalTimeQual(tuple,
- (InternalTimeQual) qual));
- }
+ elog(WARN, "HeapTupleSatisfiesTimeQual: illegal time qual");
- return (HeapTupleSatisfiesUpperBoundedInternalTimeQual(tuple,
- (InternalTimeQual) qual));
+ return (false);
}
/*
@@ -560,50 +137,48 @@ static bool
HeapTupleSatisfiesItself(HeapTuple tuple)
{
- /*
- * XXX Several evil casts are made in this routine. Casting XID to be
- * TransactionId works only because TransactionId->data is the first
- * (and only) field of the structure.
- */
- if (!AbsoluteTimeIsBackwardCompatiblyValid(tuple->t_tmin))
+ if (!(tuple->t_infomask & HEAP_XMIN_COMMITTED))
{
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmin) &&
- !TransactionIdIsValid((TransactionId) tuple->t_xmax))
+ if (tuple->t_infomask & HEAP_XMIN_INVALID) /* xid invalid or aborted */
+ return (false);
+
+ if (TransactionIdIsCurrentTransactionId(tuple->t_xmin))
{
- return (true);
+ if (tuple->t_infomask & HEAP_XMAX_INVALID) /* xid invalid */
+ return (true);
+ else
+ return (false);
}
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmin))
+ if (!TransactionIdDidCommit(tuple->t_xmin))
{
+ if (TransactionIdDidAbort(tuple->t_xmin))
+ tuple->t_infomask |= HEAP_XMIN_INVALID; /* aborted */
return (false);
}
- tuple->t_tmin = TransactionIdGetCommitTime(tuple->t_xmin);
+ tuple->t_infomask |= HEAP_XMIN_COMMITTED;
}
/* the tuple was inserted validly */
- if (AbsoluteTimeIsBackwardCompatiblyReal(tuple->t_tmax))
- {
- return (false);
- }
-
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax))
- {
+ if (tuple->t_infomask & HEAP_XMAX_INVALID) /* xid invalid or aborted */
return (true);
- }
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmax))
- {
+ if (tuple->t_infomask & HEAP_XMAX_COMMITTED)
+ return (false);
+
+ if (TransactionIdIsCurrentTransactionId(tuple->t_xmax))
return (false);
- }
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmax))
+ if (!TransactionIdDidCommit(tuple->t_xmax))
{
+ if (TransactionIdDidAbort(tuple->t_xmax))
+ tuple->t_infomask |= HEAP_XMAX_INVALID; /* aborted */
return (true);
}
/* by here, deleting transaction has committed */
- tuple->t_tmax = TransactionIdGetCommitTime(tuple->t_xmax);
+ tuple->t_infomask |= HEAP_XMAX_COMMITTED;
return (false);
}
@@ -667,295 +242,69 @@ HeapTupleSatisfiesNow(HeapTuple tuple)
*/
if (!PostgresIsInitialized)
- return ((bool) (TransactionIdIsValid((TransactionId) tuple->t_xmin) &&
- !TransactionIdIsValid((TransactionId) tuple->t_xmax)));
+ return ((bool) (TransactionIdIsValid(tuple->t_xmin) &&
+ !TransactionIdIsValid(tuple->t_xmax)));
- /*
- * XXX Several evil casts are made in this routine. Casting XID to be
- * TransactionId works only because TransactionId->data is the first
- * (and only) field of the structure.
- */
- if (!AbsoluteTimeIsBackwardCompatiblyValid(tuple->t_tmin))
+ if (!(tuple->t_infomask & HEAP_XMIN_COMMITTED))
{
-
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmin)
- && CommandIdGEScanCommandId(tuple->t_cmin))
- {
-
+ if (tuple->t_infomask & HEAP_XMIN_INVALID) /* xid invalid or aborted */
return (false);
- }
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmin)
- && !CommandIdGEScanCommandId(tuple->t_cmin))
+ if (TransactionIdIsCurrentTransactionId(tuple->t_xmin))
{
+ if (CommandIdGEScanCommandId(tuple->t_cmin))
+ return (false); /* inserted after scan started */
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax))
- {
+ if (tuple->t_infomask & HEAP_XMAX_INVALID) /* xid invalid */
return (true);
- }
- Assert(TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmax));
+ Assert(TransactionIdIsCurrentTransactionId(tuple->t_xmax));
if (CommandIdGEScanCommandId(tuple->t_cmax))
- {
- return (true);
- }
+ return (true); /* deleted after scan started */
+ else
+ return (false); /* deleted before scan started */
}
/*
* this call is VERY expensive - requires a log table lookup.
*/
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmin))
+ if (!TransactionIdDidCommit(tuple->t_xmin))
{
+ if (TransactionIdDidAbort(tuple->t_xmin))
+ tuple->t_infomask |= HEAP_XMIN_INVALID; /* aborted */
return (false);
}
- /*
- * the transaction has been committed--store the commit time _now_
- * instead of waiting for a vacuum so we avoid the expensive call
- * next time.
- */
- tuple->t_tmin = TransactionIdGetCommitTime(tuple->t_xmin);
+ tuple->t_infomask |= HEAP_XMIN_COMMITTED;
}
/* by here, the inserting transaction has committed */
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax))
- {
- return (true);
- }
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmax))
- {
- return (false);
- }
-
- if (AbsoluteTimeIsBackwardCompatiblyReal(tuple->t_tmax))
- {
- return (false);
- }
-
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmax))
- {
+ if (tuple->t_infomask & HEAP_XMAX_INVALID) /* xid invalid or aborted */
return (true);
- }
-
- /* xmax transaction committed, but no tmax set. so set it. */
- tuple->t_tmax = TransactionIdGetCommitTime(tuple->t_xmax);
-
- return (false);
-}
-
-/*
- * HeapTupleSatisfiesSnapshotInternalTimeQual --
- * True iff heap tuple is valid at the snapshot time qualification.
- *
- * Note:
- * Assumes heap tuple is valid.
- * Assumes internal time qualification is valid snapshot qualification.
- */
-/*
- * The satisfaction of Rel[T] requires the following:
- *
- * (Xmin is committed && Tmin <= T &&
- * (Xmax is null || (Xmax is not committed && Xmax != my-transaction) ||
- * Tmax >= T))
- */
-static bool
-HeapTupleSatisfiesSnapshotInternalTimeQual(HeapTuple tuple,
- InternalTimeQual qual)
-{
-
- /*
- * XXX Several evil casts are made in this routine. Casting XID to be
- * TransactionId works only because TransactionId->data is the first
- * (and only) field of the structure.
- */
- if (!AbsoluteTimeIsBackwardCompatiblyValid(tuple->t_tmin))
- {
-
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmin))
- {
- return (false);
- }
-
- tuple->t_tmin = TransactionIdGetCommitTime(tuple->t_xmin);
- }
- if (AbsoluteTimeIsBefore(TimeQualGetSnapshotTime((TimeQual) qual), tuple->t_tmin))
- {
- return (false);
- }
- /* the tuple was inserted validly before the snapshot time */
-
- if (!AbsoluteTimeIsBackwardCompatiblyReal(tuple->t_tmax))
- {
-
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax) ||
- !TransactionIdDidCommit((TransactionId) tuple->t_xmax))
- {
-
- return (true);
- }
-
- tuple->t_tmax = TransactionIdGetCommitTime(tuple->t_xmax);
- }
-
- return ((bool)
- AbsoluteTimeIsAfter(tuple->t_tmax,
- TimeQualGetSnapshotTime((TimeQual) qual)));
-}
-
-/*
- * HeapTupleSatisfiesUpperBoundedInternalTimeQual --
- * True iff heap tuple is valid within a upper bounded time qualification.
- *
- * Note:
- * Assumes heap tuple is valid.
- * Assumes time qualification is valid ranged qualification with fixed
- * upper bound.
- */
-/*
- * The satisfaction of [T1,T2] requires the following:
- *
- * (Xmin is committed && Tmin <= T2 &&
- * (Xmax is null || (Xmax is not committed && Xmax != my-transaction) ||
- * T1 is null || Tmax >= T1))
- */
-static bool
-HeapTupleSatisfiesUpperBoundedInternalTimeQual(HeapTuple tuple,
- InternalTimeQual qual)
-{
-
- /*
- * XXX Several evil casts are made in this routine. Casting XID to be
- * TransactionId works only because TransactionId->data is the first
- * (and only) field of the structure.
- */
- if (!AbsoluteTimeIsBackwardCompatiblyValid(tuple->t_tmin))
- {
-
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmin))
- {
- return (false);
- }
-
- tuple->t_tmin = TransactionIdGetCommitTime(tuple->t_xmin);
- }
-
- if (AbsoluteTimeIsBefore(TimeQualGetEndTime((TimeQual) qual), tuple->t_tmin))
- {
+ if (tuple->t_infomask & HEAP_XMAX_COMMITTED)
return (false);
- }
- /* the tuple was inserted validly before the range end */
-
- if (!AbsoluteTimeIsBackwardCompatiblyValid(TimeQualGetStartTime((TimeQual) qual)))
- {
- return (true);
- }
- if (!AbsoluteTimeIsBackwardCompatiblyReal(tuple->t_tmax))
+ if (TransactionIdIsCurrentTransactionId(tuple->t_xmax))
{
-
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax) ||
- !TransactionIdDidCommit((TransactionId) tuple->t_xmax))
- {
-
- return (true);
- }
-
- tuple->t_tmax = TransactionIdGetCommitTime(tuple->t_xmax);
- }
-
- return ((bool) AbsoluteTimeIsAfter(tuple->t_tmax,
- TimeQualGetStartTime((TimeQual) qual)));
-}
-
-/*
- * HeapTupleSatisfiesUpperUnboundedInternalTimeQual --
- * True iff heap tuple is valid within a upper bounded time qualification.
- *
- * Note:
- * Assumes heap tuple is valid.
- * Assumes time qualification is valid ranged qualification with no
- * upper bound.
- */
-/*
- * The satisfaction of [T1,] requires the following:
- *
- * ((Xmin == my-transaction && Cmin != my-command &&
- * (Xmax is null || (Xmax == my-transaction && Cmax != my-command)))
- * ||
- *
- * (Xmin is committed &&
- * (Xmax is null || (Xmax == my-transaction && Cmax == my-command) ||
- * (Xmax is not committed && Xmax != my-transaction) ||
- * T1 is null || Tmax >= T1)))
- */
-static bool
-HeapTupleSatisfiesUpperUnboundedInternalTimeQual(HeapTuple tuple,
- InternalTimeQual qual)
-{
- if (!AbsoluteTimeIsBackwardCompatiblyValid(tuple->t_tmin))
- {
-
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmin) &&
- CommandIdGEScanCommandId(tuple->t_cmin))
- {
-
- return (false);
- }
-
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmin) &&
- !CommandIdGEScanCommandId(tuple->t_cmin))
- {
-
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax))
- {
- return (true);
- }
-
- Assert(TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmax));
-
- return ((bool) !CommandIdGEScanCommandId(tuple->t_cmax));
- }
-
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmin))
- {
- return (false);
- }
-
- tuple->t_tmin = TransactionIdGetCommitTime(tuple->t_xmin);
+ if (CommandIdGEScanCommandId(tuple->t_cmax))
+ return (true); /* deleted after scan started */
+ else
+ return (false); /* deleted before scan started */
}
- /* the tuple was inserted validly */
- if (!AbsoluteTimeIsBackwardCompatiblyValid(TimeQualGetStartTime((TimeQual) qual)))
+ if (!TransactionIdDidCommit(tuple->t_xmax))
{
+ if (TransactionIdDidAbort(tuple->t_xmax))
+ tuple->t_infomask |= HEAP_XMAX_INVALID; /* aborted */
return (true);
}
- if (!AbsoluteTimeIsBackwardCompatiblyReal(tuple->t_tmax))
- {
+ /* xmax transaction committed */
+ tuple->t_infomask |= HEAP_XMAX_COMMITTED;
- if (!TransactionIdIsValid((TransactionId) tuple->t_xmax))
- {
- return (true);
- }
-
- if (TransactionIdIsCurrentTransactionId((TransactionId) tuple->t_xmax))
- {
- return (CommandIdGEScanCommandId(tuple->t_cmin));
- /* it looks like error ^^^^ */
- }
-
- if (!TransactionIdDidCommit((TransactionId) tuple->t_xmax))
- {
- return (true);
- }
-
- tuple->t_tmax = TransactionIdGetCommitTime(tuple->t_xmax);
- }
-
- return ((bool) AbsoluteTimeIsAfter(tuple->t_tmax,
- TimeQualGetStartTime((TimeQual) qual)));
+ return (false);
}
generated by cgit v1.2.3 (git 2.25.1) at 2025-05-30 17:34:00 +0000