#include "lib/ilist.h"
#include "storage/lock.h"
#include "storage/lwlock.h"

Include dependency graph for predicate_internals.h:

This graph shows which files directly or indirectly include this file:

Data Structures
struct	SERIALIZABLEXACT

struct	PredXactListData

struct	RWConflictData

struct	RWConflictPoolHeaderData

struct	SERIALIZABLEXIDTAG

struct	SERIALIZABLEXID

struct	PREDICATELOCKTARGETTAG

struct	PREDICATELOCKTARGET

struct	PREDICATELOCKTAG

struct	PREDICATELOCK

struct	LOCALPREDICATELOCK

struct	PredicateLockData

struct	TwoPhasePredicateXactRecord

struct	TwoPhasePredicateLockRecord

struct	TwoPhasePredicateRecord

Macros
#define	InvalidSerCommitSeqNo ((SerCommitSeqNo) PG_UINT64_MAX)

#define	RecoverySerCommitSeqNo ((SerCommitSeqNo) 1)

#define	FirstNormalSerCommitSeqNo ((SerCommitSeqNo) 2)

#define	SXACT_FLAG_COMMITTED 0x00000001 /* already committed */

#define	SXACT_FLAG_PREPARED 0x00000002 /* about to commit */

#define	SXACT_FLAG_ROLLED_BACK 0x00000004 /* already rolled back */

#define	SXACT_FLAG_DOOMED 0x00000008 /* will roll back */

#define	SXACT_FLAG_CONFLICT_OUT 0x00000010

#define	SXACT_FLAG_READ_ONLY 0x00000020

#define	SXACT_FLAG_DEFERRABLE_WAITING 0x00000040

#define	SXACT_FLAG_RO_SAFE 0x00000080

#define	SXACT_FLAG_RO_UNSAFE 0x00000100

#define	SXACT_FLAG_SUMMARY_CONFLICT_IN 0x00000200

#define	SXACT_FLAG_SUMMARY_CONFLICT_OUT 0x00000400

#define	SXACT_FLAG_PARTIALLY_RELEASED 0x00000800

#define	PredXactListDataSize ((Size)MAXALIGN(sizeof(PredXactListData)))

#define	RWConflictDataSize ((Size)MAXALIGN(sizeof(RWConflictData)))

#define	RWConflictPoolHeaderDataSize ((Size)MAXALIGN(sizeof(RWConflictPoolHeaderData)))

#define	SET_PREDICATELOCKTARGETTAG_RELATION(locktag, dboid, reloid)

#define	SET_PREDICATELOCKTARGETTAG_PAGE(locktag, dboid, reloid, blocknum)

#define	SET_PREDICATELOCKTARGETTAG_TUPLE(locktag, dboid, reloid, blocknum, offnum)

#define	GET_PREDICATELOCKTARGETTAG_DB(locktag) ((Oid) (locktag).locktag_field1)

#define	GET_PREDICATELOCKTARGETTAG_RELATION(locktag) ((Oid) (locktag).locktag_field2)

#define	GET_PREDICATELOCKTARGETTAG_PAGE(locktag) ((BlockNumber) (locktag).locktag_field3)

#define	GET_PREDICATELOCKTARGETTAG_OFFSET(locktag) ((OffsetNumber) (locktag).locktag_field4)

#define	GET_PREDICATELOCKTARGETTAG_TYPE(locktag)

#define	InvalidSerializableXact ((SERIALIZABLEXACT *) NULL)

Typedefs
typedef uint64	SerCommitSeqNo

typedef struct SERIALIZABLEXACT	SERIALIZABLEXACT

typedef struct PredXactListData	PredXactListData

typedef struct PredXactListData *	PredXactList

typedef struct RWConflictData	RWConflictData

typedef struct RWConflictData *	RWConflict

typedef struct RWConflictPoolHeaderData	RWConflictPoolHeaderData

typedef struct RWConflictPoolHeaderData *	RWConflictPoolHeader

typedef struct SERIALIZABLEXIDTAG	SERIALIZABLEXIDTAG

typedef struct SERIALIZABLEXID	SERIALIZABLEXID

typedef struct PREDICATELOCKTARGETTAG	PREDICATELOCKTARGETTAG

typedef struct PREDICATELOCKTARGET	PREDICATELOCKTARGET

typedef struct PREDICATELOCKTAG	PREDICATELOCKTAG

typedef struct PREDICATELOCK	PREDICATELOCK

typedef struct LOCALPREDICATELOCK	LOCALPREDICATELOCK

typedef enum PredicateLockTargetType	PredicateLockTargetType

