#include <worker_internal.h>

Data Fields
slock_t	mutex

TransactionId	xid

ParallelTransState	xact_state

uint16	logicalrep_worker_generation

int	logicalrep_worker_slot_no

pg_atomic_uint32	pending_stream_count

XLogRecPtr	last_commit_end

PartialFileSetState	fileset_state

FileSet	fileset

Detailed Description

Definition at line 138 of file worker_internal.h.

Field Documentation

◆ fileset

FileSet ParallelApplyWorkerShared::fileset

Definition at line 182 of file worker_internal.h.

Referenced by pa_process_spooled_messages_if_required(), and pa_set_fileset_state().

◆ fileset_state

PartialFileSetState ParallelApplyWorkerShared::fileset_state

Definition at line 181 of file worker_internal.h.

Referenced by pa_get_fileset_state(), pa_set_fileset_state(), and pa_setup_dsm().

◆ last_commit_end

XLogRecPtr ParallelApplyWorkerShared::last_commit_end

Definition at line 169 of file worker_internal.h.

Referenced by apply_handle_stream_commit(), apply_handle_stream_prepare(), pa_setup_dsm(), and pa_xact_finish().

◆ logicalrep_worker_generation

uint16 ParallelApplyWorkerShared::logicalrep_worker_generation

Definition at line 156 of file worker_internal.h.

Referenced by logicalrep_pa_worker_stop(), and ParallelApplyWorkerMain().

◆ logicalrep_worker_slot_no

int ParallelApplyWorkerShared::logicalrep_worker_slot_no

Definition at line 157 of file worker_internal.h.

Referenced by logicalrep_pa_worker_stop(), and ParallelApplyWorkerMain().

◆ mutex

slock_t ParallelApplyWorkerShared::mutex

Definition at line 140 of file worker_internal.h.

Referenced by logicalrep_pa_worker_stop(), pa_allocate_worker(), pa_get_fileset_state(), pa_get_xact_state(), pa_set_fileset_state(), pa_set_xact_state(), pa_setup_dsm(), and ParallelApplyWorkerMain().

◆ pending_stream_count

pg_atomic_uint32 ParallelApplyWorkerShared::pending_stream_count

Definition at line 163 of file worker_internal.h.

Referenced by apply_handle_stream_abort(), apply_handle_stream_start(), pa_decr_and_wait_stream_block(), and pa_setup_dsm().

◆ xact_state

ParallelTransState ParallelApplyWorkerShared::xact_state

Definition at line 153 of file worker_internal.h.

Referenced by pa_allocate_worker(), pa_get_xact_state(), pa_set_xact_state(), and pa_setup_dsm().

◆ xid

TransactionId ParallelApplyWorkerShared::xid

Definition at line 142 of file worker_internal.h.

Referenced by apply_handle_stream_prepare(), apply_handle_stream_start(), apply_handle_stream_stop(), pa_allocate_worker(), pa_decr_and_wait_stream_block(), pa_free_worker(), pa_free_worker_info(), pa_process_spooled_messages_if_required(), pa_switch_to_partial_serialize(), pa_wait_for_xact_finish(), and pa_xact_finish().

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

src/include/replication/worker_internal.h

Data Fields