LogicalRepWorker Struct Reference

#include <worker_internal.h>

Data Fields
LogicalRepWorkerType	type
TimestampTz	launch_time
bool	in_use
uint16	generation
PGPROC *	proc
Oid	dbid
Oid	userid
Oid	subid
Oid	relid
char	relstate
XLogRecPtr	relstate_lsn
slock_t	relmutex
FileSet *	stream_fileset
pid_t	leader_pid
bool	parallel_apply
TransactionId	oldest_nonremovable_xid
XLogRecPtr	last_lsn
TimestampTz	last_send_time
TimestampTz	last_recv_time
XLogRecPtr	reply_lsn
TimestampTz	reply_time
TimestampTz	last_seqsync_start_time

Detailed Description

Definition at line 38 of file worker_internal.h.

Field Documentation

dbid

Oid LogicalRepWorker::dbid

Definition at line 56 of file worker_internal.h.

Referenced by InitializeLogRepWorker(), launch_sync_worker(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), and pa_launch_parallel_worker().

generation

uint16 LogicalRepWorker::generation

Definition at line 50 of file worker_internal.h.

Referenced by logicalrep_pa_worker_stop(), logicalrep_worker_launch(), logicalrep_worker_stop_internal(), ParallelApplyWorkerMain(), and WaitForReplicationWorkerAttach().

in_use

bool LogicalRepWorker::in_use

Definition at line 47 of file worker_internal.h.

Referenced by am_leader_apply_worker(), am_parallel_apply_worker(), logicalrep_worker_attach(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_worker_stop_internal(), logicalrep_workers_find(), and WaitForReplicationWorkerAttach().

last_lsn

XLogRecPtr LogicalRepWorker::last_lsn

Definition at line 105 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), pg_stat_get_subscription(), and UpdateWorkerStats().

last_recv_time

TimestampTz LogicalRepWorker::last_recv_time

Definition at line 107 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), ParallelApplyWorkerMain(), pg_stat_get_subscription(), SetupApplyOrSyncWorker(), and UpdateWorkerStats().

last_send_time

TimestampTz LogicalRepWorker::last_send_time

Definition at line 106 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), ParallelApplyWorkerMain(), pg_stat_get_subscription(), SetupApplyOrSyncWorker(), and UpdateWorkerStats().

last_seqsync_start_time

TimestampTz LogicalRepWorker::last_seqsync_start_time

Definition at line 111 of file worker_internal.h.

Referenced by logicalrep_reset_seqsync_start_time(), logicalrep_worker_launch(), and ProcessSequencesForSync().

launch_time

TimestampTz LogicalRepWorker::launch_time

Definition at line 44 of file worker_internal.h.

Referenced by logicalrep_worker_launch().

leader_pid

pid_t LogicalRepWorker::leader_pid

Definition at line 85 of file worker_internal.h.

Referenced by GetLeaderApplyWorkerPid(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), pa_shutdown(), ParallelApplyWorkerMain(), and pg_stat_get_subscription().

oldest_nonremovable_xid

TransactionId LogicalRepWorker::oldest_nonremovable_xid

Definition at line 102 of file worker_internal.h.

Referenced by compute_min_nonremovable_xid(), FindDeletedTupleInLocalRel(), get_candidate_xid(), InitializeLogRepWorker(), logicalrep_worker_launch(), stop_conflict_info_retention(), and wait_for_local_flush().

parallel_apply

bool LogicalRepWorker::parallel_apply

Definition at line 88 of file worker_internal.h.

Referenced by apply_handle_stream_abort(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), pa_can_start(), and set_stream_options().

proc

PGPROC* LogicalRepWorker::proc

Definition at line 53 of file worker_internal.h.