typedef struct PredicateLockData	PredicateLockData

typedef enum TwoPhasePredicateRecordType	TwoPhasePredicateRecordType

typedef struct TwoPhasePredicateXactRecord	TwoPhasePredicateXactRecord

typedef struct TwoPhasePredicateLockRecord	TwoPhasePredicateLockRecord

typedef struct TwoPhasePredicateRecord	TwoPhasePredicateRecord

Enumerations
enum	PredicateLockTargetType { PREDLOCKTAG_RELATION , PREDLOCKTAG_PAGE , PREDLOCKTAG_TUPLE }

enum	TwoPhasePredicateRecordType { TWOPHASEPREDICATERECORD_XACT , TWOPHASEPREDICATERECORD_LOCK }

Functions
PredicateLockData *	GetPredicateLockStatusData (void)

int	GetSafeSnapshotBlockingPids (int blocked_pid, int *output, int output_size)

Macro Definition Documentation

◆ FirstNormalSerCommitSeqNo

#define FirstNormalSerCommitSeqNo ((SerCommitSeqNo) 2)

Definition at line 40 of file predicate_internals.h.

◆ GET_PREDICATELOCKTARGETTAG_DB

#define GET_PREDICATELOCKTARGETTAG_DB ( locktag ) ((Oid) (locktag).locktag_field1)

Definition at line 406 of file predicate_internals.h.

◆ GET_PREDICATELOCKTARGETTAG_OFFSET

#define GET_PREDICATELOCKTARGETTAG_OFFSET ( locktag ) ((OffsetNumber) (locktag).locktag_field4)

Definition at line 412 of file predicate_internals.h.

◆ GET_PREDICATELOCKTARGETTAG_PAGE

#define GET_PREDICATELOCKTARGETTAG_PAGE ( locktag ) ((BlockNumber) (locktag).locktag_field3)

Definition at line 410 of file predicate_internals.h.

◆ GET_PREDICATELOCKTARGETTAG_RELATION

#define GET_PREDICATELOCKTARGETTAG_RELATION ( locktag ) ((Oid) (locktag).locktag_field2)

Definition at line 408 of file predicate_internals.h.

◆ GET_PREDICATELOCKTARGETTAG_TYPE

#define GET_PREDICATELOCKTARGETTAG_TYPE ( locktag )

Value:

    (((locktag).locktag_field4 != InvalidOffsetNumber) ? PREDLOCKTAG_TUPLE : \
     (((locktag).locktag_field3 != InvalidBlockNumber) ? PREDLOCKTAG_PAGE :   \
      PREDLOCKTAG_RELATION))

Definition at line 414 of file predicate_internals.h.

◆ InvalidSerCommitSeqNo

#define InvalidSerCommitSeqNo ((SerCommitSeqNo) PG_UINT64_MAX)

Definition at line 38 of file predicate_internals.h.

◆ InvalidSerializableXact

#define InvalidSerializableXact ((SERIALIZABLEXACT *) NULL)

Definition at line 467 of file predicate_internals.h.

◆ PredXactListDataSize

#define PredXactListDataSize ((Size)MAXALIGN(sizeof(PredXactListData)))

Definition at line 179 of file predicate_internals.h.

◆ RecoverySerCommitSeqNo

#define RecoverySerCommitSeqNo ((SerCommitSeqNo) 1)

Definition at line 39 of file predicate_internals.h.

◆ RWConflictDataSize

#define RWConflictDataSize ((Size)MAXALIGN(sizeof(RWConflictData)))

Definition at line 203 of file predicate_internals.h.

◆ RWConflictPoolHeaderDataSize

#define RWConflictPoolHeaderDataSize ((Size)MAXALIGN(sizeof(RWConflictPoolHeaderData)))

Definition at line 214 of file predicate_internals.h.

◆ SET_PREDICATELOCKTARGETTAG_PAGE

#define SET_PREDICATELOCKTARGETTAG_PAGE	(	locktag,
		dboid,
		reloid,
		blocknum
	)

Value:

    ((locktag).locktag_field1 = (dboid), \
     (locktag).locktag_field2 = (reloid), \
     (locktag).locktag_field3 = (blocknum), \
     (locktag).locktag_field4 = InvalidOffsetNumber)

Definition at line 394 of file predicate_internals.h.

◆ SET_PREDICATELOCKTARGETTAG_RELATION

#define SET_PREDICATELOCKTARGETTAG_RELATION	(	locktag,
		dboid,
		reloid
	)

