backend_progress.c File Reference

#include "postgres.h"
#include "access/parallel.h"
#include "libpq/pqformat.h"
#include "utils/backend_progress.h"
#include "utils/backend_status.h"

Include dependency graph for backend_progress.c:

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)

Function Documentation

pgstat_progress_end_command()

void pgstat_progress_end_command

(

void

)

Definition at line 150 of file backend_progress.c.

{
    volatile PgBackendStatus *beentry = MyBEEntry;
 
    if (!beentry || !pgstat_track_activities)
        return;
 
    if (beentry->st_progress_command == PROGRESS_COMMAND_INVALID)
        return;
 
    PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
    beentry->st_progress_command = PROGRESS_COMMAND_INVALID;
    beentry->st_progress_command_target = InvalidOid;
    PGSTAT_END_WRITE_ACTIVITY(beentry);
}

References fb(), InvalidOid, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, and PROGRESS_COMMAND_INVALID.

Referenced by AbortSubTransaction(), AbortTransaction(), analyze_rel(), basebackup_progress_done(), cluster_rel(), DefineIndex(), EndCopy(), EndCopyFrom(), heap_vacuum_rel(), reindex_index(), and ReindexRelationConcurrently().

pgstat_progress_incr_param()

void pgstat_progress_incr_param	(	int	index,
		int64	incr
	)

Definition at line 69 of file backend_progress.c.

{
    volatile PgBackendStatus *beentry = MyBEEntry;
 
    Assert(index >= 0 && index < PGSTAT_NUM_PROGRESS_PARAM);
 
    if (!beentry || !pgstat_track_activities)
        return;
 
    PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
    beentry->st_progress_param[index] += incr;
    PGSTAT_END_WRITE_ACTIVITY(beentry);
}

References Assert, fb(), MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, and pgstat_track_activities.

Referenced by DefineIndex(), pgstat_progress_parallel_incr_param(), ProcessParallelMessage(), and vacuum_delay_point().

pgstat_progress_parallel_incr_param()

void pgstat_progress_parallel_incr_param	(	int	index,
		int64	incr
	)

Definition at line 91 of file backend_progress.c.

{
    /*
     * Parallel workers notify a leader through a PqMsg_Progress message to
     * update progress, passing the progress index and incremented value.
     * Leaders can just call pgstat_progress_incr_param directly.
     */
    if (IsParallelWorker())
    {
        static StringInfoData progress_message;
 
        initStringInfo(&progress_message);
 
        pq_beginmessage(&progress_message, PqMsg_Progress);
        pq_sendint32(&progress_message, index);
        pq_sendint64(&progress_message, incr);
        pq_endmessage(&progress_message);
    }
    else
        pgstat_progress_incr_param(index, incr);
}

References fb(), initStringInfo(), IsParallelWorker, pgstat_progress_incr_param(), pq_beginmessage(), pq_endmessage(), pq_sendint32(), pq_sendint64(), and PqMsg_Progress.

Referenced by parallel_vacuum_main(), parallel_vacuum_process_one_index(), and vacuum_delay_point().

pgstat_progress_start_command()

void pgstat_progress_start_command	(	ProgressCommandType	cmdtype,
		Oid	relid
	)

Definition at line 27 of file backend_progress.c.

{
    volatile PgBackendStatus *beentry = MyBEEntry;
 
    if (!beentry || !pgstat_track_activities)
        return;
 
    PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
    beentry->st_progress_command = cmdtype;
    beentry->st_progress_command_target = relid;
    MemSet(&beentry->st_progress_param, 0, sizeof(beentry->st_progress_param));
    PGSTAT_END_WRITE_ACTIVITY(beentry);
}

References fb(), MemSet, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, and pgstat_track_activities.

Referenced by analyze_rel(), bbsink_progress_new(), BeginCopyFrom(), BeginCopyTo(), cluster_rel(), DefineIndex(), heap_vacuum_rel(), reindex_index(), and ReindexRelationConcurrently().

pgstat_progress_update_multi_param()

void pgstat_progress_update_multi_param	(	int	nparam,
		const int *	index,
		const int64 *	val
	)

Definition at line 121 of file backend_progress.c.

{
    volatile PgBackendStatus *beentry = MyBEEntry;
    int         i;
 
    if (!beentry || !pgstat_track_activities || nparam == 0)
        return;
 
    PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
 
    for (i = 0; i < nparam; ++i)
    {
        Assert(index[i] >= 0 && index[i] < PGSTAT_NUM_PROGRESS_PARAM);
 
        beentry->st_progress_param[index[i]] = val[i];
    }
 
    PGSTAT_END_WRITE_ACTIVITY(beentry);
}

References Assert, fb(), i, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, and val.

Referenced by _bt_spools_heapscan(), _gin_parallel_merge(), 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().

pgstat_progress_update_param()

void pgstat_progress_update_param	(	int	index,
		int64	val
	)

Definition at line 48 of file backend_progress.c.

{
    volatile PgBackendStatus *beentry = MyBEEntry;
 
    Assert(index >= 0 && index < PGSTAT_NUM_PROGRESS_PARAM);
 
    if (!beentry || !pgstat_track_activities)
        return;
 
    PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
    beentry->st_progress_param[index] = val;
    PGSTAT_END_WRITE_ACTIVITY(beentry);
}

References Assert, fb(), MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, and val.

Referenced by _bt_leafbuild(), _bt_load(), _bt_parallel_scan_and_sort(), _bt_spools_heapscan(), _gin_parallel_merge(), _gin_process_worker_data(), _h_indexbuild(), acquire_inherited_sample_rows(), acquire_sample_rows(), analyze_rel(), 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(), CopyRelationTo(), CopySendEndOfRow(), DefineIndex(), do_analyze_rel(), finish_heap_swap(), ginbuild(), 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().