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
XLogRecPtr	last_lsn
TimestampTz	last_send_time
TimestampTz	last_recv_time
XLogRecPtr	reply_lsn
TimestampTz	reply_time

Detailed Description

Definition at line 37 of file worker_internal.h.

Field Documentation

dbid

Oid LogicalRepWorker::dbid

Definition at line 55 of file worker_internal.h.

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

generation

uint16 LogicalRepWorker::generation

Definition at line 49 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 46 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 90 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 92 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 91 of file worker_internal.h.

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

launch_time

TimestampTz LogicalRepWorker::launch_time

Definition at line 43 of file worker_internal.h.

Referenced by logicalrep_worker_launch().

leader_pid

pid_t LogicalRepWorker::leader_pid

Definition at line 84 of file worker_internal.h.

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

parallel_apply

bool LogicalRepWorker::parallel_apply

Definition at line 87 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 52 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(), process_syncing_tables_for_apply(), wait_for_worker_state_change(), and WaitForReplicationWorkerAttach().

relid

Oid LogicalRepWorker::relid

Definition at line 64 of file worker_internal.h.

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

relmutex

slock_t LogicalRepWorker::relmutex

Definition at line 67 of file worker_internal.h.

Referenced by ApplyLauncherShmemInit(), LogicalRepSyncTableStart(), process_syncing_tables_for_apply(), and process_syncing_tables_for_sync().

relstate

char LogicalRepWorker::relstate

Definition at line 65 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), LogicalRepSyncTableStart(), process_syncing_tables_for_apply(), process_syncing_tables_for_sync(), and wait_for_worker_state_change().

relstate_lsn

XLogRecPtr LogicalRepWorker::relstate_lsn

Definition at line 66 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), LogicalRepSyncTableStart(), process_syncing_tables_for_apply(), and process_syncing_tables_for_sync().

reply_lsn

XLogRecPtr LogicalRepWorker::reply_lsn

Definition at line 93 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 94 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 78 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 61 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(), finish_sync_worker(), InitializeLogRepWorker(), logicalrep_pa_worker_count(), logicalrep_sync_worker_count(), logicalrep_worker_cleanup(), logicalrep_worker_detach(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_workers_find(), LogicalRepSyncTableStart(), maybe_reread_subscription(), pa_free_worker_info(), pa_lock_stream(), pa_lock_transaction(), pa_unlock_stream(), pa_unlock_transaction(), pg_stat_get_subscription(), process_syncing_tables_for_apply(), process_syncing_tables_for_sync(), stream_abort_internal(), stream_start_internal(), stream_stop_internal(), wait_for_relation_state_change(), and wait_for_worker_state_change().

type

LogicalRepWorkerType LogicalRepWorker::type

Definition at line 40 of file worker_internal.h.

Referenced by am_leader_apply_worker(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), pg_stat_get_subscription(), process_syncing_tables(), and should_apply_changes_for_rel().

userid

Oid LogicalRepWorker::userid

Definition at line 58 of file worker_internal.h.

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

---

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

• src/include/replication/worker_internal.h