Value:

    ((locktag).locktag_field1 = (dboid), \
     (locktag).locktag_field2 = (reloid), \
     (locktag).locktag_field3 = InvalidBlockNumber, \
     (locktag).locktag_field4 = InvalidOffsetNumber)

Definition at line 388 of file predicate_internals.h.

◆ SET_PREDICATELOCKTARGETTAG_TUPLE

#define SET_PREDICATELOCKTARGETTAG_TUPLE	(	locktag,
		dboid,
		reloid,
		blocknum,
		offnum
	)

Value:

    ((locktag).locktag_field1 = (dboid), \
     (locktag).locktag_field2 = (reloid), \
     (locktag).locktag_field3 = (blocknum), \
     (locktag).locktag_field4 = (offnum))

Definition at line 400 of file predicate_internals.h.

◆ SXACT_FLAG_COMMITTED

#define SXACT_FLAG_COMMITTED 0x00000001 /* already committed */

Definition at line 121 of file predicate_internals.h.

◆ SXACT_FLAG_CONFLICT_OUT

#define SXACT_FLAG_CONFLICT_OUT 0x00000010

Definition at line 130 of file predicate_internals.h.

◆ SXACT_FLAG_DEFERRABLE_WAITING

#define SXACT_FLAG_DEFERRABLE_WAITING 0x00000040

Definition at line 132 of file predicate_internals.h.

◆ SXACT_FLAG_DOOMED

#define SXACT_FLAG_DOOMED 0x00000008 /* will roll back */

Definition at line 124 of file predicate_internals.h.

◆ SXACT_FLAG_PARTIALLY_RELEASED

#define SXACT_FLAG_PARTIALLY_RELEASED 0x00000800

Definition at line 142 of file predicate_internals.h.

◆ SXACT_FLAG_PREPARED

#define SXACT_FLAG_PREPARED 0x00000002 /* about to commit */

Definition at line 122 of file predicate_internals.h.

◆ SXACT_FLAG_READ_ONLY

#define SXACT_FLAG_READ_ONLY 0x00000020

Definition at line 131 of file predicate_internals.h.

◆ SXACT_FLAG_RO_SAFE

#define SXACT_FLAG_RO_SAFE 0x00000080

Definition at line 133 of file predicate_internals.h.

◆ SXACT_FLAG_RO_UNSAFE

#define SXACT_FLAG_RO_UNSAFE 0x00000100

Definition at line 134 of file predicate_internals.h.

◆ SXACT_FLAG_ROLLED_BACK

#define SXACT_FLAG_ROLLED_BACK 0x00000004 /* already rolled back */

Definition at line 123 of file predicate_internals.h.

◆ SXACT_FLAG_SUMMARY_CONFLICT_IN

#define SXACT_FLAG_SUMMARY_CONFLICT_IN 0x00000200

Definition at line 135 of file predicate_internals.h.

◆ SXACT_FLAG_SUMMARY_CONFLICT_OUT

#define SXACT_FLAG_SUMMARY_CONFLICT_OUT 0x00000400

Definition at line 136 of file predicate_internals.h.

Typedef Documentation

◆ LOCALPREDICATELOCK

typedef struct LOCALPREDICATELOCK LOCALPREDICATELOCK

◆ PREDICATELOCK

typedef struct PREDICATELOCK PREDICATELOCK

◆ PredicateLockData

typedef struct PredicateLockData PredicateLockData

◆ PREDICATELOCKTAG

typedef struct PREDICATELOCKTAG PREDICATELOCKTAG

◆ PREDICATELOCKTARGET

typedef struct PREDICATELOCKTARGET PREDICATELOCKTARGET

◆ PREDICATELOCKTARGETTAG

typedef struct PREDICATELOCKTARGETTAG PREDICATELOCKTARGETTAG

◆ PredicateLockTargetType

typedef enum PredicateLockTargetType PredicateLockTargetType

◆ PredXactList

typedef struct PredXactListData* PredXactList

Definition at line 177 of file predicate_internals.h.

◆ PredXactListData

typedef struct PredXactListData PredXactListData

◆ RWConflict

typedef struct RWConflictData* RWConflict

Definition at line 201 of file predicate_internals.h.

◆ RWConflictData

typedef struct RWConflictData RWConflictData

◆ RWConflictPoolHeader

typedef struct RWConflictPoolHeaderData* RWConflictPoolHeader

Definition at line 212 of file predicate_internals.h.

◆ RWConflictPoolHeaderData

typedef struct RWConflictPoolHeaderData RWConflictPoolHeaderData

◆ SerCommitSeqNo

