PostgreSQL Source Code git master
|
#include <worker_internal.h>
Definition at line 138 of file worker_internal.h.
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().
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().
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().
uint16 ParallelApplyWorkerShared::logicalrep_worker_generation |
Definition at line 156 of file worker_internal.h.
Referenced by logicalrep_pa_worker_stop(), and ParallelApplyWorkerMain().
int ParallelApplyWorkerShared::logicalrep_worker_slot_no |
Definition at line 157 of file worker_internal.h.
Referenced by logicalrep_pa_worker_stop(), and ParallelApplyWorkerMain().
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().
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().
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().
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().