Referenced by GetLeaderApplyWorkerPid(), logicalrep_pa_worker_stop(), logicalrep_worker_attach(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_worker_stop_internal(), logicalrep_worker_wakeup_ptr(), logicalrep_workers_find(), pg_stat_get_subscription(), ProcessSyncingTablesForApply(), wait_for_worker_state_change(), and WaitForReplicationWorkerAttach().

relid

Oid LogicalRepWorker::relid

Definition at line 65 of file worker_internal.h.

Referenced by DropSubscription(), FinishSyncWorker(), InitializeLogRepWorker(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), LogicalRepSyncTableStart(), pg_stat_get_subscription(), ProcessSyncingTablesForSync(), run_tablesync_worker(), and should_apply_changes_for_rel().

relmutex

slock_t LogicalRepWorker::relmutex

Definition at line 68 of file worker_internal.h.

Referenced by ApplyLauncherShmemInit(), compute_min_nonremovable_xid(), FindDeletedTupleInLocalRel(), LogicalRepSyncTableStart(), ProcessSyncingTablesForApply(), ProcessSyncingTablesForSync(), stop_conflict_info_retention(), and wait_for_local_flush().

relstate

char LogicalRepWorker::relstate

Definition at line 66 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), LogicalRepSyncTableStart(), ProcessSyncingTablesForApply(), ProcessSyncingTablesForSync(), and wait_for_worker_state_change().

relstate_lsn

XLogRecPtr LogicalRepWorker::relstate_lsn

Definition at line 67 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), LogicalRepSyncTableStart(), ProcessSyncingTablesForApply(), and ProcessSyncingTablesForSync().

reply_lsn

XLogRecPtr LogicalRepWorker::reply_lsn

Definition at line 108 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), pg_stat_get_subscription(), and UpdateWorkerStats().

reply_time

TimestampTz LogicalRepWorker::reply_time

Definition at line 109 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), ParallelApplyWorkerMain(), pg_stat_get_subscription(), SetupApplyOrSyncWorker(), and UpdateWorkerStats().

stream_fileset

FileSet* LogicalRepWorker::stream_fileset

Definition at line 79 of file worker_internal.h.

Referenced by apply_handle_stream_commit(), apply_handle_stream_prepare(), logicalrep_worker_launch(), logicalrep_worker_onexit(), pa_set_fileset_state(), stream_abort_internal(), stream_cleanup_files(), stream_open_file(), stream_start_internal(), subxact_info_read(), and subxact_info_write().

subid

Oid LogicalRepWorker::subid

Definition at line 62 of file worker_internal.h.

Referenced by apply_handle_stream_commit(), apply_handle_stream_prepare(), apply_handle_stream_start(), apply_spooled_messages(), apply_worker_exit(), DisableSubscriptionAndExit(), DropSubscription(), ensure_last_message(), FindDeletedTupleInLocalRel(), FinishSyncWorker(), InitializeLogRepWorker(), logicalrep_pa_worker_count(), logicalrep_reset_seqsync_start_time(), logicalrep_sync_worker_count(), logicalrep_worker_cleanup(), logicalrep_worker_detach(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_workers_find(), LogicalRepSyncSequences(), LogicalRepSyncTableStart(), maybe_reread_subscription(), pa_free_worker_info(), pa_lock_stream(), pa_lock_transaction(), pa_unlock_stream(), pa_unlock_transaction(), pg_stat_get_subscription(), ProcessSequencesForSync(), ProcessSyncingTablesForApply(), ProcessSyncingTablesForSync(), stream_abort_internal(), stream_start_internal(), stream_stop_internal(), wait_for_table_state_change(), and wait_for_worker_state_change().

type

LogicalRepWorkerType LogicalRepWorker::type

Definition at line 41 of file worker_internal.h.

Referenced by am_leader_apply_worker(), DisableSubscriptionAndExit(), DropSubscription(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), pg_stat_get_subscription(), ProcessSyncingRelations(), should_apply_changes_for_rel(), and start_apply().

userid

Oid LogicalRepWorker::userid

Definition at line 59 of file worker_internal.h.

Referenced by InitializeLogRepWorker(), launch_sync_worker(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), and pa_launch_parallel_worker().

---

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

• src/include/replication/worker_internal.h