typedef uint64 SerCommitSeqNo

Definition at line 24 of file predicate_internals.h.

◆ SERIALIZABLEXACT

typedef struct SERIALIZABLEXACT SERIALIZABLEXACT

◆ SERIALIZABLEXID

typedef struct SERIALIZABLEXID SERIALIZABLEXID

◆ SERIALIZABLEXIDTAG

typedef struct SERIALIZABLEXIDTAG SERIALIZABLEXIDTAG

◆ TwoPhasePredicateLockRecord

typedef struct TwoPhasePredicateLockRecord TwoPhasePredicateLockRecord

◆ TwoPhasePredicateRecord

typedef struct TwoPhasePredicateRecord TwoPhasePredicateRecord

◆ TwoPhasePredicateRecordType

typedef enum TwoPhasePredicateRecordType TwoPhasePredicateRecordType

◆ TwoPhasePredicateXactRecord

typedef struct TwoPhasePredicateXactRecord TwoPhasePredicateXactRecord

Enumeration Type Documentation

◆ PredicateLockTargetType

enum PredicateLockTargetType

Enumerator
PREDLOCKTAG_RELATION
PREDLOCKTAG_PAGE
PREDLOCKTAG_TUPLE

Definition at line 361 of file predicate_internals.h.

{
    PREDLOCKTAG_RELATION,
    PREDLOCKTAG_PAGE,
    PREDLOCKTAG_TUPLE,
    /* TODO SSI: Other types may be needed for index locking */
} PredicateLockTargetType;

◆ TwoPhasePredicateRecordType

enum TwoPhasePredicateRecordType

Enumerator
TWOPHASEPREDICATERECORD_XACT
TWOPHASEPREDICATERECORD_LOCK

Definition at line 424 of file predicate_internals.h.

{
    TWOPHASEPREDICATERECORD_XACT,
    TWOPHASEPREDICATERECORD_LOCK,
} TwoPhasePredicateRecordType;

Function Documentation

◆ GetPredicateLockStatusData()

PredicateLockData * GetPredicateLockStatusData ( void )

Definition at line 1445 of file predicate.c.

{
    PredicateLockData *data;
    int         i;
    int         els,
                el;
    HASH_SEQ_STATUS seqstat;
    PREDICATELOCK *predlock;
 
    data = (PredicateLockData *) palloc(sizeof(PredicateLockData));
 
    /*
     * To ensure consistency, take simultaneous locks on all partition locks
     * in ascending order, then SerializableXactHashLock.
     */
    for (i = 0; i < NUM_PREDICATELOCK_PARTITIONS; i++)
        LWLockAcquire(PredicateLockHashPartitionLockByIndex(i), LW_SHARED);
    LWLockAcquire(SerializableXactHashLock, LW_SHARED);
 
    /* Get number of locks and allocate appropriately-sized arrays. */
    els = hash_get_num_entries(PredicateLockHash);
    data->nelements = els;
    data->locktags = (PREDICATELOCKTARGETTAG *)
        palloc(sizeof(PREDICATELOCKTARGETTAG) * els);
    data->xacts = (SERIALIZABLEXACT *)
        palloc(sizeof(SERIALIZABLEXACT) * els);
 
 
    /* Scan through PredicateLockHash and copy contents */
    hash_seq_init(&seqstat, PredicateLockHash);
 
    el = 0;
 
    while ((predlock = (PREDICATELOCK *) hash_seq_search(&seqstat)))
    {
        data->locktags[el] = predlock->tag.myTarget->tag;
        data->xacts[el] = *predlock->tag.myXact;
        el++;
    }
 
    Assert(el == els);
 
    /* Release locks in reverse order */
    LWLockRelease(SerializableXactHashLock);
    for (i = NUM_PREDICATELOCK_PARTITIONS - 1; i >= 0; i--)
        LWLockRelease(PredicateLockHashPartitionLockByIndex(i));
 
    return data;
}

References Assert(), data, hash_get_num_entries(), hash_seq_init(), hash_seq_search(), i, LW_SHARED, LWLockAcquire(), LWLockRelease(), PREDICATELOCKTAG::myTarget, PREDICATELOCKTAG::myXact, NUM_PREDICATELOCK_PARTITIONS, palloc(), PredicateLockHash, PredicateLockHashPartitionLockByIndex, PREDICATELOCKTARGET::tag, and PREDICATELOCK::tag.

Referenced by pg_lock_status().

◆ GetSafeSnapshotBlockingPids()

int GetSafeSnapshotBlockingPids	(	int	blocked_pid,
		int *	output,
		int	output_size
	)

