31 #define NUM_SERIAL_BUFFERS 16 81 void *recdata,
uint32 len);
bool PageIsPredicateLocked(Relation relation, BlockNumber blkno)
void CheckForSerializableConflictIn(Relation relation, ItemPointer tid, BlockNumber blkno)
void RegisterPredicateLockingXid(TransactionId xid)
void PredicateLockPage(Relation relation, BlockNumber blkno, Snapshot snapshot)
void CheckPointPredicate(void)
Snapshot GetSerializableTransactionSnapshot(Snapshot snapshot)
void CheckTableForSerializableConflictIn(Relation relation)
void AttachSerializableXact(SerializableXactHandle handle)
Size PredicateLockShmemSize(void)
void PredicateLockTID(Relation relation, ItemPointer tid, Snapshot snapshot, TransactionId insert_xid)
SerializableXactHandle ShareSerializableXact(void)
int max_predicate_locks_per_xact
void PredicateLockPageSplit(Relation relation, BlockNumber oldblkno, BlockNumber newblkno)
int max_predicate_locks_per_relation
void PostPrepare_PredicateLocks(TransactionId xid)
int max_predicate_locks_per_page
void PredicateLockPageCombine(Relation relation, BlockNumber oldblkno, BlockNumber newblkno)
void SetSerializableTransactionSnapshot(Snapshot snapshot, VirtualTransactionId *sourcevxid, int sourcepid)
void ReleasePredicateLocks(bool isCommit, bool isReadOnlySafe)
void * SerializableXactHandle
void InitPredicateLocks(void)
void PredicateLockTwoPhaseFinish(TransactionId xid, bool isCommit)
bool CheckForSerializableConflictOutNeeded(Relation relation, Snapshot snapshot)
void PreCommit_CheckForSerializationFailure(void)
void TransferPredicateLocksToHeapRelation(Relation relation)
void CheckForSerializableConflictOut(Relation relation, TransactionId xid, Snapshot snapshot)
void predicatelock_twophase_recover(TransactionId xid, uint16 info, void *recdata, uint32 len)
void PredicateLockRelation(Relation relation, Snapshot snapshot)
void AtPrepare_PredicateLocks(void)