/*
* Report ANALYZE to the stats collector, too. However, if doing
* inherited stats we shouldn't report, because the stats collector only
- * tracks per-table stats.
+ * tracks per-table stats. Reset the changes_since_analyze counter only
+ * if we analyzed all columns; otherwise, there is still work for
+ * auto-analyze to do.
*/
if (!inh)
- pgstat_report_analyze(onerel, totalrows, totaldeadrows);
+ pgstat_report_analyze(onerel, totalrows, totaldeadrows,
+ (vacstmt->va_cols == NIL));
/* If this isn't part of VACUUM ANALYZE, let index AMs do cleanup */
if (!(vacstmt->options & VACOPT_VACUUM))
* pgstat_report_analyze() -
*
* Tell the collector about the table we just analyzed.
+ *
+ * Caller must provide new live- and dead-tuples estimates, as well as a
+ * flag indicating whether to reset the changes_since_analyze counter.
* --------
*/
void
pgstat_report_analyze(Relation rel,
- PgStat_Counter livetuples, PgStat_Counter deadtuples)
+ PgStat_Counter livetuples, PgStat_Counter deadtuples,
+ bool resetcounter)
{
PgStat_MsgAnalyze msg;
msg.m_databaseid = rel->rd_rel->relisshared ? InvalidOid : MyDatabaseId;
msg.m_tableoid = RelationGetRelid(rel);
msg.m_autovacuum = IsAutoVacuumWorkerProcess();
+ msg.m_resetcounter = resetcounter;
msg.m_analyzetime = GetCurrentTimestamp();
msg.m_live_tuples = livetuples;
msg.m_dead_tuples = deadtuples;
tabentry->n_dead_tuples = msg->m_dead_tuples;
/*
- * We reset changes_since_analyze to zero, forgetting any changes that
- * occurred while the ANALYZE was in progress.
+ * If commanded, reset changes_since_analyze to zero. This forgets any
+ * changes that were committed while the ANALYZE was in progress, but we
+ * have no good way to estimate how many of those there were.
*/
- tabentry->changes_since_analyze = 0;
+ if (msg->m_resetcounter)
+ tabentry->changes_since_analyze = 0;
if (msg->m_autovacuum)
{
Oid m_databaseid;
Oid m_tableoid;
bool m_autovacuum;
+ bool m_resetcounter;
TimestampTz m_analyzetime;
PgStat_Counter m_live_tuples;
PgStat_Counter m_dead_tuples;
extern void pgstat_report_vacuum(Oid tableoid, bool shared,
PgStat_Counter tuples);
extern void pgstat_report_analyze(Relation rel,
- PgStat_Counter livetuples, PgStat_Counter deadtuples);
+ PgStat_Counter livetuples, PgStat_Counter deadtuples,
+ bool resetcounter);
extern void pgstat_report_recovery_conflict(int reason);
extern void pgstat_report_deadlock(void);