Definition at line 1628 of file predicate.c.

{
    int         num_written = 0;
    dlist_iter  iter;
    SERIALIZABLEXACT *blocking_sxact = NULL;
 
    LWLockAcquire(SerializableXactHashLock, LW_SHARED);
 
    /* Find blocked_pid's SERIALIZABLEXACT by linear search. */
    dlist_foreach(iter, &PredXact->activeList)
    {
        SERIALIZABLEXACT *sxact =
            dlist_container(SERIALIZABLEXACT, xactLink, iter.cur);
 
        if (sxact->pid == blocked_pid)
        {
            blocking_sxact = sxact;
            break;
        }
    }
 
    /* Did we find it, and is it currently waiting in GetSafeSnapshot? */
    if (blocking_sxact != NULL && SxactIsDeferrableWaiting(blocking_sxact))
    {
        /* Traverse the list of possible unsafe conflicts collecting PIDs. */
        dlist_foreach(iter, &blocking_sxact->possibleUnsafeConflicts)
        {
            RWConflict  possibleUnsafeConflict =
                dlist_container(RWConflictData, inLink, iter.cur);
 
            output[num_written++] = possibleUnsafeConflict->sxactOut->pid;
 
            if (num_written >= output_size)
                break;
        }
    }
 
    LWLockRelease(SerializableXactHashLock);
 
    return num_written;
}

References PredXactListData::activeList, dlist_iter::cur, dlist_container, dlist_foreach, LW_SHARED, LWLockAcquire(), LWLockRelease(), output, SERIALIZABLEXACT::pid, SERIALIZABLEXACT::possibleUnsafeConflicts, PredXact, SxactIsDeferrableWaiting, and RWConflictData::sxactOut.

Referenced by pg_isolation_test_session_is_blocked(), and pg_safe_snapshot_blocking_pids().

Data Structures

Macros

Typedefs

Enumerations

Functions

Macro Definition Documentation

◆ FirstNormalSerCommitSeqNo

◆ GET_PREDICATELOCKTARGETTAG_DB

◆ GET_PREDICATELOCKTARGETTAG_OFFSET

◆ GET_PREDICATELOCKTARGETTAG_PAGE

◆ GET_PREDICATELOCKTARGETTAG_RELATION

◆ GET_PREDICATELOCKTARGETTAG_TYPE

◆ InvalidSerCommitSeqNo

◆ InvalidSerializableXact

◆ PredXactListDataSize

◆ RecoverySerCommitSeqNo

◆ RWConflictDataSize

◆ RWConflictPoolHeaderDataSize

◆ SET_PREDICATELOCKTARGETTAG_PAGE

◆ SET_PREDICATELOCKTARGETTAG_RELATION

◆ SET_PREDICATELOCKTARGETTAG_TUPLE

◆ SXACT_FLAG_COMMITTED

◆ SXACT_FLAG_CONFLICT_OUT

◆ SXACT_FLAG_DEFERRABLE_WAITING

◆ SXACT_FLAG_DOOMED

◆ SXACT_FLAG_PARTIALLY_RELEASED

◆ SXACT_FLAG_PREPARED

◆ SXACT_FLAG_READ_ONLY

◆ SXACT_FLAG_RO_SAFE

◆ SXACT_FLAG_RO_UNSAFE

◆ SXACT_FLAG_ROLLED_BACK

◆ SXACT_FLAG_SUMMARY_CONFLICT_IN

◆ SXACT_FLAG_SUMMARY_CONFLICT_OUT

Typedef Documentation

◆ LOCALPREDICATELOCK

◆ PREDICATELOCK

◆ PredicateLockData

◆ PREDICATELOCKTAG

◆ PREDICATELOCKTARGET

◆ PREDICATELOCKTARGETTAG

◆ PredicateLockTargetType

◆ PredXactList

◆ PredXactListData

◆ RWConflict

◆ RWConflictData

◆ RWConflictPoolHeader

◆ RWConflictPoolHeaderData

◆ SerCommitSeqNo

◆ SERIALIZABLEXACT

◆ SERIALIZABLEXID

◆ SERIALIZABLEXIDTAG

◆ TwoPhasePredicateLockRecord

◆ TwoPhasePredicateRecord

◆ TwoPhasePredicateRecordType

◆ TwoPhasePredicateXactRecord

Enumeration Type Documentation

◆ PredicateLockTargetType

◆ TwoPhasePredicateRecordType

Function Documentation

◆ GetPredicateLockStatusData()

◆ GetSafeSnapshotBlockingPids()