Home
last modified time | relevance | path

Searched refs:replication_slot_catalog_xmin (Results 1 – 25 of 42) sorted by relevance

12

/dports/databases/postgresql96-server/postgresql-9.6.24/src/backend/storage/ipc/
H A Dprocarray.c91 TransactionId replication_slot_catalog_xmin; member
249 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1400 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1457 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1459 result = replication_slot_catalog_xmin; in GetOldestXmin()
1721 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1753 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1755 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2210 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2996 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/backend/storage/ipc/
H A Dprocarray.c91 TransactionId replication_slot_catalog_xmin; member
249 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1400 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1457 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1459 result = replication_slot_catalog_xmin; in GetOldestXmin()
1721 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1753 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1755 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2210 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2996 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql96-plpython/postgresql-9.6.24/src/backend/storage/ipc/
H A Dprocarray.c91 TransactionId replication_slot_catalog_xmin; member
249 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1400 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1457 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1459 result = replication_slot_catalog_xmin; in GetOldestXmin()
1721 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1753 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1755 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2210 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2996 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql10-docs/postgresql-10.19/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1395 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1454 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1456 result = replication_slot_catalog_xmin; in GetOldestXmin()
1719 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1751 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1753 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2211 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2997 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql11-client/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1451 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1453 result = replication_slot_catalog_xmin; in GetOldestXmin()
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1750 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
3005 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql10-client/postgresql-10.19/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1395 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1454 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1456 result = replication_slot_catalog_xmin; in GetOldestXmin()
1719 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1751 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1753 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2211 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2997 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1395 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1454 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1456 result = replication_slot_catalog_xmin; in GetOldestXmin()
1719 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1751 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1753 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2211 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2997 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1395 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1454 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1456 result = replication_slot_catalog_xmin; in GetOldestXmin()
1719 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1751 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1753 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2211 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2997 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1395 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1454 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1456 result = replication_slot_catalog_xmin; in GetOldestXmin()
1719 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1751 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1753 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2211 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2997 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql11-docs/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1451 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1453 result = replication_slot_catalog_xmin; in GetOldestXmin()
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1750 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
3005 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1451 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1453 result = replication_slot_catalog_xmin; in GetOldestXmin()
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1750 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
3005 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; in into_option()
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId;
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1451 TransactionIdIsValid(replication_slot_catalog_xmin) &&
1453 result = replication_slot_catalog_xmin;
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) &&
1750 RecentGlobalXmin = replication_slot_catalog_xmin;
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin;
3005 procArray->replication_slot_catalog_xmin = catalog_xmin;
[all …]
/dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin;
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId;
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1451 TransactionIdIsValid(replication_slot_catalog_xmin) &&
1453 result = replication_slot_catalog_xmin;
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) &&
1750 RecentGlobalXmin = replication_slot_catalog_xmin;
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin;
3005 procArray->replication_slot_catalog_xmin = catalog_xmin;
[all …]
/dports/databases/postgresql11-server/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1451 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1453 result = replication_slot_catalog_xmin; in GetOldestXmin()
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1750 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
3005 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql10-server/postgresql-10.19/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin; member
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1395 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1454 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1456 result = replication_slot_catalog_xmin; in GetOldestXmin()
1719 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1751 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1753 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2211 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2997 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/storage/ipc/
H A Dprocarray.c92 TransactionId replication_slot_catalog_xmin;
247 procArray->replication_slot_catalog_xmin = InvalidTransactionId;
1392 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1451 TransactionIdIsValid(replication_slot_catalog_xmin) &&
1453 result = replication_slot_catalog_xmin;
1716 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1748 if (TransactionIdIsNormal(replication_slot_catalog_xmin) &&
1750 RecentGlobalXmin = replication_slot_catalog_xmin;
2219 oldestSafeXid = procArray->replication_slot_catalog_xmin;
3005 procArray->replication_slot_catalog_xmin = catalog_xmin;
[all …]
/dports/databases/postgresql96-client/postgresql-9.6.24/src/backend/storage/ipc/
H A Dprocarray.c91 TransactionId replication_slot_catalog_xmin; member
249 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1400 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1457 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1459 result = replication_slot_catalog_xmin; in GetOldestXmin()
1721 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1753 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1755 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2210 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2996 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql12-server/postgresql-12.9/src/backend/storage/ipc/
H A Dprocarray.c93 TransactionId replication_slot_catalog_xmin;
248 procArray->replication_slot_catalog_xmin = InvalidTransactionId;
1380 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1439 TransactionIdIsValid(replication_slot_catalog_xmin) &&
1441 result = replication_slot_catalog_xmin;
1707 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin;
1739 if (TransactionIdIsNormal(replication_slot_catalog_xmin) &&
1741 RecentGlobalXmin = replication_slot_catalog_xmin;
2213 oldestSafeXid = procArray->replication_slot_catalog_xmin;
2999 procArray->replication_slot_catalog_xmin = catalog_xmin;
[all …]
/dports/databases/postgresql96-docs/postgresql-9.6.24/src/backend/storage/ipc/
H A Dprocarray.c91 TransactionId replication_slot_catalog_xmin; member
249 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1400 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1457 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1459 result = replication_slot_catalog_xmin; in GetOldestXmin()
1721 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1753 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1755 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2210 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2996 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql96-contrib/postgresql-9.6.24/src/backend/storage/ipc/
H A Dprocarray.c91 TransactionId replication_slot_catalog_xmin; member
249 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1400 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1457 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1459 result = replication_slot_catalog_xmin; in GetOldestXmin()
1721 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1753 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1755 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2210 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2996 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql12-docs/postgresql-12.9/src/backend/storage/ipc/
H A Dprocarray.c93 TransactionId replication_slot_catalog_xmin; member
248 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1380 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1439 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1441 result = replication_slot_catalog_xmin; in GetOldestXmin()
1707 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1739 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1741 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2213 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2999 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/storage/ipc/
H A Dprocarray.c93 TransactionId replication_slot_catalog_xmin; member
248 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1380 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1439 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1441 result = replication_slot_catalog_xmin; in GetOldestXmin()
1707 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1739 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1741 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2213 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2999 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/storage/ipc/
H A Dprocarray.c93 TransactionId replication_slot_catalog_xmin; member
248 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1380 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1439 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1441 result = replication_slot_catalog_xmin; in GetOldestXmin()
1707 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1739 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1741 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2213 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2999 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql12-client/postgresql-12.9/src/backend/storage/ipc/
H A Dprocarray.c93 TransactionId replication_slot_catalog_xmin; member
248 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1380 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1439 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1441 result = replication_slot_catalog_xmin; in GetOldestXmin()
1707 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1739 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1741 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2213 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2999 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]
/dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/storage/ipc/
H A Dprocarray.c93 TransactionId replication_slot_catalog_xmin; member
248 procArray->replication_slot_catalog_xmin = InvalidTransactionId; in CreateSharedProcArray()
1380 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetOldestXmin()
1439 TransactionIdIsValid(replication_slot_catalog_xmin) && in GetOldestXmin()
1441 result = replication_slot_catalog_xmin; in GetOldestXmin()
1707 replication_slot_catalog_xmin = procArray->replication_slot_catalog_xmin; in GetSnapshotData()
1739 if (TransactionIdIsNormal(replication_slot_catalog_xmin) && in GetSnapshotData()
1741 RecentGlobalXmin = replication_slot_catalog_xmin; in GetSnapshotData()
2213 oldestSafeXid = procArray->replication_slot_catalog_xmin; in GetOldestSafeDecodingTransactionId()
2999 procArray->replication_slot_catalog_xmin = catalog_xmin; in ProcArraySetReplicationSlotXmin()
[all …]

12