LogicalRepWorker Struct Reference

#include <worker_internal.h>

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

Detailed Description

Definition at line 25 of file worker_internal.h.

Field Documentation

dbid

Oid LogicalRepWorker::dbid

Definition at line 40 of file worker_internal.h.

Referenced by ApplyWorkerMain(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), and process_syncing_tables_for_apply().

generation

uint16 LogicalRepWorker::generation

Definition at line 34 of file worker_internal.h.

Referenced by logicalrep_worker_launch(), logicalrep_worker_stop(), and WaitForReplicationWorkerAttach().

in_use

bool LogicalRepWorker::in_use

Definition at line 31 of file worker_internal.h.

Referenced by logicalrep_worker_attach(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_worker_stop(), logicalrep_workers_find(), and WaitForReplicationWorkerAttach().

last_lsn

XLogRecPtr LogicalRepWorker::last_lsn

Definition at line 64 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 66 of file worker_internal.h.

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

last_send_time

TimestampTz LogicalRepWorker::last_send_time

Definition at line 65 of file worker_internal.h.

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

launch_time

TimestampTz LogicalRepWorker::launch_time

Definition at line 28 of file worker_internal.h.

Referenced by logicalrep_worker_launch().

proc

PGPROC* LogicalRepWorker::proc

Definition at line 37 of file worker_internal.h.

Referenced by logicalrep_worker_attach(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_worker_stop(), 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 49 of file worker_internal.h.

Referenced by am_tablesync_worker(), ApplyWorkerMain(), DropSubscription(), logicalrep_sync_worker_count(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), LogicalRepSyncTableStart(), pg_attribute_noreturn(), pg_stat_get_subscription(), process_syncing_tables_for_sync(), and should_apply_changes_for_rel().

relmutex

slock_t LogicalRepWorker::relmutex

Definition at line 52 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 50 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 51 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 67 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 68 of file worker_internal.h.

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

stream_fileset

FileSet* LogicalRepWorker::stream_fileset

Definition at line 61 of file worker_internal.h.

Referenced by apply_handle_stream_abort(), apply_handle_stream_start(), apply_spooled_messages(), logicalrep_worker_launch(), logicalrep_worker_onexit(), stream_cleanup_files(), stream_open_file(), subxact_info_read(), and subxact_info_write().

subid

Oid LogicalRepWorker::subid

Definition at line 46 of file worker_internal.h.

Referenced by apply_handle_stream_abort(), apply_handle_stream_commit(), apply_handle_stream_prepare(), apply_handle_stream_start(), apply_handle_stream_stop(), apply_spooled_messages(), ApplyWorkerMain(), DisableSubscriptionAndExit(), DropSubscription(), logicalrep_sync_worker_count(), logicalrep_worker_cleanup(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_workers_find(), LogicalRepSyncTableStart(), maybe_reread_subscription(), pg_attribute_noreturn(), pg_stat_get_subscription(), process_syncing_tables_for_apply(), process_syncing_tables_for_sync(), wait_for_relation_state_change(), and wait_for_worker_state_change().

userid

Oid LogicalRepWorker::userid

Definition at line 43 of file worker_internal.h.

Referenced by ApplyWorkerMain(), logicalrep_worker_cleanup(), logicalrep_worker_launch(), and process_syncing_tables_for_apply().

---

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

• src/include/replication/worker_internal.h