PostgreSQL Source Code
git master
|
#include <slot.h>
ConditionVariable ReplicationSlot::active_cv |
Definition at line 162 of file slot.h.
Referenced by InvalidateObsoleteReplicationSlots(), ReplicationSlotAcquireInternal(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotRelease(), and ReplicationSlotsShmemInit().
pid_t ReplicationSlot::active_pid |
Definition at line 135 of file slot.h.
Referenced by pg_get_replication_slots(), ReplicationSlotAcquireInternal(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotRelease(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), and RestoreSlotFromDisk().
TransactionId ReplicationSlot::candidate_catalog_xmin |
Definition at line 171 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
XLogRecPtr ReplicationSlot::candidate_restart_lsn |
Definition at line 174 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
XLogRecPtr ReplicationSlot::candidate_restart_valid |
Definition at line 173 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
XLogRecPtr ReplicationSlot::candidate_xmin_lsn |
Definition at line 172 of file slot.h.
Referenced by LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), ReplicationSlotCreate(), and RestoreSlotFromDisk().
ReplicationSlotPersistentData ReplicationSlot::data |
Definition at line 156 of file slot.h.
Referenced by CheckPointReplicationSlots(), copy_replication_slot(), create_physical_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), CreateReplicationSlot(), CreateSlotOnDisk(), DecodeDelete(), DecodeInsert(), DecodeLogicalMsgOp(), DecodeMultiInsert(), DecodeSpecConfirm(), DecodeTruncate(), DecodeTXNNeedSkip(), DecodeUpdate(), DecodingContextFindStartpoint(), InvalidateObsoleteReplicationSlots(), LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), LogicalIncreaseXminForSlot(), output_plugin_error_callback(), pg_create_logical_replication_slot(), pg_create_physical_replication_slot(), pg_get_replication_slots(), pg_logical_replication_slot_advance(), pg_logical_slot_get_changes_guts(), pg_physical_replication_slot_advance(), pg_replication_slot_advance(), PhysicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), ReorderBufferAllocate(), ReorderBufferFree(), ReorderBufferSerializedPath(), ReplicationSlotAcquireInternal(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotPersist(), ReplicationSlotRelease(), ReplicationSlotReserveWal(), ReplicationSlotSave(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), RestoreSlotFromDisk(), SaveSlotToPath(), SearchNamedReplicationSlot(), StartLogicalReplication(), StartupDecodingContext(), and UpdateDecodingStats().
bool ReplicationSlot::dirty |
Definition at line 139 of file slot.h.
Referenced by CreateSlotOnDisk(), ReplicationSlotCreate(), ReplicationSlotMarkDirty(), and SaveSlotToPath().
TransactionId ReplicationSlot::effective_catalog_xmin |
Definition at line 153 of file slot.h.
Referenced by copy_replication_slot(), CreateInitDecodingContext(), LogicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), ReplicationSlotCreate(), ReplicationSlotsComputeRequiredXmin(), and RestoreSlotFromDisk().
TransactionId ReplicationSlot::effective_xmin |
Definition at line 152 of file slot.h.
Referenced by copy_replication_slot(), CreateInitDecodingContext(), PhysicalReplicationSlotNewXmin(), ReplicationSlotCreate(), ReplicationSlotRelease(), ReplicationSlotsComputeRequiredXmin(), and RestoreSlotFromDisk().
bool ReplicationSlot::in_use |
Definition at line 132 of file slot.h.
Referenced by CheckPointReplicationSlots(), copy_replication_slot(), InvalidateObsoleteReplicationSlots(), pg_get_replication_slots(), ReplicationSlotAcquireInternal(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), RestoreSlotFromDisk(), and SearchNamedReplicationSlot().
LWLock ReplicationSlot::io_in_progress_lock |
Definition at line 159 of file slot.h.
Referenced by ReplicationSlotsShmemInit(), and SaveSlotToPath().
bool ReplicationSlot::just_dirtied |
Definition at line 138 of file slot.h.
Referenced by ReplicationSlotCreate(), ReplicationSlotMarkDirty(), and SaveSlotToPath().
slock_t ReplicationSlot::mutex |
Definition at line 129 of file slot.h.
Referenced by copy_replication_slot(), CreateInitDecodingContext(), DecodingContextFindStartpoint(), InvalidateObsoleteReplicationSlots(), LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), LogicalIncreaseXminForSlot(), pg_get_replication_slots(), pg_physical_replication_slot_advance(), PhysicalConfirmReceivedLocation(), PhysicalReplicationSlotNewXmin(), ReplicationSlotAcquireInternal(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotMarkDirty(), ReplicationSlotPersist(), ReplicationSlotRelease(), ReplicationSlotReserveWal(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), ReplicationSlotsShmemInit(), and SaveSlotToPath().