PostgreSQL Source Code
git master
|
#include "postgres.h"
#include "access/parallel.h"
#include "libpq/pqformat.h"
#include "port/atomics.h"
#include "utils/backend_progress.h"
#include "utils/backend_status.h"
Go to the source code of this file.
Functions | |
void | pgstat_progress_start_command (ProgressCommandType cmdtype, Oid relid) |
void | pgstat_progress_update_param (int index, int64 val) |
void | pgstat_progress_incr_param (int index, int64 incr) |
void | pgstat_progress_parallel_incr_param (int index, int64 incr) |
void | pgstat_progress_update_multi_param (int nparam, const int *index, const int64 *val) |
void | pgstat_progress_end_command (void) |
void pgstat_progress_end_command | ( | void | ) |
Definition at line 151 of file backend_progress.c.
References InvalidOid, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, PROGRESS_COMMAND_INVALID, PgBackendStatus::st_progress_command, and PgBackendStatus::st_progress_command_target.
Referenced by AbortSubTransaction(), AbortTransaction(), analyze_rel(), basebackup_progress_done(), cluster_rel(), DefineIndex(), EndCopy(), EndCopyFrom(), heap_vacuum_rel(), reindex_index(), and ReindexRelationConcurrently().
void pgstat_progress_incr_param | ( | int | index, |
int64 | incr | ||
) |
Definition at line 70 of file backend_progress.c.
References Assert, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, and PgBackendStatus::st_progress_param.
Referenced by DefineIndex(), HandleParallelMessage(), and pgstat_progress_parallel_incr_param().
void pgstat_progress_parallel_incr_param | ( | int | index, |
int64 | incr | ||
) |
Definition at line 92 of file backend_progress.c.
References initStringInfo(), IsParallelWorker, pgstat_progress_incr_param(), pq_beginmessage(), pq_endmessage(), pq_sendint32(), pq_sendint64(), and PqMsg_Progress.
Referenced by parallel_vacuum_process_one_index().
void pgstat_progress_start_command | ( | ProgressCommandType | cmdtype, |
Oid | relid | ||
) |
Definition at line 28 of file backend_progress.c.
References MemSet, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, PgBackendStatus::st_progress_command, PgBackendStatus::st_progress_command_target, and PgBackendStatus::st_progress_param.
Referenced by analyze_rel(), bbsink_progress_new(), BeginCopyFrom(), BeginCopyTo(), cluster_rel(), DefineIndex(), heap_vacuum_rel(), reindex_index(), and ReindexRelationConcurrently().
void pgstat_progress_update_multi_param | ( | int | nparam, |
const int * | index, | ||
const int64 * | val | ||
) |
Definition at line 122 of file backend_progress.c.
References Assert, i, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, PgBackendStatus::st_progress_param, and val.
Referenced by _bt_spools_heapscan(), acquire_inherited_sample_rows(), basebackup_progress_wait_wal_archive(), bbsink_progress_archive_contents(), bbsink_progress_begin_backup(), BeginCopyFrom(), BeginCopyTo(), BuildRelationExtStatistics(), dead_items_add(), DefineIndex(), heapam_relation_copy_for_cluster(), index_build(), lazy_check_wraparound_failsafe(), lazy_cleanup_all_indexes(), lazy_scan_heap(), lazy_vacuum_all_indexes(), reindex_index(), ReindexRelationConcurrently(), validate_index(), and WaitForLockersMultiple().
void pgstat_progress_update_param | ( | int | index, |
int64 | val | ||
) |
Definition at line 49 of file backend_progress.c.
References Assert, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, PgBackendStatus::st_progress_param, and val.
Referenced by _bt_leafbuild(), _bt_load(), _bt_parallel_scan_and_sort(), _bt_spools_heapscan(), _h_indexbuild(), acquire_inherited_sample_rows(), acquire_sample_rows(), basebackup_progress_estimate_backup_size(), basebackup_progress_transfer_wal(), basebackup_progress_wait_checkpoint(), bbsink_progress_end_archive(), bbsink_progress_new(), btvacuumscan(), BuildRelationExtStatistics(), cluster_rel(), copy_dest_receive(), CopyFrom(), CopyLoadRawBuf(), CopyMultiInsertBufferFlush(), CopySendEndOfRow(), DefineIndex(), do_analyze_rel(), DoCopyTo(), finish_heap_swap(), hashbuild(), heap_vacuum_rel(), heapam_index_build_range_scan(), heapam_index_validate_scan(), heapam_relation_copy_for_cluster(), lazy_cleanup_all_indexes(), lazy_scan_heap(), lazy_truncate_heap(), lazy_vacuum_all_indexes(), lazy_vacuum_heap_page(), lazy_vacuum_heap_rel(), reindex_index(), reindex_relation(), ReindexRelationConcurrently(), validate_index(), WaitForLockersMultiple(), and WaitForOlderSnapshots().