PostgreSQL Source Code git master
Data Fields
ReplicationSlot Struct Reference

#include <slot.h>

Data Fields

slock_t mutex
 
bool in_use
 
pid_t active_pid
 
bool just_dirtied
 
bool dirty
 
TransactionId effective_xmin
 
TransactionId effective_catalog_xmin
 
ReplicationSlotPersistentData data
 
LWLock io_in_progress_lock
 
ConditionVariable active_cv
 
TransactionId candidate_catalog_xmin
 
XLogRecPtr candidate_xmin_lsn
 
XLogRecPtr candidate_restart_valid
 
XLogRecPtr candidate_restart_lsn
 
XLogRecPtr last_saved_confirmed_flush
 
TimestampTz inactive_since
 
XLogRecPtr last_saved_restart_lsn
 
SlotSyncSkipReason slotsync_skip_reason
 

Detailed Description

Definition at line 180 of file slot.h.

Field Documentation

◆ active_cv

ConditionVariable ReplicationSlot::active_cv

Definition at line 216 of file slot.h.

Referenced by InvalidatePossiblyObsoleteSlot(), ReplicationSlotAcquire(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotRelease(), and ReplicationSlotsShmemInit().

◆ active_pid

pid_t ReplicationSlot::active_pid

Definition at line 189 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().

◆ candidate_catalog_xmin

TransactionId ReplicationSlot::candidate_catalog_xmin

Definition at line 225 of file slot.h.

Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().

◆ candidate_restart_lsn

XLogRecPtr ReplicationSlot::candidate_restart_lsn

Definition at line 228 of file slot.h.

Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().

◆ candidate_restart_valid

XLogRecPtr ReplicationSlot::candidate_restart_valid

Definition at line 227 of file slot.h.

Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().

◆ candidate_xmin_lsn

XLogRecPtr ReplicationSlot::candidate_xmin_lsn

Definition at line 226 of file slot.h.

Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().

◆ data

ReplicationSlotPersistentData ReplicationSlot::data

Definition at line 210 of file slot.h.

Referenced by ApplyLauncherMain(), binary_upgrade_logical_slot_has_caught_up(), CanInvalidateIdleSlot(), CheckPointReplicationSlots(), copy_replication_slot(), create_physical_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), CreateReplicationSlot(), CreateSlotOnDisk(), DecodeDelete(), DecodeInsert(), DecodeMultiInsert(), DecodeSpecConfirm(), DecodeTruncate(), DecodeTXNNeedSkip(), DecodeUpdate(), DecodingContextFindStartpoint(), DetermineSlotInvalidationCause(), get_local_synced_slots(), init_conflict_slot_xmin(), InvalidatePossiblyObsoleteSlot(), local_sync_slot_required(), LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), LogicalIncreaseXminForSlot(), logicalmsg_decode(), logicalrep_worker_launch(), 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(), pgstat_report_replslotsync(), PhysicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), PhysicalWakeupLogicalWalSnd(), ReadReplicationSlot(), ReorderBufferAllocate(), ReorderBufferFree(), ReorderBufferSerializedPath(), ReplicationSlotAcquire(), ReplicationSlotAlter(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDrop(), ReplicationSlotDropPtr(), ReplicationSlotName(), ReplicationSlotPersist(), ReplicationSlotRelease(), ReplicationSlotReserveWal(), ReplicationSlotSave(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), ReplicationSlotSetInactiveSince(), reserve_wal_for_local_slot(), RestoreSlotFromDisk(), SaveSlotToPath(), SearchNamedReplicationSlot(), StandbySlotsHaveCaughtup(), StartLogicalReplication(), StartupDecodingContext(), synchronize_one_slot(), update_and_persist_local_synced_slot(), update_conflict_slot_xmin(), update_local_synced_slot(), update_synced_slots_inactive_since(), and WaitForStandbyConfirmation().

◆ dirty

bool ReplicationSlot::dirty

Definition at line 193 of file slot.h.

Referenced by CheckPointReplicationSlots(), CreateSlotOnDisk(), ReplicationSlotCreate(), ReplicationSlotMarkDirty(), and SaveSlotToPath().

◆ effective_catalog_xmin

TransactionId ReplicationSlot::effective_catalog_xmin

Definition at line 207 of file slot.h.

Referenced by copy_replication_slot(), CreateInitDecodingContext(), DetermineSlotInvalidationCause(), LogicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), ReplicationSlotCreate(), ReplicationSlotsComputeRequiredXmin(), RestoreSlotFromDisk(), synchronize_one_slot(), and update_local_synced_slot().

◆ effective_xmin

TransactionId ReplicationSlot::effective_xmin

Definition at line 206 of file slot.h.

Referenced by copy_replication_slot(), CreateInitDecodingContext(), DetermineSlotInvalidationCause(), init_conflict_slot_xmin(), PhysicalReplicationSlotNewXmin(), ReplicationSlotCreate(), ReplicationSlotRelease(), ReplicationSlotsComputeRequiredXmin(), RestoreSlotFromDisk(), and update_conflict_slot_xmin().

◆ in_use

bool ReplicationSlot::in_use

Definition at line 186 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().

◆ inactive_since

TimestampTz ReplicationSlot::inactive_since

Definition at line 242 of file slot.h.

Referenced by CanInvalidateIdleSlot(), DetermineSlotInvalidationCause(), pg_get_replication_slots(), ReplicationSlotCreate(), and ReplicationSlotSetInactiveSince().

◆ io_in_progress_lock

LWLock ReplicationSlot::io_in_progress_lock

Definition at line 213 of file slot.h.

Referenced by ReplicationSlotsShmemInit(), and SaveSlotToPath().

◆ just_dirtied

bool ReplicationSlot::just_dirtied

Definition at line 192 of file slot.h.

Referenced by CheckPointReplicationSlots(), ReplicationSlotCreate(), ReplicationSlotMarkDirty(), and SaveSlotToPath().

◆ last_saved_confirmed_flush

XLogRecPtr ReplicationSlot::last_saved_confirmed_flush

Definition at line 235 of file slot.h.

Referenced by CheckPointReplicationSlots(), ReplicationSlotCreate(), RestoreSlotFromDisk(), and SaveSlotToPath().

◆ last_saved_restart_lsn

XLogRecPtr ReplicationSlot::last_saved_restart_lsn

Definition at line 268 of file slot.h.

Referenced by CheckPointReplicationSlots(), InvalidatePossiblyObsoleteSlot(), ReplicationSlotCreate(), ReplicationSlotReserveWal(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), RestoreSlotFromDisk(), and SaveSlotToPath().

◆ mutex

slock_t ReplicationSlot::mutex

Definition at line 183 of file slot.h.

Referenced by CheckPointReplicationSlots(), copy_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), DecodingContextFindStartpoint(), init_conflict_slot_xmin(), 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(), ReplicationSlotSetInactiveSince(), ReplicationSlotsShmemInit(), reserve_wal_for_local_slot(), SaveSlotToPath(), StandbySlotsHaveCaughtup(), synchronize_one_slot(), update_conflict_slot_xmin(), update_local_synced_slot(), and update_slotsync_skip_stats().

◆ slotsync_skip_reason

SlotSyncSkipReason ReplicationSlot::slotsync_skip_reason

Definition at line 281 of file slot.h.

Referenced by pg_get_replication_slots(), ReplicationSlotCreate(), and update_slotsync_skip_stats().

The documentation for this struct was generated from the following file: