if (metad->btm_fastroot != metad->btm_root)
ereport(DEBUG1,
(errcode(ERRCODE_NO_DATA),
- errmsg("harmless fast root mismatch in index %s",
+ errmsg_internal("harmless fast root mismatch in index %s",
RelationGetRelationName(rel)),
errdetail_internal("Fast root block %u (level %u) differs from true root block %u (level %u).",
metad->btm_fastroot, metad->btm_fastlevel,
else
ereport(DEBUG1,
(errcode(ERRCODE_NO_DATA),
- errmsg("block %u of index \"%s\" ignored",
+ errmsg_internal("block %u of index \"%s\" ignored",
current, RelationGetRelationName(state->rel))));
goto nextpage;
}
/* Report split in left sibling, not target (or new target) */
ereport(DEBUG1,
(errcode(ERRCODE_INTERNAL_ERROR),
- errmsg("harmless concurrent page split detected in index \"%s\"",
+ errmsg_internal("harmless concurrent page split detected in index \"%s\"",
RelationGetRelationName(state->rel)),
errdetail_internal("Block=%u new right sibling=%u original right sibling=%u.",
leftcurrent, newtargetblock,
targetnext = opaque->btpo_next;
ereport(DEBUG1,
(errcode(ERRCODE_NO_DATA),
- errmsg("level %u leftmost page of index \"%s\" was found deleted or half dead",
+ errmsg_internal("level %u leftmost page of index \"%s\" was found deleted or half dead",
opaque->btpo.level, RelationGetRelationName(state->rel)),
errdetail_internal("Deleted page found when building scankey from right sibling.")));
*/
ereport(DEBUG1,
(errcode(ERRCODE_NO_DATA),
- errmsg("%s block %u of index \"%s\" has no first data item",
+ errmsg_internal("%s block %u of index \"%s\" has no first data item",
P_ISLEAF(opaque) ? "leaf" : "internal", targetnext,
RelationGetRelationName(state->rel))));
return NULL;
{
ereport(DEBUG1,
(errcode(ERRCODE_NO_DATA),
- errmsg("harmless interrupted page split detected in index %s",
+ errmsg_internal("harmless interrupted page split detected in index %s",
RelationGetRelationName(state->rel)),
errdetail_internal("Block=%u level=%u left sibling=%u page lsn=%X/%X.",
blkno, opaque->btpo.level,
apw_state->pid_using_dumpfile = InvalidPid;
ereport(DEBUG1,
- (errmsg("wrote block details for %d blocks", num_blocks)));
+ (errmsg_internal("wrote block details for %d blocks", num_blocks)));
return num_blocks;
}
/* Log the info */
ereport(DEBUG1,
- (errmsg("MultiXactId wrap limit is %u, limited by database with OID %u",
+ (errmsg_internal("MultiXactId wrap limit is %u, limited by database with OID %u",
multiWrapLimit, oldest_datoid)));
/*
if (oldestOffsetKnown)
ereport(DEBUG1,
- (errmsg("oldest MultiXactId member is at offset %u",
+ (errmsg_internal("oldest MultiXactId member is at offset %u",
oldestOffset)));
else
ereport(LOG,
(errmsg("MultiXact member wraparound protections are now enabled")));
ereport(DEBUG1,
- (errmsg("MultiXact member stop limit is now %u based on MultiXact %u",
+ (errmsg_internal("MultiXact member stop limit is now %u based on MultiXact %u",
offsetStopLimit, oldestMultiXactId)));
}
else if (prevOldestOffsetKnown)
/* Unlink the file. */
SlruFileName(ctl, path, segno);
- ereport(DEBUG2, (errmsg("removing file \"%s\"", path)));
+ ereport(DEBUG2, (errmsg_internal("removing file \"%s\"", path)));
unlink(path);
}
/* Log the info */
ereport(DEBUG1,
- (errmsg("transaction ID wrap limit is %u, limited by database with OID %u",
+ (errmsg_internal("transaction ID wrap limit is %u, limited by database with OID %u",
xidWrapLimit, oldest_datoid)));
/*
minRecoveryPointTLI = newMinRecoveryPointTLI;
ereport(DEBUG2,
- (errmsg("updated min recovery point to %X/%X on timeline %u",
+ (errmsg_internal("updated min recovery point to %X/%X on timeline %u",
(uint32) (minRecoveryPoint >> 32),
(uint32) minRecoveryPoint,
newMinRecoveryPointTLI)));
true, recycleSegNo, true))
{
ereport(DEBUG2,
- (errmsg("recycled write-ahead log file \"%s\"",
+ (errmsg_internal("recycled write-ahead log file \"%s\"",
segname)));
CheckpointStats.ckpt_segs_recycled++;
/* Needn't recheck that slot on future iterations */
int rc;
ereport(DEBUG2,
- (errmsg("removing write-ahead log file \"%s\"",
+ (errmsg_internal("removing write-ahead log file \"%s\"",
segname)));
#ifdef WIN32
memcpy(&checkPoint, XLogRecGetData(xlogreader), sizeof(CheckPoint));
wasShutdown = ((record->xl_info & ~XLR_INFO_MASK) == XLOG_CHECKPOINT_SHUTDOWN);
ereport(DEBUG1,
- (errmsg("checkpoint record is at %X/%X",
+ (errmsg_internal("checkpoint record is at %X/%X",
(uint32) (checkPointLoc >> 32), (uint32) checkPointLoc)));
InRecovery = true; /* force recovery even if SHUTDOWNED */
if (record != NULL)
{
ereport(DEBUG1,
- (errmsg("checkpoint record is at %X/%X",
+ (errmsg_internal("checkpoint record is at %X/%X",
(uint32) (checkPointLoc >> 32), (uint32) checkPointLoc)));
}
else
int nxids;
ereport(DEBUG1,
- (errmsg("initializing for hot standby")));
+ (errmsg_internal("initializing for hot standby")));
InitRecoveryTransactionEnvironment();
WALInsertLockRelease();
END_CRIT_SECTION();
ereport(DEBUG1,
- (errmsg("checkpoint skipped because system is idle")));
+ (errmsg_internal("checkpoint skipped because system is idle")));
return;
}
}
if (!RecoveryInProgress())
{
ereport(DEBUG2,
- (errmsg("skipping restartpoint, recovery has already ended")));
+ (errmsg_internal("skipping restartpoint, recovery has already ended")));
return false;
}
lastCheckPoint.redo <= ControlFile->checkPointCopy.redo)
{
ereport(DEBUG2,
- (errmsg("skipping restartpoint, already performed at %X/%X",
+ (errmsg_internal("skipping restartpoint, already performed at %X/%X",
(uint32) (lastCheckPoint.redo >> 32),
(uint32) lastCheckPoint.redo)));
*/
if (fscanf(lfp, "START TIME: %127[^\n]\n", backuptime) == 1)
ereport(DEBUG1,
- (errmsg("backup time %s in file \"%s\"",
+ (errmsg_internal("backup time %s in file \"%s\"",
backuptime, BACKUP_LABEL_FILE)));
if (fscanf(lfp, "LABEL: %1023[^\n]\n", backuplabel) == 1)
ereport(DEBUG1,
- (errmsg("backup label %s in file \"%s\"",
+ (errmsg_internal("backup label %s in file \"%s\"",
backuplabel, BACKUP_LABEL_FILE)));
/*
tli_from_file, tli_from_walseg)));
ereport(DEBUG1,
- (errmsg("backup timeline %u in file \"%s\"",
+ (errmsg_internal("backup timeline %u in file \"%s\"",
tli_from_file, BACKUP_LABEL_FILE)));
}
* log_min_messages are different.
*/
ereport(DEBUG2,
- (errmsg("drop auto-cascades to %s",
+ (errmsg_internal("drop auto-cascades to %s",
objDesc)));
}
else if (behavior == DROP_RESTRICT)
if (indexInfo->ii_ParallelWorkers == 0)
ereport(DEBUG1,
- (errmsg("building index \"%s\" on table \"%s\" serially",
+ (errmsg_internal("building index \"%s\" on table \"%s\" serially",
RelationGetRelationName(indexRelation),
RelationGetRelationName(heapRelation))));
else
ereport(DEBUG1,
- (errmsg_plural("building index \"%s\" on table \"%s\" with request for %d parallel worker",
- "building index \"%s\" on table \"%s\" with request for %d parallel workers",
- indexInfo->ii_ParallelWorkers,
+ (errmsg_internal("building index \"%s\" on table \"%s\" with request for %d parallel workers",
RelationGetRelationName(indexRelation),
RelationGetRelationName(heapRelation),
indexInfo->ii_ParallelWorkers)));
}
ereport(DEBUG1,
- (errmsg("%s %s will create implicit index \"%s\" for table \"%s\"",
+ (errmsg_internal("%s %s will create implicit index \"%s\" for table \"%s\"",
is_alter_table ? "ALTER TABLE / ADD" : "CREATE TABLE /",
constraint_type,
indexRelationName, RelationGetRelationName(rel))));
copy_data ? SUBREL_STATE_INIT : SUBREL_STATE_READY,
InvalidXLogRecPtr);
ereport(DEBUG1,
- (errmsg("table \"%s.%s\" added to subscription \"%s\"",
+ (errmsg_internal("table \"%s.%s\" added to subscription \"%s\"",
rv->schemaname, rv->relname, sub->name)));
}
}
}
ereport(DEBUG1,
- (errmsg("table \"%s.%s\" removed from subscription \"%s\"",
+ (errmsg_internal("table \"%s.%s\" removed from subscription \"%s\"",
get_namespace_name(get_rel_namespace(relid)),
get_rel_name(relid),
sub->name)));
if (newrel)
ereport(DEBUG1,
- (errmsg("rewriting table \"%s\"",
+ (errmsg_internal("rewriting table \"%s\"",
RelationGetRelationName(oldrel))));
else
ereport(DEBUG1,
- (errmsg("verifying table \"%s\"",
+ (errmsg_internal("verifying table \"%s\"",
RelationGetRelationName(oldrel))));
if (newrel)
if (ConstraintImpliedByRelConstraint(rel, list_make1(nnulltest), NIL))
{
ereport(DEBUG1,
- (errmsg("existing constraints on column \"%s.%s\" are sufficient to prove that it does not contain nulls",
+ (errmsg_internal("existing constraints on column \"%s.%s\" are sufficient to prove that it does not contain nulls",
RelationGetRelationName(rel), NameStr(attr->attname))));
return true;
}
MemoryContext perTupCxt;
ereport(DEBUG1,
- (errmsg("validating foreign key constraint \"%s\"", conname)));
+ (errmsg_internal("validating foreign key constraint \"%s\"", conname)));
/*
* Build a trigger call structure; we'll need it either way.
{
if (!validate_default)
ereport(DEBUG1,
- (errmsg("partition constraint for table \"%s\" is implied by existing constraints",
+ (errmsg_internal("partition constraint for table \"%s\" is implied by existing constraints",
RelationGetRelationName(scanrel))));
else
ereport(DEBUG1,
- (errmsg("updated partition constraint for default partition \"%s\" is implied by existing constraints",
+ (errmsg_internal("updated partition constraint for default partition \"%s\" is implied by existing constraints",
RelationGetRelationName(scanrel))));
return;
}
MemoryContextSwitchTo(oldcontext);
ereport(DEBUG1,
- (errmsg("time to inline: %.3fs, opt: %.3fs, emit: %.3fs",
+ (errmsg_internal("time to inline: %.3fs, opt: %.3fs, emit: %.3fs",
INSTR_TIME_GET_DOUBLE(context->base.instr.inlining_counter),
INSTR_TIME_GET_DOUBLE(context->base.instr.optimization_counter),
INSTR_TIME_GET_DOUBLE(context->base.instr.emission_counter)),
r = be_tls_open_server(port);
ereport(DEBUG2,
- (errmsg("SSL connection from \"%s\"",
+ (errmsg_internal("SSL connection from \"%s\"",
port->peer_cn ? port->peer_cn : "(anonymous)")));
#endif
}
ereport(DEBUG1,
- (errmsg("%s will create implicit sequence \"%s\" for serial column \"%s.%s\"",
+ (errmsg_internal("%s will create implicit sequence \"%s\" for serial column \"%s.%s\"",
cxt->stmtType, sname,
cxt->relation->relname, column->colname)));
if (PartConstraintImpliedByRelConstraint(default_rel, def_part_constraints))
{
ereport(DEBUG1,
- (errmsg("updated partition constraint for default partition \"%s\" is implied by existing constraints",
+ (errmsg_internal("updated partition constraint for default partition \"%s\" is implied by existing constraints",
RelationGetRelationName(default_rel))));
return;
}
def_part_constraints))
{
ereport(DEBUG1,
- (errmsg("updated partition constraint for default partition \"%s\" is implied by existing constraints",
+ (errmsg_internal("updated partition constraint for default partition \"%s\" is implied by existing constraints",
RelationGetRelationName(part_rel))));
table_close(part_rel, NoLock);
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("the processor does not support large pages")));
ereport(DEBUG1,
- (errmsg("disabling huge pages")));
+ (errmsg_internal("disabling huge pages")));
}
else if (!EnableLockPagesPrivilege(huge_pages == HUGE_PAGES_ON ? FATAL : DEBUG1))
{
ereport(DEBUG1,
- (errmsg("disabling huge pages")));
+ (errmsg_internal("disabling huge pages")));
}
else
{
init_ps_display(NULL);
ereport(DEBUG1,
- (errmsg("autovacuum launcher started")));
+ (errmsg_internal("autovacuum launcher started")));
if (PostAuthDelay)
pg_usleep(PostAuthDelay * 1000000L);
AutoVacLauncherShutdown(void)
{
ereport(DEBUG1,
- (errmsg("autovacuum launcher shutting down")));
+ (errmsg_internal("autovacuum launcher shutting down")));
AutoVacuumShmem->av_launcherpid = 0;
proc_exit(0); /* done */
SetProcessingMode(NormalProcessing);
set_ps_display(dbname);
ereport(DEBUG1,
- (errmsg("autovacuum: processing database \"%s\"", dbname)));
+ (errmsg_internal("autovacuum: processing database \"%s\"", dbname)));
if (PostAuthDelay)
pg_usleep(PostAuthDelay * 1000000L);
/* Log it! */
ereport(DEBUG1,
- (errmsg("registering background worker \"%s\"",
+ (errmsg_internal("registering background worker \"%s\"",
rw->rw_worker.bgw_name)));
slist_push_head(&BackgroundWorkerList, &rw->rw_lnode);
slot->in_use = false;
ereport(DEBUG1,
- (errmsg("unregistering background worker \"%s\"",
+ (errmsg_internal("unregistering background worker \"%s\"",
rw->rw_worker.bgw_name)));
slist_delete_current(cur);
if (!IsUnderPostmaster)
ereport(DEBUG1,
- (errmsg("registering background worker \"%s\"", worker->bgw_name)));
+ (errmsg_internal("registering background worker \"%s\"", worker->bgw_name)));
if (!process_shared_preload_libraries_in_progress &&
strcmp(worker->bgw_library_name, "postgres") != 0)
CheckpointerShmem->requests[preserve_count++] = CheckpointerShmem->requests[n];
}
ereport(DEBUG1,
- (errmsg("compacted fsync request queue from %d entries to %d entries",
+ (errmsg_internal("compacted fsync request queue from %d entries to %d entries",
CheckpointerShmem->num_requests, preserve_count)));
CheckpointerShmem->num_requests = preserve_count;
}
ereport(DEBUG1,
- (errmsg("starting background worker process \"%s\"",
+ (errmsg_internal("starting background worker process \"%s\"",
rw->rw_worker.bgw_name)));
#ifdef EXEC_BACKEND
* it DEBUG1 to suppress in normal use.
*/
ereport(DEBUG1,
- (errmsg("logger shutting down")));
+ (errmsg_internal("logger shutting down")));
/*
* Normal exit from the syslogger is here. Note that we
TimestampTz now;
ereport(DEBUG1,
- (errmsg("starting logical replication worker for subscription \"%s\"",
+ (errmsg_internal("starting logical replication worker for subscription \"%s\"",
subname)));
/* Report this after the initial starting message for consistency. */
TimestampTz last_start_time = 0;
ereport(DEBUG1,
- (errmsg("logical replication launcher started")));
+ (errmsg_internal("logical replication launcher started")));
before_shmem_exit(logicalrep_launcher_onexit, (Datum) 0);
SpinLockRelease(&MyWalSnd->mutex);
ereport(DEBUG1,
- (errmsg("standby \"%s\" now has synchronous standby priority %u",
+ (errmsg_internal("standby \"%s\" now has synchronous standby priority %u",
application_name, priority)));
}
}
if (MyWalSnd->state == WALSNDSTATE_CATCHUP)
{
ereport(DEBUG1,
- (errmsg("\"%s\" has now caught up with upstream server",
+ (errmsg_internal("\"%s\" has now caught up with upstream server",
application_name)));
WalSndSetState(WALSNDSTATE_STREAMING);
}
/* else, need to retry... */
ereport(DEBUG2,
(errcode(ERRCODE_T_R_SERIALIZATION_FAILURE),
- errmsg("deferrable snapshot was unsafe; trying a new one")));
+ errmsg_internal("deferrable snapshot was unsafe; trying a new one")));
ReleasePredicateLocks(false, false);
}
initStringInfo(&logbuf);
DescribeLockTag(&locktagbuf, &locktag_copy);
appendStringInfo(&logbuf,
- _("Process %d waits for %s on %s."),
+ "Process %d waits for %s on %s.",
MyProcPid,
GetLockmodeName(lockmethod_copy, lockmode),
locktagbuf.data);
ereport(DEBUG1,
- (errmsg("sending cancel to blocking autovacuum PID %d",
+ (errmsg_internal("sending cancel to blocking autovacuum PID %d",
pid),
errdetail_log("%s", logbuf.data)));
if (!RegisterSyncRequest(&tag, SYNC_REQUEST, false /* retryOnError */ ))
{
ereport(DEBUG1,
- (errmsg("could not forward fsync request because request queue is full")));
+ (errmsg_internal("could not forward fsync request because request queue is full")));
if (FileSync(seg->mdfd_vfd, WAIT_EVENT_DATA_FILE_SYNC) < 0)
ereport(data_sync_elevel(ERROR),
else
ereport(DEBUG1,
(errcode_for_file_access(),
- errmsg("could not fsync file \"%s\" but retrying: %m",
+ errmsg_internal("could not fsync file \"%s\" but retrying: %m",
path)));
/*
whereToSendOutput = DestNone;
ereport(DEBUG1,
(errcode(ERRCODE_CONNECTION_DOES_NOT_EXIST),
- errmsg("unexpected EOF on client connection")));
+ errmsg_internal("unexpected EOF on client connection")));
}
return qtype;
}
whereToSendOutput = DestNone;
ereport(DEBUG1,
(errcode(ERRCODE_CONNECTION_DOES_NOT_EXIST),
- errmsg("unexpected EOF on client connection")));
+ errmsg_internal("unexpected EOF on client connection")));
}
return EOF;
}
whereToSendOutput = DestNone;
ereport(DEBUG1,
(errcode(ERRCODE_CONNECTION_DOES_NOT_EXIST),
- errmsg("unexpected EOF on client connection")));
+ errmsg_internal("unexpected EOF on client connection")));
}
return EOF;
}
ResetUsage();
ereport(DEBUG2,
- (errmsg("parse %s: %s",
+ (errmsg_internal("parse %s: %s",
*stmt_name ? stmt_name : "<unnamed>",
query_string)));
stmt_name = pq_getmsgstring(input_message);
ereport(DEBUG2,
- (errmsg("bind %s to %s",
+ (errmsg_internal("bind %s to %s",
*portal_name ? portal_name : "<unnamed>",
*stmt_name ? stmt_name : "<unnamed>")));
else if (IsLogicalLauncher())
{
ereport(DEBUG1,
- (errmsg("logical replication launcher shutting down")));
+ (errmsg_internal("logical replication launcher shutting down")));
/*
* The logical replication launcher can be stopped at any time.
}
load_file(filename, restricted);
ereport(DEBUG1,
- (errmsg("loaded library \"%s\"", filename)));
+ (errmsg_internal("loaded library \"%s\"", filename)));
if (expanded)
pfree(expanded);
}