PostgreSQL Source Code
git master
|
#include <worker_internal.h>
Definition at line 25 of file worker_internal.h.
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().
uint16 LogicalRepWorker::generation |
Definition at line 34 of file worker_internal.h.
Referenced by logicalrep_worker_launch(), logicalrep_worker_stop(), and WaitForReplicationWorkerAttach().
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().
XLogRecPtr LogicalRepWorker::last_lsn |
Definition at line 64 of file worker_internal.h.
Referenced by logicalrep_worker_launch(), pg_stat_get_subscription(), and UpdateWorkerStats().
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().
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().
TimestampTz LogicalRepWorker::launch_time |
Definition at line 28 of file worker_internal.h.
Referenced by logicalrep_worker_launch().
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().
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().
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().
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().
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().
XLogRecPtr LogicalRepWorker::reply_lsn |
Definition at line 67 of file worker_internal.h.
Referenced by logicalrep_worker_launch(), pg_stat_get_subscription(), and UpdateWorkerStats().
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().
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().
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().
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().