PostgreSQL Source Code: LogicalRepWorker Struct Reference (original) (raw)

#include <[worker_internal.h](worker%5F%5Finternal%5F8h%5Fsource.html)>

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

Definition at line 37 of file worker_internal.h.

◆ dbid

Oid LogicalRepWorker::dbid

◆ generation

uint16 LogicalRepWorker::generation

◆ in_use

bool LogicalRepWorker::in_use

◆ last_lsn

◆ last_recv_time

◆ last_send_time

◆ launch_time

◆ leader_pid

pid_t LogicalRepWorker::leader_pid

◆ parallel_apply

bool LogicalRepWorker::parallel_apply

◆ 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

◆ relstate

char LogicalRepWorker::relstate

◆ relstate_lsn

◆ reply_lsn

◆ reply_time

◆ 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

◆ userid

Oid LogicalRepWorker::userid

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