lmgr.h File Reference

#include "lib/stringinfo.h"
#include "storage/itemptr.h"
#include "storage/lock.h"
#include "utils/rel.h"

Include dependency graph for lmgr.h:

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

Go to the source code of this file.

Typedefs
typedef enum XLTW_Oper	XLTW_Oper

Enumerations
enum	XLTW_Oper {   XLTW_None, XLTW_Update, XLTW_Delete, XLTW_Lock,   XLTW_LockUpdated, XLTW_InsertIndex, XLTW_InsertIndexUnique, XLTW_FetchUpdated,   XLTW_RecheckExclusionConstr }

Functions
void	RelationInitLockInfo (Relation relation)
void	LockRelationOid (Oid relid, LOCKMODE lockmode)
bool	ConditionalLockRelationOid (Oid relid, LOCKMODE lockmode)
void	UnlockRelationId (LockRelId *relid, LOCKMODE lockmode)
void	UnlockRelationOid (Oid relid, LOCKMODE lockmode)
void	LockRelation (Relation relation, LOCKMODE lockmode)
bool	ConditionalLockRelation (Relation relation, LOCKMODE lockmode)
void	UnlockRelation (Relation relation, LOCKMODE lockmode)
bool	LockHasWaitersRelation (Relation relation, LOCKMODE lockmode)
void	LockRelationIdForSession (LockRelId *relid, LOCKMODE lockmode)
void	UnlockRelationIdForSession (LockRelId *relid, LOCKMODE lockmode)
void	LockRelationForExtension (Relation relation, LOCKMODE lockmode)
void	UnlockRelationForExtension (Relation relation, LOCKMODE lockmode)
bool	ConditionalLockRelationForExtension (Relation relation, LOCKMODE lockmode)
int	RelationExtensionLockWaiterCount (Relation relation)
void	LockPage (Relation relation, BlockNumber blkno, LOCKMODE lockmode)
bool	ConditionalLockPage (Relation relation, BlockNumber blkno, LOCKMODE lockmode)
void	UnlockPage (Relation relation, BlockNumber blkno, LOCKMODE lockmode)
void	LockTuple (Relation relation, ItemPointer tid, LOCKMODE lockmode)
bool	ConditionalLockTuple (Relation relation, ItemPointer tid, LOCKMODE lockmode)
void	UnlockTuple (Relation relation, ItemPointer tid, LOCKMODE lockmode)
void	XactLockTableInsert (TransactionId xid)
void	XactLockTableDelete (TransactionId xid)
void	XactLockTableWait (TransactionId xid, Relation rel, ItemPointer ctid, XLTW_Oper oper)
bool	ConditionalXactLockTableWait (TransactionId xid)
void	WaitForLockers (LOCKTAG heaplocktag, LOCKMODE lockmode)
void	WaitForLockersMultiple (List *locktags, LOCKMODE lockmode)
uint32	SpeculativeInsertionLockAcquire (TransactionId xid)
void	SpeculativeInsertionLockRelease (TransactionId xid)
void	SpeculativeInsertionWait (TransactionId xid, uint32 token)
void	LockDatabaseObject (Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void	UnlockDatabaseObject (Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void	LockSharedObject (Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void	UnlockSharedObject (Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void	LockSharedObjectForSession (Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void	UnlockSharedObjectForSession (Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void	DescribeLockTag (StringInfo buf, const LOCKTAG *tag)
const char *	GetLockNameFromTagType (uint16 locktag_type)

Typedef Documentation

XLTW_Oper

typedef enum XLTW_Oper XLTW_Oper

Enumeration Type Documentation

XLTW_Oper

enum XLTW_Oper

Enumerator
XLTW_None
XLTW_Update
XLTW_Delete
XLTW_Lock
XLTW_LockUpdated
XLTW_InsertIndex
XLTW_InsertIndexUnique
XLTW_FetchUpdated
XLTW_RecheckExclusionConstr

Definition at line 24 of file lmgr.h.

{
    XLTW_None,
    XLTW_Update,
    XLTW_Delete,
    XLTW_Lock,
    XLTW_LockUpdated,
    XLTW_InsertIndex,
    XLTW_InsertIndexUnique,
    XLTW_FetchUpdated,
    XLTW_RecheckExclusionConstr
} XLTW_Oper;

Function Documentation

ConditionalLockPage()

bool ConditionalLockPage	(	Relation	relation,
		BlockNumber	blkno,
		LOCKMODE	lockmode
	)

Definition at line 419 of file lmgr.c.

References LockRelId::dbId, LockAcquire(), LOCKACQUIRE_NOT_AVAIL, LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_PAGE.

Referenced by ginInsertCleanup().

{
    LOCKTAG     tag;

    SET_LOCKTAG_PAGE(tag,
                     relation->rd_lockInfo.lockRelId.dbId,
                     relation->rd_lockInfo.lockRelId.relId,
                     blkno);

    return (LockAcquire(&tag, lockmode, false, true) != LOCKACQUIRE_NOT_AVAIL);
}

ConditionalLockRelation()

bool ConditionalLockRelation	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 226 of file lmgr.c.

References AcceptInvalidationMessages(), LockRelId::dbId, LockAcquire(), LOCKACQUIRE_ALREADY_HELD, LOCKACQUIRE_NOT_AVAIL, LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by lazy_truncate_heap().

{
    LOCKTAG     tag;
    LockAcquireResult res;

    SET_LOCKTAG_RELATION(tag,
                         relation->rd_lockInfo.lockRelId.dbId,
                         relation->rd_lockInfo.lockRelId.relId);

    res = LockAcquire(&tag, lockmode, false, true);

    if (res == LOCKACQUIRE_NOT_AVAIL)
        return false;

    /*
     * Now that we have the lock, check for invalidation messages; see notes
     * in LockRelationOid.
     */
    if (res != LOCKACQUIRE_ALREADY_HELD)
        AcceptInvalidationMessages();

    return true;
}

ConditionalLockRelationForExtension()

bool ConditionalLockRelationForExtension	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 350 of file lmgr.c.

References LockRelId::dbId, LockAcquire(), LOCKACQUIRE_NOT_AVAIL, LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION_EXTEND.

Referenced by RelationGetBufferForTuple().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION_EXTEND(tag,
                                relation->rd_lockInfo.lockRelId.dbId,
                                relation->rd_lockInfo.lockRelId.relId);

    return (LockAcquire(&tag, lockmode, false, true) != LOCKACQUIRE_NOT_AVAIL);
}

ConditionalLockRelationOid()

bool ConditionalLockRelationOid	(	Oid	relid,
		LOCKMODE	lockmode
	)

Definition at line 138 of file lmgr.c.

References AcceptInvalidationMessages(), LockAcquire(), LOCKACQUIRE_ALREADY_HELD, LOCKACQUIRE_NOT_AVAIL, and SetLocktagRelationOid().

Referenced by AlterTableMoveAll(), analyze_rel(), do_autovacuum(), LockTableRecurse(), LockViewRecurse_walker(), RangeVarGetRelidExtended(), and vacuum_rel().

{
    LOCKTAG     tag;
    LockAcquireResult res;

    SetLocktagRelationOid(&tag, relid);

    res = LockAcquire(&tag, lockmode, false, true);

    if (res == LOCKACQUIRE_NOT_AVAIL)
        return false;

    /*
     * Now that we have the lock, check for invalidation messages; see notes
     * in LockRelationOid.
     */
    if (res != LOCKACQUIRE_ALREADY_HELD)
        AcceptInvalidationMessages();

    return true;
}

ConditionalLockTuple()

bool ConditionalLockTuple	(	Relation	relation,
		ItemPointer	tid,
		LOCKMODE	lockmode
	)

Definition at line 475 of file lmgr.c.

References LockRelId::dbId, ItemPointerGetBlockNumber, ItemPointerGetOffsetNumber, LockAcquire(), LOCKACQUIRE_NOT_AVAIL, LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_TUPLE.

{
    LOCKTAG     tag;

    SET_LOCKTAG_TUPLE(tag,
                      relation->rd_lockInfo.lockRelId.dbId,
                      relation->rd_lockInfo.lockRelId.relId,
                      ItemPointerGetBlockNumber(tid),
                      ItemPointerGetOffsetNumber(tid));

    return (LockAcquire(&tag, lockmode, false, true) != LOCKACQUIRE_NOT_AVAIL);
}

ConditionalXactLockTableWait()

bool ConditionalXactLockTableWait

(

TransactionId

xid

)

Definition at line 627 of file lmgr.c.

References Assert, GetTopTransactionIdIfAny(), LockAcquire(), LOCKACQUIRE_NOT_AVAIL, LockRelease(), pg_usleep(), SET_LOCKTAG_TRANSACTION, ShareLock, SubTransGetTopmostTransaction(), TransactionIdEquals, TransactionIdIsInProgress(), and TransactionIdIsValid.

Referenced by Do_MultiXactIdWait(), EvalPlanQualFetch(), and heap_lock_tuple().

{
    LOCKTAG     tag;
    bool        first = true;

    for (;;)
    {
        Assert(TransactionIdIsValid(xid));
        Assert(!TransactionIdEquals(xid, GetTopTransactionIdIfAny()));

        SET_LOCKTAG_TRANSACTION(tag, xid);

        if (LockAcquire(&tag, ShareLock, false, true) == LOCKACQUIRE_NOT_AVAIL)
            return false;

        LockRelease(&tag, ShareLock, false);

        if (!TransactionIdIsInProgress(xid))
            break;

        /* See XactLockTableWait about this case */
        if (!first)
            pg_usleep(1000L);
        first = false;
        xid = SubTransGetTopmostTransaction(xid);
    }

    return true;
}

DescribeLockTag()

void DescribeLockTag	(	StringInfo	buf,
		const LOCKTAG *	tag
	)

Definition at line 980 of file lmgr.c.

References _, appendStringInfo(), LOCKTAG_ADVISORY, LOCKTAG::locktag_field1, LOCKTAG::locktag_field2, LOCKTAG::locktag_field3, LOCKTAG::locktag_field4, LOCKTAG_OBJECT, LOCKTAG_PAGE, LOCKTAG_RELATION, LOCKTAG_RELATION_EXTEND, LOCKTAG_SPECULATIVE_TOKEN, LOCKTAG_TRANSACTION, LOCKTAG_TUPLE, LOCKTAG::locktag_type, LOCKTAG_USERLOCK, and LOCKTAG_VIRTUALTRANSACTION.

Referenced by DeadLockReport(), and ProcSleep().

{
    switch ((LockTagType) tag->locktag_type)
    {
        case LOCKTAG_RELATION:
            appendStringInfo(buf,
                             _("relation %u of database %u"),
                             tag->locktag_field2,
                             tag->locktag_field1);
            break;
        case LOCKTAG_RELATION_EXTEND:
            appendStringInfo(buf,
                             _("extension of relation %u of database %u"),
                             tag->locktag_field2,
                             tag->locktag_field1);
            break;
        case LOCKTAG_PAGE:
            appendStringInfo(buf,
                             _("page %u of relation %u of database %u"),
                             tag->locktag_field3,
                             tag->locktag_field2,
                             tag->locktag_field1);
            break;
        case LOCKTAG_TUPLE:
            appendStringInfo(buf,
                             _("tuple (%u,%u) of relation %u of database %u"),
                             tag->locktag_field3,
                             tag->locktag_field4,
                             tag->locktag_field2,
                             tag->locktag_field1);
            break;
        case LOCKTAG_TRANSACTION:
            appendStringInfo(buf,
                             _("transaction %u"),
                             tag->locktag_field1);
            break;
        case LOCKTAG_VIRTUALTRANSACTION:
            appendStringInfo(buf,
                             _("virtual transaction %d/%u"),
                             tag->locktag_field1,
                             tag->locktag_field2);
            break;
        case LOCKTAG_SPECULATIVE_TOKEN:
            appendStringInfo(buf,
                             _("speculative token %u of transaction %u"),
                             tag->locktag_field2,
                             tag->locktag_field1);
            break;
        case LOCKTAG_OBJECT:
            appendStringInfo(buf,
                             _("object %u of class %u of database %u"),
                             tag->locktag_field3,
                             tag->locktag_field2,
                             tag->locktag_field1);
            break;
        case LOCKTAG_USERLOCK:
            /* reserved for old contrib code, now on pgfoundry */
            appendStringInfo(buf,
                             _("user lock [%u,%u,%u]"),
                             tag->locktag_field1,
                             tag->locktag_field2,
                             tag->locktag_field3);
            break;
        case LOCKTAG_ADVISORY:
            appendStringInfo(buf,
                             _("advisory lock [%u,%u,%u,%u]"),
                             tag->locktag_field1,
                             tag->locktag_field2,
                             tag->locktag_field3,
                             tag->locktag_field4);
            break;
        default:
            appendStringInfo(buf,
                             _("unrecognized locktag type %d"),
                             (int) tag->locktag_type);
            break;
    }
}

GetLockNameFromTagType()

const char* GetLockNameFromTagType

(

uint16

locktag_type

)

Definition at line 1065 of file lmgr.c.

References LOCKTAG_LAST_TYPE, and LockTagTypeNames.

Referenced by pgstat_get_wait_event().

{
    if (locktag_type > LOCKTAG_LAST_TYPE)
        return "???";
    return LockTagTypeNames[locktag_type];
}

LockDatabaseObject()

void LockDatabaseObject	(	Oid	classid,
		Oid	objid,
		uint16	objsubid,
		LOCKMODE	lockmode
	)

Definition at line 856 of file lmgr.c.

References AcceptInvalidationMessages(), LockAcquire(), MyDatabaseId, and SET_LOCKTAG_OBJECT.

Referenced by AcquireDeletionLock(), AddEnumLabel(), get_object_address(), RangeVarGetAndCheckCreationNamespace(), and RenameEnumLabel().

{
    LOCKTAG     tag;

    SET_LOCKTAG_OBJECT(tag,
                       MyDatabaseId,
                       classid,
                       objid,
                       objsubid);

    (void) LockAcquire(&tag, lockmode, false, false);

    /* Make sure syscaches are up-to-date with any changes we waited for */
    AcceptInvalidationMessages();
}

LockHasWaitersRelation()

bool LockHasWaitersRelation	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 275 of file lmgr.c.

References LockRelId::dbId, LockHasWaiters(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by count_nondeletable_pages().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION(tag,
                         relation->rd_lockInfo.lockRelId.dbId,
                         relation->rd_lockInfo.lockRelId.relId);

    return LockHasWaiters(&tag, lockmode, false);
}

LockPage()

void LockPage	(	Relation	relation,
		BlockNumber	blkno,
		LOCKMODE	lockmode
	)

Definition at line 400 of file lmgr.c.

References LockRelId::dbId, LockAcquire(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_PAGE.

Referenced by ginInsertCleanup().

{
    LOCKTAG     tag;

    SET_LOCKTAG_PAGE(tag,
                     relation->rd_lockInfo.lockRelId.dbId,
                     relation->rd_lockInfo.lockRelId.relId,
                     blkno);

    (void) LockAcquire(&tag, lockmode, false, false);
}

LockRelation()

void LockRelation	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 199 of file lmgr.c.

References AcceptInvalidationMessages(), LockRelId::dbId, LockAcquire(), LOCKACQUIRE_ALREADY_HELD, LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by index_create().

{
    LOCKTAG     tag;
    LockAcquireResult res;

    SET_LOCKTAG_RELATION(tag,
                         relation->rd_lockInfo.lockRelId.dbId,
                         relation->rd_lockInfo.lockRelId.relId);

    res = LockAcquire(&tag, lockmode, false, false);

    /*
     * Now that we have the lock, check for invalidation messages; see notes
     * in LockRelationOid.
     */
    if (res != LOCKACQUIRE_ALREADY_HELD)
        AcceptInvalidationMessages();
}

LockRelationForExtension()

void LockRelationForExtension	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 332 of file lmgr.c.

References LockRelId::dbId, LockAcquire(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION_EXTEND.

Referenced by _bt_getbuf(), BloomNewBuffer(), brin_getinsertbuffer(), brin_page_cleanup(), btvacuumscan(), fsm_extend(), GinNewBuffer(), ginvacuumcleanup(), gistNewBuffer(), gistvacuumcleanup(), lazy_scan_heap(), pgstat_index(), RelationGetBufferForTuple(), revmap_physical_extend(), SpGistNewBuffer(), spgvacuumscan(), and vm_extend().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION_EXTEND(tag,
                                relation->rd_lockInfo.lockRelId.dbId,
                                relation->rd_lockInfo.lockRelId.relId);

    (void) LockAcquire(&tag, lockmode, false, false);
}

LockRelationIdForSession()

void LockRelationIdForSession	(	LockRelId *	relid,
		LOCKMODE	lockmode
	)

Definition at line 299 of file lmgr.c.

References LockRelId::dbId, LockAcquire(), LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by DefineIndex(), index_drop(), and vacuum_rel().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION(tag, relid->dbId, relid->relId);

    (void) LockAcquire(&tag, lockmode, true, false);
}

LockRelationOid()

void LockRelationOid	(	Oid	relid,
		LOCKMODE	lockmode
	)

Definition at line 105 of file lmgr.c.

References AcceptInvalidationMessages(), LockAcquire(), LOCKACQUIRE_ALREADY_HELD, and SetLocktagRelationOid().

Referenced by AcquireDeletionLock(), AcquireExecutorLocks(), AlterTableMoveAll(), ATExecAttachPartition(), ATExecDetachPartition(), copy_heap_data(), CreateTrigger(), ExecLockNonLeafAppendTables(), ExecRefreshMatView(), find_inheritance_children(), heap_drop_with_catalog(), InitCatCachePhase2(), InitPlan(), load_critical_index(), lock_and_open_sequence(), LockTableRecurse(), LockViewRecurse_walker(), pg_replication_origin_advance(), RangeVarCallbackForAttachIndex(), RangeVarCallbackForDropRelation(), RangeVarCallbackForReindexIndex(), RangeVarGetAndCheckCreationNamespace(), RangeVarGetRelidExtended(), relation_open(), ScanQueryForLocks(), and try_relation_open().

{
    LOCKTAG     tag;
    LockAcquireResult res;

    SetLocktagRelationOid(&tag, relid);

    res = LockAcquire(&tag, lockmode, false, false);

    /*
     * Now that we have the lock, check for invalidation messages, so that we
     * will update or flush any stale relcache entry before we try to use it.
     * RangeVarGetRelid() specifically relies on us for this.  We can skip
     * this in the not-uncommon case that we already had the same type of lock
     * being requested, since then no one else could have modified the
     * relcache entry in an undesirable way.  (In the case where our own xact
     * modifies the rel, the relcache update happens via
     * CommandCounterIncrement, not here.)
     */
    if (res != LOCKACQUIRE_ALREADY_HELD)
        AcceptInvalidationMessages();
}

LockSharedObject()

void LockSharedObject	(	Oid	classid,
		Oid	objid,
		uint16	objsubid,
		LOCKMODE	lockmode
	)

Definition at line 897 of file lmgr.c.

References AcceptInvalidationMessages(), InvalidOid, LockAcquire(), and SET_LOCKTAG_OBJECT.

Referenced by AddSubscriptionRelState(), AlterSubscription(), DropRole(), DropSubscription(), get_db_info(), get_object_address(), InitPostgres(), PreCommit_Notify(), shdepLockAndCheckObject(), and UpdateSubscriptionRelState().

{
    LOCKTAG     tag;

    SET_LOCKTAG_OBJECT(tag,
                       InvalidOid,
                       classid,
                       objid,
                       objsubid);

    (void) LockAcquire(&tag, lockmode, false, false);

    /* Make sure syscaches are up-to-date with any changes we waited for */
    AcceptInvalidationMessages();
}

LockSharedObjectForSession()

void LockSharedObjectForSession	(	Oid	classid,
		Oid	objid,
		uint16	objsubid,
		LOCKMODE	lockmode
	)

Definition at line 939 of file lmgr.c.

References InvalidOid, LockAcquire(), and SET_LOCKTAG_OBJECT.

Referenced by dbase_redo(), and movedb().

{
    LOCKTAG     tag;

    SET_LOCKTAG_OBJECT(tag,
                       InvalidOid,
                       classid,
                       objid,
                       objsubid);

    (void) LockAcquire(&tag, lockmode, true, false);
}

LockTuple()

void LockTuple	(	Relation	relation,
		ItemPointer	tid,
		LOCKMODE	lockmode
	)

Definition at line 455 of file lmgr.c.

References LockRelId::dbId, ItemPointerGetBlockNumber, ItemPointerGetOffsetNumber, LockAcquire(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_TUPLE.

{
    LOCKTAG     tag;

    SET_LOCKTAG_TUPLE(tag,
                      relation->rd_lockInfo.lockRelId.dbId,
                      relation->rd_lockInfo.lockRelId.relId,
                      ItemPointerGetBlockNumber(tid),
                      ItemPointerGetOffsetNumber(tid));

    (void) LockAcquire(&tag, lockmode, false, false);
}

RelationExtensionLockWaiterCount()

int RelationExtensionLockWaiterCount

(

Relation

relation

)

Definition at line 367 of file lmgr.c.

References LockRelId::dbId, LockInfoData::lockRelId, LockWaiterCount(), RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION_EXTEND.

Referenced by RelationAddExtraBlocks().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION_EXTEND(tag,
                                relation->rd_lockInfo.lockRelId.dbId,
                                relation->rd_lockInfo.lockRelId.relId);

    return LockWaiterCount(&tag);
}

RelationInitLockInfo()

void RelationInitLockInfo

(

Relation

relation

)

Definition at line 68 of file lmgr.c.

References Assert, LockRelId::dbId, InvalidOid, LockInfoData::lockRelId, MyDatabaseId, OidIsValid, RelationData::rd_lockInfo, RelationData::rd_rel, RelationGetRelid, RelationIsValid, and LockRelId::relId.

Referenced by formrdesc(), load_relcache_init_file(), RelationBuildDesc(), and RelationBuildLocalRelation().

{
    Assert(RelationIsValid(relation));
    Assert(OidIsValid(RelationGetRelid(relation)));

    relation->rd_lockInfo.lockRelId.relId = RelationGetRelid(relation);

    if (relation->rd_rel->relisshared)
        relation->rd_lockInfo.lockRelId.dbId = InvalidOid;
    else
        relation->rd_lockInfo.lockRelId.dbId = MyDatabaseId;
}

SpeculativeInsertionLockAcquire()

uint32 SpeculativeInsertionLockAcquire

(

TransactionId

xid

)

Definition at line 669 of file lmgr.c.

References ExclusiveLock, LockAcquire(), SET_LOCKTAG_SPECULATIVE_INSERTION, and speculativeInsertionToken.

Referenced by ExecInsert().

{
    LOCKTAG     tag;

    speculativeInsertionToken++;

    /*
     * Check for wrap-around. Zero means no token is held, so don't use that.
     */
    if (speculativeInsertionToken == 0)
        speculativeInsertionToken = 1;

    SET_LOCKTAG_SPECULATIVE_INSERTION(tag, xid, speculativeInsertionToken);

    (void) LockAcquire(&tag, ExclusiveLock, false, false);

    return speculativeInsertionToken;
}

SpeculativeInsertionLockRelease()

void SpeculativeInsertionLockRelease

(

TransactionId

xid

)

Definition at line 695 of file lmgr.c.

References ExclusiveLock, LockRelease(), SET_LOCKTAG_SPECULATIVE_INSERTION, and speculativeInsertionToken.

Referenced by ExecInsert().

{
    LOCKTAG     tag;

    SET_LOCKTAG_SPECULATIVE_INSERTION(tag, xid, speculativeInsertionToken);

    LockRelease(&tag, ExclusiveLock, false);
}

SpeculativeInsertionWait()

void SpeculativeInsertionWait	(	TransactionId	xid,
		uint32	token
	)

Definition at line 711 of file lmgr.c.

References Assert, LockAcquire(), LockRelease(), SET_LOCKTAG_SPECULATIVE_INSERTION, ShareLock, and TransactionIdIsValid.

Referenced by _bt_doinsert(), and check_exclusion_or_unique_constraint().

{
    LOCKTAG     tag;

    SET_LOCKTAG_SPECULATIVE_INSERTION(tag, xid, token);

    Assert(TransactionIdIsValid(xid));
    Assert(token != 0);

    (void) LockAcquire(&tag, ShareLock, false, false);
    LockRelease(&tag, ShareLock, false);
}

UnlockDatabaseObject()

void UnlockDatabaseObject	(	Oid	classid,
		Oid	objid,
		uint16	objsubid,
		LOCKMODE	lockmode
	)

Definition at line 877 of file lmgr.c.

References LockRelease(), MyDatabaseId, and SET_LOCKTAG_OBJECT.

Referenced by get_object_address(), RangeVarGetAndCheckCreationNamespace(), and ReleaseDeletionLock().

{
    LOCKTAG     tag;

    SET_LOCKTAG_OBJECT(tag,
                       MyDatabaseId,
                       classid,
                       objid,
                       objsubid);

    LockRelease(&tag, lockmode, false);
}

UnlockPage()

void UnlockPage	(	Relation	relation,
		BlockNumber	blkno,
		LOCKMODE	lockmode
	)

Definition at line 435 of file lmgr.c.

References LockRelId::dbId, LockRelease(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_PAGE.

Referenced by ginInsertCleanup().

{
    LOCKTAG     tag;

    SET_LOCKTAG_PAGE(tag,
                     relation->rd_lockInfo.lockRelId.dbId,
                     relation->rd_lockInfo.lockRelId.relId,
                     blkno);

    LockRelease(&tag, lockmode, false);
}

UnlockRelation()

void UnlockRelation	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 257 of file lmgr.c.

References LockRelId::dbId, LockRelease(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by lazy_truncate_heap().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION(tag,
                         relation->rd_lockInfo.lockRelId.dbId,
                         relation->rd_lockInfo.lockRelId.relId);

    LockRelease(&tag, lockmode, false);
}

UnlockRelationForExtension()

void UnlockRelationForExtension	(	Relation	relation,
		LOCKMODE	lockmode
	)

Definition at line 382 of file lmgr.c.

References LockRelId::dbId, LockRelease(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_RELATION_EXTEND.

Referenced by _bt_getbuf(), BloomNewBuffer(), brin_getinsertbuffer(), brin_page_cleanup(), btvacuumscan(), fsm_extend(), GinNewBuffer(), ginvacuumcleanup(), gistNewBuffer(), gistvacuumcleanup(), lazy_scan_heap(), pgstat_index(), RelationGetBufferForTuple(), revmap_physical_extend(), SpGistNewBuffer(), spgvacuumscan(), and vm_extend().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION_EXTEND(tag,
                                relation->rd_lockInfo.lockRelId.dbId,
                                relation->rd_lockInfo.lockRelId.relId);

    LockRelease(&tag, lockmode, false);
}

UnlockRelationId()

void UnlockRelationId	(	LockRelId *	relid,
		LOCKMODE	lockmode
	)

Definition at line 167 of file lmgr.c.

References LockRelId::dbId, LockRelease(), LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by index_close(), and relation_close().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION(tag, relid->dbId, relid->relId);

    LockRelease(&tag, lockmode, false);
}

UnlockRelationIdForSession()

void UnlockRelationIdForSession	(	LockRelId *	relid,
		LOCKMODE	lockmode
	)

Definition at line 312 of file lmgr.c.

References LockRelId::dbId, LockRelease(), LockRelId::relId, and SET_LOCKTAG_RELATION.

Referenced by DefineIndex(), index_drop(), and vacuum_rel().

{
    LOCKTAG     tag;

    SET_LOCKTAG_RELATION(tag, relid->dbId, relid->relId);

    LockRelease(&tag, lockmode, true);
}

UnlockRelationOid()

void UnlockRelationOid	(	Oid	relid,
		LOCKMODE	lockmode
	)

Definition at line 182 of file lmgr.c.

References LockRelease(), and SetLocktagRelationOid().

Referenced by AcquireExecutorLocks(), do_autovacuum(), expand_vacuum_rel(), find_inheritance_children(), InitCatCachePhase2(), load_critical_index(), LockTableRecurse(), pg_replication_origin_advance(), RangeVarCallbackForAttachIndex(), RangeVarCallbackForDropRelation(), RangeVarCallbackForReindexIndex(), RangeVarGetAndCheckCreationNamespace(), RangeVarGetRelidExtended(), ReleaseDeletionLock(), ScanQueryForLocks(), and try_relation_open().

{
    LOCKTAG     tag;

    SetLocktagRelationOid(&tag, relid);

    LockRelease(&tag, lockmode, false);
}

UnlockSharedObject()

void UnlockSharedObject	(	Oid	classid,
		Oid	objid,
		uint16	objsubid,
		LOCKMODE	lockmode
	)

Definition at line 918 of file lmgr.c.

References InvalidOid, LockRelease(), and SET_LOCKTAG_OBJECT.

Referenced by AlterDatabaseSet(), createdb_failure_callback(), get_db_info(), and get_object_address().

{
    LOCKTAG     tag;

    SET_LOCKTAG_OBJECT(tag,
                       InvalidOid,
                       classid,
                       objid,
                       objsubid);

    LockRelease(&tag, lockmode, false);
}

UnlockSharedObjectForSession()

void UnlockSharedObjectForSession	(	Oid	classid,
		Oid	objid,
		uint16	objsubid,
		LOCKMODE	lockmode
	)

Definition at line 957 of file lmgr.c.

References InvalidOid, LockRelease(), and SET_LOCKTAG_OBJECT.

Referenced by dbase_redo(), and movedb().

{
    LOCKTAG     tag;

    SET_LOCKTAG_OBJECT(tag,
                       InvalidOid,
                       classid,
                       objid,
                       objsubid);

    LockRelease(&tag, lockmode, true);
}

UnlockTuple()

void UnlockTuple	(	Relation	relation,
		ItemPointer	tid,
		LOCKMODE	lockmode
	)

Definition at line 492 of file lmgr.c.

References LockRelId::dbId, ItemPointerGetBlockNumber, ItemPointerGetOffsetNumber, LockRelease(), LockInfoData::lockRelId, RelationData::rd_lockInfo, LockRelId::relId, and SET_LOCKTAG_TUPLE.

{
    LOCKTAG     tag;

    SET_LOCKTAG_TUPLE(tag,
                      relation->rd_lockInfo.lockRelId.dbId,
                      relation->rd_lockInfo.lockRelId.relId,
                      ItemPointerGetBlockNumber(tid),
                      ItemPointerGetOffsetNumber(tid));

    LockRelease(&tag, lockmode, false);
}

WaitForLockers()

void WaitForLockers	(	LOCKTAG	heaplocktag,
		LOCKMODE	lockmode
	)

Definition at line 837 of file lmgr.c.

References list_free(), list_make1, and WaitForLockersMultiple().

Referenced by DefineIndex(), and index_drop().

{
    List       *l;

    l = list_make1(&heaplocktag);
    WaitForLockersMultiple(l, lockmode);
    list_free(l);
}

WaitForLockersMultiple()

void WaitForLockersMultiple	(	List *	locktags,
		LOCKMODE	lockmode
	)

Definition at line 793 of file lmgr.c.

References GetLockConflicts(), lappend(), lfirst, list_free_deep(), list_length(), NIL, VirtualTransactionIdIsValid, and VirtualXactLock().

Referenced by WaitForLockers().

{
    List       *holders = NIL;
    ListCell   *lc;

    /* Done if no locks to wait for */
    if (list_length(locktags) == 0)
        return;

    /* Collect the transactions we need to wait on */
    foreach(lc, locktags)
    {
        LOCKTAG    *locktag = lfirst(lc);

        holders = lappend(holders, GetLockConflicts(locktag, lockmode));
    }

    /*
     * Note: GetLockConflicts() never reports our own xid, hence we need not
     * check for that.  Also, prepared xacts are not reported, which is fine
     * since they certainly aren't going to do anything anymore.
     */

    /* Finally wait for each such transaction to complete */
    foreach(lc, holders)
    {
        VirtualTransactionId *lockholders = lfirst(lc);

        while (VirtualTransactionIdIsValid(*lockholders))
        {
            VirtualXactLock(*lockholders, true);
            lockholders++;
        }
    }

    list_free_deep(holders);
}

XactLockTableDelete()

void XactLockTableDelete

(

TransactionId

xid

)

Definition at line 530 of file lmgr.c.

References ExclusiveLock, LockRelease(), and SET_LOCKTAG_TRANSACTION.

Referenced by CommitSubTransaction().

{
    LOCKTAG     tag;

    SET_LOCKTAG_TRANSACTION(tag, xid);

    LockRelease(&tag, ExclusiveLock, false);
}

XactLockTableInsert()

void XactLockTableInsert

(

TransactionId

xid

)

Definition at line 513 of file lmgr.c.

References ExclusiveLock, LockAcquire(), and SET_LOCKTAG_TRANSACTION.

Referenced by AssignTransactionId().

{
    LOCKTAG     tag;

    SET_LOCKTAG_TRANSACTION(tag, xid);

    (void) LockAcquire(&tag, ExclusiveLock, false, false);
}

XactLockTableWait()

void XactLockTableWait	(	TransactionId	xid,
		Relation	rel,
		ItemPointer	ctid,
		XLTW_Oper	oper
	)

Definition at line 554 of file lmgr.c.

References ErrorContextCallback::arg, Assert, callback(), ErrorContextCallback::callback, XactLockTableWaitInfo::ctid, error_context_stack, GetTopTransactionIdIfAny(), ItemPointerIsValid, LockAcquire(), LockRelease(), XactLockTableWaitInfo::oper, pg_usleep(), ErrorContextCallback::previous, XactLockTableWaitInfo::rel, RelationIsValid, SET_LOCKTAG_TRANSACTION, ShareLock, SubTransGetTopmostTransaction(), TransactionIdEquals, TransactionIdIsInProgress(), TransactionIdIsValid, XactLockTableWaitErrorCb(), and XLTW_None.

Referenced by _bt_doinsert(), check_exclusion_or_unique_constraint(), Do_MultiXactIdWait(), EvalPlanQualFetch(), heap_delete(), heap_lock_tuple(), heap_lock_updated_tuple_rec(), heap_update(), IndexBuildHeapRangeScan(), RelationFindReplTupleByIndex(), RelationFindReplTupleSeq(), and SnapBuildWaitSnapshot().

{
    LOCKTAG     tag;
    XactLockTableWaitInfo info;
    ErrorContextCallback callback;
    bool        first = true;

    /*
     * If an operation is specified, set up our verbose error context
     * callback.
     */
    if (oper != XLTW_None)
    {
        Assert(RelationIsValid(rel));
        Assert(ItemPointerIsValid(ctid));

        info.rel = rel;
        info.ctid = ctid;
        info.oper = oper;

        callback.callback = XactLockTableWaitErrorCb;
        callback.arg = &info;
        callback.previous = error_context_stack;
        error_context_stack = &callback;
    }

    for (;;)
    {
        Assert(TransactionIdIsValid(xid));
        Assert(!TransactionIdEquals(xid, GetTopTransactionIdIfAny()));

        SET_LOCKTAG_TRANSACTION(tag, xid);

        (void) LockAcquire(&tag, ShareLock, false, false);

        LockRelease(&tag, ShareLock, false);

        if (!TransactionIdIsInProgress(xid))
            break;

        /*
         * If the Xid belonged to a subtransaction, then the lock would have
         * gone away as soon as it was finished; for correct tuple visibility,
         * the right action is to wait on its parent transaction to go away.
         * But instead of going levels up one by one, we can just wait for the
         * topmost transaction to finish with the same end result, which also
         * incurs less locktable traffic.
         *
         * Some uses of this function don't involve tuple visibility -- such
         * as when building snapshots for logical decoding.  It is possible to
         * see a transaction in ProcArray before it registers itself in the
         * locktable.  The topmost transaction in that case is the same xid,
         * so we try again after a short sleep.  (Don't sleep the first time
         * through, to avoid slowing down the normal case.)
         */
        if (!first)
            pg_usleep(1000L);
        first = false;
        xid = SubTransGetTopmostTransaction(xid);
    }

    if (oper != XLTW_None)
        error_context_stack = callback.previous;
}