@ -109,8 +109,7 @@ static void MultiXactIdWait(MultiXactId multi, MultiXactStatus status, uint16 in
Relation rel , ItemPointer ctid , XLTW_Oper oper ,
Relation rel , ItemPointer ctid , XLTW_Oper oper ,
int * remaining ) ;
int * remaining ) ;
static bool ConditionalMultiXactIdWait ( MultiXactId multi , MultiXactStatus status ,
static bool ConditionalMultiXactIdWait ( MultiXactId multi , MultiXactStatus status ,
uint16 infomask , Relation rel , ItemPointer ctid ,
uint16 infomask , Relation rel , int * remaining ) ;
XLTW_Oper oper , int * remaining ) ;
static XLogRecPtr log_heap_new_cid ( Relation relation , HeapTuple tup ) ;
static XLogRecPtr log_heap_new_cid ( Relation relation , HeapTuple tup ) ;
static HeapTuple ExtractReplicaIdentity ( Relation rel , HeapTuple tup , bool key_modified ,
static HeapTuple ExtractReplicaIdentity ( Relation rel , HeapTuple tup , bool key_modified ,
bool * copy ) ;
bool * copy ) ;
@ -4438,8 +4437,7 @@ l3:
{
{
if ( ! ConditionalMultiXactIdWait ( ( MultiXactId ) xwait ,
if ( ! ConditionalMultiXactIdWait ( ( MultiXactId ) xwait ,
status , infomask , relation ,
status , infomask , relation ,
& tuple - > t_data - > t_ctid ,
NULL ) )
XLTW_Lock , NULL ) )
ereport ( ERROR ,
ereport ( ERROR ,
( errcode ( ERRCODE_LOCK_NOT_AVAILABLE ) ,
( errcode ( ERRCODE_LOCK_NOT_AVAILABLE ) ,
errmsg ( " could not obtain lock on row in relation \" %s \" " ,
errmsg ( " could not obtain lock on row in relation \" %s \" " ,
@ -6246,11 +6244,10 @@ MultiXactIdWait(MultiXactId multi, MultiXactStatus status, uint16 infomask,
*/
*/
static bool
static bool
ConditionalMultiXactIdWait ( MultiXactId multi , MultiXactStatus status ,
ConditionalMultiXactIdWait ( MultiXactId multi , MultiXactStatus status ,
uint16 infomask , Relation rel , ItemPointer ctid ,
uint16 infomask , Relation rel , int * remaining )
XLTW_Oper oper , int * remaining )
{
{
return Do_MultiXactIdWait ( multi , status , infomask , true ,
return Do_MultiXactIdWait ( multi , status , infomask , true ,
rel , ctid , oper , remaining ) ;
rel , NULL , XLTW_None , remaining ) ;
}
}
/*
/*