ParallelApplyWorkerInfo Struct Reference

#include <worker_internal.h>

Data Fields
shm_mq_handle *	mq_handle
shm_mq_handle *	error_mq_handle
dsm_segment *	dsm_seg
bool	serialize_changes
bool	in_use
ParallelApplyWorkerShared *	shared

Detailed Description

Definition at line 188 of file worker_internal.h.

Field Documentation

dsm_seg

dsm_segment* ParallelApplyWorkerInfo::dsm_seg

Definition at line 202 of file worker_internal.h.

Referenced by pa_free_worker_info(), pa_launch_parallel_worker(), and pa_setup_dsm().

error_mq_handle

shm_mq_handle* ParallelApplyWorkerInfo::error_mq_handle

Definition at line 200 of file worker_internal.h.

Referenced by HandleParallelApplyMessages(), logicalrep_pa_worker_stop(), pa_detach_all_error_mq(), pa_free_worker_info(), and pa_setup_dsm().

in_use

bool ParallelApplyWorkerInfo::in_use

Definition at line 215 of file worker_internal.h.

Referenced by pa_allocate_worker(), pa_find_worker(), pa_free_worker(), and pa_launch_parallel_worker().

mq_handle

shm_mq_handle* ParallelApplyWorkerInfo::mq_handle

Definition at line 194 of file worker_internal.h.

Referenced by pa_free_worker_info(), pa_send_data(), and pa_setup_dsm().

serialize_changes

bool ParallelApplyWorkerInfo::serialize_changes

Definition at line 209 of file worker_internal.h.

Referenced by get_transaction_apply_action(), pa_allocate_worker(), pa_free_worker(), pa_free_worker_info(), pa_send_data(), and pa_switch_to_partial_serialize().

shared

ParallelApplyWorkerShared* ParallelApplyWorkerInfo::shared

Definition at line 217 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(), logicalrep_pa_worker_stop(), pa_allocate_worker(), pa_free_worker(), pa_free_worker_info(), pa_setup_dsm(), pa_switch_to_partial_serialize(), pa_wait_for_xact_finish(), pa_wait_for_xact_state(), and pa_xact_finish().

---

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

• src/include/replication/worker_internal.h