PostgreSQL Source Code
git master
|
#include <slot.h>
ConditionVariable ReplicationSlot::active_cv |
Definition at line 187 of file slot.h.
Referenced by InvalidatePossiblyObsoleteSlot(), ReplicationSlotAcquire(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotRelease(), and ReplicationSlotsShmemInit().
pid_t ReplicationSlot::active_pid |
Definition at line 160 of file slot.h.
Referenced by InvalidatePossiblyObsoleteSlot(), pg_get_replication_slots(), ReplicationSlotAcquire(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotRelease(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), RestoreSlotFromDisk(), StandbySlotsHaveCaughtup(), and update_synced_slots_inactive_since().
TransactionId ReplicationSlot::candidate_catalog_xmin |
Definition at line 196 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
XLogRecPtr ReplicationSlot::candidate_restart_lsn |
Definition at line 199 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
XLogRecPtr ReplicationSlot::candidate_restart_valid |
Definition at line 198 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
XLogRecPtr ReplicationSlot::candidate_xmin_lsn |
Definition at line 197 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
ReplicationSlotPersistentData ReplicationSlot::data |
Definition at line 181 of file slot.h.
Referenced by binary_upgrade_logical_slot_has_caught_up(), CheckPointReplicationSlots(), copy_replication_slot(), create_physical_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), CreateReplicationSlot(), CreateSlotOnDisk(), DecodeDelete(), DecodeInsert(), DecodeMultiInsert(), DecodeSpecConfirm(), DecodeTruncate(), DecodeTXNNeedSkip(), DecodeUpdate(), DecodingContextFindStartpoint(), get_local_synced_slots(), InvalidatePossiblyObsoleteSlot(), local_sync_slot_required(), LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), LogicalIncreaseXminForSlot(), logicalmsg_decode(), LogicalReplicationSlotHasPendingWal(), LogicalSlotAdvanceAndCheckSnapState(), NeedToWaitForStandbys(), pg_create_logical_replication_slot(), pg_create_physical_replication_slot(), pg_get_replication_slots(), pg_logical_slot_get_changes_guts(), pg_physical_replication_slot_advance(), pg_replication_slot_advance(), PhysicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), PhysicalWakeupLogicalWalSnd(), ReadReplicationSlot(), ReorderBufferAllocate(), ReorderBufferFree(), ReorderBufferSerializedPath(), ReplicationSlotAcquire(), ReplicationSlotAlter(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDrop(), ReplicationSlotDropPtr(), ReplicationSlotName(), ReplicationSlotPersist(), ReplicationSlotRelease(), ReplicationSlotReserveWal(), ReplicationSlotSave(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), reserve_wal_for_local_slot(), RestoreSlotFromDisk(), SaveSlotToPath(), SearchNamedReplicationSlot(), StandbySlotsHaveCaughtup(), StartLogicalReplication(), StartupDecodingContext(), synchronize_one_slot(), update_and_persist_local_synced_slot(), update_local_synced_slot(), update_synced_slots_inactive_since(), and WaitForStandbyConfirmation().
bool ReplicationSlot::dirty |
Definition at line 164 of file slot.h.
Referenced by CheckPointReplicationSlots(), CreateSlotOnDisk(), ReplicationSlotCreate(), ReplicationSlotMarkDirty(), and SaveSlotToPath().
TransactionId ReplicationSlot::effective_catalog_xmin |
Definition at line 178 of file slot.h.
Referenced by copy_replication_slot(), CreateInitDecodingContext(), InvalidatePossiblyObsoleteSlot(), LogicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), ReplicationSlotCreate(), ReplicationSlotsComputeRequiredXmin(), RestoreSlotFromDisk(), synchronize_one_slot(), and update_local_synced_slot().
TransactionId ReplicationSlot::effective_xmin |
Definition at line 177 of file slot.h.
Referenced by copy_replication_slot(), CreateInitDecodingContext(), InvalidatePossiblyObsoleteSlot(), PhysicalReplicationSlotNewXmin(), ReplicationSlotCreate(), ReplicationSlotRelease(), ReplicationSlotsComputeRequiredXmin(), and RestoreSlotFromDisk().
bool ReplicationSlot::in_use |
Definition at line 157 of file slot.h.
Referenced by CheckPointReplicationSlots(), copy_replication_slot(), get_local_synced_slots(), InvalidateObsoleteReplicationSlots(), InvalidatePossiblyObsoleteSlot(), pg_get_replication_slots(), ReadReplicationSlot(), ReplicationSlotAcquire(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotName(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), RestoreSlotFromDisk(), SearchNamedReplicationSlot(), and update_synced_slots_inactive_since().
TimestampTz ReplicationSlot::inactive_since |
Definition at line 209 of file slot.h.
Referenced by pg_get_replication_slots(), ReplicationSlotAcquire(), ReplicationSlotCreate(), ReplicationSlotRelease(), RestoreSlotFromDisk(), and update_synced_slots_inactive_since().
LWLock ReplicationSlot::io_in_progress_lock |
Definition at line 184 of file slot.h.
Referenced by ReplicationSlotsShmemInit(), and SaveSlotToPath().
bool ReplicationSlot::just_dirtied |
Definition at line 163 of file slot.h.
Referenced by CheckPointReplicationSlots(), ReplicationSlotCreate(), ReplicationSlotMarkDirty(), and SaveSlotToPath().
XLogRecPtr ReplicationSlot::last_saved_confirmed_flush |
Definition at line 206 of file slot.h.
Referenced by CheckPointReplicationSlots(), ReplicationSlotCreate(), RestoreSlotFromDisk(), and SaveSlotToPath().
slock_t ReplicationSlot::mutex |
Definition at line 154 of file slot.h.
Referenced by CheckPointReplicationSlots(), copy_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), DecodingContextFindStartpoint(), InvalidatePossiblyObsoleteSlot(), local_sync_slot_required(), LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), LogicalIncreaseXminForSlot(), pg_get_replication_slots(), pg_physical_replication_slot_advance(), PhysicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), ReadReplicationSlot(), ReplicationSlotAcquire(), ReplicationSlotAlter(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotMarkDirty(), ReplicationSlotPersist(), ReplicationSlotRelease(), ReplicationSlotReserveWal(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), ReplicationSlotsShmemInit(), reserve_wal_for_local_slot(), SaveSlotToPath(), StandbySlotsHaveCaughtup(), synchronize_one_slot(), update_local_synced_slot(), and update_synced_slots_inactive_since().