@ -1109,11 +1109,11 @@ ProcArrayApplyRecoveryInfo(RunningTransactions running)
running - > oldestRunningXid ) )
running - > oldestRunningXid ) )
{
{
standbyState = STANDBY_SNAPSHOT_READY ;
standbyState = STANDBY_SNAPSHOT_READY ;
elog ( trace_recovery ( DEBUG1 ) ,
elog ( DEBUG1 ,
" recovery snapshots are now enabled " ) ;
" recovery snapshots are now enabled " ) ;
}
}
else
else
elog ( trace_recovery ( DEBUG1 ) ,
elog ( DEBUG1 ,
" recovery snapshot waiting for non-overflowed snapshot or "
" recovery snapshot waiting for non-overflowed snapshot or "
" until oldest active xid on standby is at least %u (now %u) " ,
" until oldest active xid on standby is at least %u (now %u) " ,
standbySnapshotPendingXmin ,
standbySnapshotPendingXmin ,
@ -1208,7 +1208,7 @@ ProcArrayApplyRecoveryInfo(RunningTransactions running)
KnownAssignedXidsAdd ( xids [ i ] , xids [ i ] , true ) ;
KnownAssignedXidsAdd ( xids [ i ] , xids [ i ] , true ) ;
}
}
KnownAssignedXidsDisplay ( trace_recovery ( DEBUG3 ) ) ;
KnownAssignedXidsDisplay ( DEBUG3 ) ;
}
}
pfree ( xids ) ;
pfree ( xids ) ;
@ -1280,11 +1280,11 @@ ProcArrayApplyRecoveryInfo(RunningTransactions running)
Assert ( FullTransactionIdIsValid ( TransamVariables - > nextXid ) ) ;
Assert ( FullTransactionIdIsValid ( TransamVariables - > nextXid ) ) ;
KnownAssignedXidsDisplay ( trace_recovery ( DEBUG3 ) ) ;
KnownAssignedXidsDisplay ( DEBUG3 ) ;
if ( standbyState = = STANDBY_SNAPSHOT_READY )
if ( standbyState = = STANDBY_SNAPSHOT_READY )
elog ( trace_recovery ( DEBUG1 ) , " recovery snapshots are now enabled " ) ;
elog ( DEBUG1 , " recovery snapshots are now enabled " ) ;
else
else
elog ( trace_recovery ( DEBUG1 ) ,
elog ( DEBUG1 ,
" recovery snapshot waiting for non-overflowed snapshot or "
" recovery snapshot waiting for non-overflowed snapshot or "
" until oldest active xid on standby is at least %u (now %u) " ,
" until oldest active xid on standby is at least %u (now %u) " ,
standbySnapshotPendingXmin ,
standbySnapshotPendingXmin ,
@ -4339,7 +4339,7 @@ RecordKnownAssignedTransactionIds(TransactionId xid)
Assert ( TransactionIdIsValid ( xid ) ) ;
Assert ( TransactionIdIsValid ( xid ) ) ;
Assert ( TransactionIdIsValid ( latestObservedXid ) ) ;
Assert ( TransactionIdIsValid ( latestObservedXid ) ) ;
elog ( trace_recovery ( DEBUG4 ) , " record known xact %u latestObservedXid %u " ,
elog ( DEBUG4 , " record known xact %u latestObservedXid %u " ,
xid , latestObservedXid ) ;
xid , latestObservedXid ) ;
/*
/*
@ -4897,7 +4897,7 @@ KnownAssignedXidsRemove(TransactionId xid)
{
{
Assert ( TransactionIdIsValid ( xid ) ) ;
Assert ( TransactionIdIsValid ( xid ) ) ;
elog ( trace_recovery ( DEBUG4 ) , " remove KnownAssignedXid %u " , xid ) ;
elog ( DEBUG4 , " remove KnownAssignedXid %u " , xid ) ;
/*
/*
* Note : we cannot consider it an error to remove an XID that ' s not
* Note : we cannot consider it an error to remove an XID that ' s not
@ -4951,13 +4951,13 @@ KnownAssignedXidsRemovePreceding(TransactionId removeXid)
if ( ! TransactionIdIsValid ( removeXid ) )
if ( ! TransactionIdIsValid ( removeXid ) )
{
{
elog ( trace_recovery ( DEBUG4 ) , " removing all KnownAssignedXids " ) ;
elog ( DEBUG4 , " removing all KnownAssignedXids " ) ;
pArray - > numKnownAssignedXids = 0 ;
pArray - > numKnownAssignedXids = 0 ;
pArray - > headKnownAssignedXids = pArray - > tailKnownAssignedXids = 0 ;
pArray - > headKnownAssignedXids = pArray - > tailKnownAssignedXids = 0 ;
return ;
return ;
}
}
elog ( trace_recovery ( DEBUG4 ) , " prune KnownAssignedXids to %u " , removeXid ) ;
elog ( DEBUG4 , " prune KnownAssignedXids to %u " , removeXid ) ;
/*
/*
* Mark entries invalid starting at the tail . Since array is sorted , we
* Mark entries invalid starting at the tail . Since array is sorted , we