|
%a
- Application name i n local server
+ Application name o n local server
|
%u
- User name i n local server
+ User name o n local server
|
%d
- Database name i n local server
+ Database name o n local server
|
%p
- Process ID of backend i n local server
+ Process ID of backend o n local server
|
%%
- Read some information associated to a replication slot. Returns a tuple
+ Read some information associated with a replication slot. Returns a tuple
with NULL values if the replication slot does not
exist. This command is currently only supported for physical replication
slots.
restart_tli (int8 )
- The timeline ID associated to restart_lsn ,
+ The timeline ID associated with restart_lsn ,
following the current timeline history.
streaming starts on timeline tli;
otherwise, the server's current timeline is selected. The server can
reply with an error, for example if the requested section of WAL has already
- been recycled. On success, server responds with a CopyBothResponse
+ been recycled. On success, the server responds with a CopyBothResponse
message, and then starts to stream WAL to the frontend.
The server can reply with an error, for example if the
- slot does not exist. On success, server responds with a CopyBothResponse
+ slot does not exist. On success, the server responds with a CopyBothResponse
message, and then starts to stream WAL to the frontend.
This section describes the detailed format of each logical replication
message. These messages are either returned by the replication slot SQL
-interface or are sent by a walsender. In the case of a walsender they are
+interface or are sent by a walsender. In the case of a walsender, they are
encapsulated inside replication protocol WAL messages as described in
flow as physical replication.
tables/schemas that were present in the publication will be removed. The
ADD and DROP clauses will add and
remove one or more tables/schemas from the publication. Note that adding
- tables/schemas to a publication that is already subscribed to will require a
+ tables/schemas to a publication that is already subscribed to will require an
ALTER SUBSCRIPTION ... REFRESH PUBLICATION action on the
subscribing side in order to become effective.
Adding/Setting a table that is part of schema specified in
ALL TABLES IN SCHEMA , adding/setting a schema to a
- publication that already has a table that is part of specified schema or
+ publication that already has a table that is part of the specified schema or
adding/setting a table to a publication that already has a table's schema as
part of the specified schema is not supported.
When a partitioned table is published via schema level publication, all
- of its existing and future partitions irrespective of it being from the
- publication schema or not are implicitly considered to be part of the
- publication. So, even operations that are performed directly on a
+ of its existing and future partitions are implicitly considered to be part of the
+ publication, regardless of whether they are from the publication schema or not.
+ So, even operations that are performed directly on a
partition are also published via publications that its ancestors are
part of.
If FOR TABLE , FOR ALL TABLES or
- FOR ALL TABLES IN SCHEMA is not specified, then the
+ FOR ALL TABLES IN SCHEMA are not specified, then the
publication starts out with an empty set of tables. That is useful if
tables or schemas are to be added later.
First, scan the directory where the WAL segment files are written and
- find the newest completed segment file, using as starting point the
- beginning of the next WAL segment file. This is calculated independently
- on the compression method used to compress each segment.
+ find the newest completed segment file, using as the starting point the
+ beginning of the next WAL segment file.
If a starting point cannot be calculated with the previous method,
and if a replication slot is used, an extra
READ_REPLICATION_SLOT command is issued to retrieve
- the slot's restart_lsn to use as starting point.
+ the slot's restart_lsn to use as the starting point.
This option is only available when streaming write-ahead logs from
If a starting point cannot be calculated with the previous method,
the latest WAL flush location is used as reported by the server from
- a IDENTIFY_SYSTEM command.
+ an IDENTIFY_SYSTEM command.
Enables compression of write-ahead logs using the specified method.
- Supported values gzip , lz4
+ Supported values are gzip , lz4
(if
PostgreSQL was compiled with
--with-lz4 ), and none .
data is generated in pgbench client and then
sent to the server. This uses the client/server bandwidth
extensively through a COPY .
- pgbench uses the FREEZE option with 14 or later
-
versions of
PostgreSQL to speed up
+ pgbench uses the FREEZE option with version 14 or later
+ of
PostgreSQL to speed up
subsequent VACUUM , unless partitions are enabled.
Using g causes logging to print one message
every 100,000 rows while generating data for the
of the upgraded cluster to be written safely to disk. This option
causes pg_upgrade to return without waiting, which
is faster, but means that a subsequent operating system crash can leave
- the synchronized data directory corrupt. Generally, this option is
+ the data directory corrupt. Generally, this option is
useful for testing but should not be used on a production
installation.
In contrast to CREATE TABLE AS , SELECT
- INTO does not allow to specify properties like a table's access
+ INTO does not allow specifying properties like a table's access
method with
tablespace with
CREATE TABLE AS if necessary. Therefore, the default table
GinScanKey key = so->keys + i;
/*
- * If we're considering a lossy page, skip excludeOnly keys, They
+ * If we're considering a lossy page, skip excludeOnly keys. They
* can't exclude the whole page anyway.
*/
if (ItemPointerIsLossyPage(item) && key->excludeOnly)
/*
* Build a heap tuple representing the configured REPLICA IDENTITY to represent
- * the old tuple in a UPDATE or DELETE.
+ * the old tuple in an UPDATE or DELETE.
*
* Returns NULL if there's no need to log an identity or if there's no suitable
* key defined.
*/
if (LogwrtResult.Flush < WriteRqst.Flush &&
LogwrtResult.Flush < LogwrtResult.Write)
-
{
/*
* Could get here without iterating above loop, in which case we might
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * pg_publication.c
+ * src/backend/catalog/ pg_publication.c
*
*-------------------------------------------------------------------------
*/
RelationGetRelationName(OldHeap))));
/*
- * Hand of the actual copying to AM specific function, the generic code
+ * Hand off the actual copying to AM specific function, the generic code
* cannot know how to deal with visibility across AMs. Note that this
* routine is allowed to set FreezeXid / MultiXactCutoff to different
* values (e.g. because the AM doesn't use freezing).
Assert(availchars > 0); /* else caller chose a bad label */
/*
- * If we must truncate, preferentially truncate the longer name. This
+ * If we must truncate, preferentially truncate the longer name. This
* logic could be expressed without a loop, but it's simple and obvious as
* a loop.
*/
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * publicationcmds.c
+ * src/backend/commands/ publicationcmds.c
*
*-------------------------------------------------------------------------
*/
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * subscriptioncmds.c
+ * src/backend/commands/s ubscriptioncmds.c
*
*-------------------------------------------------------------------------
*/
*
*
* IDENTIFICATION
- * src/backend/optimizer/path /appendinfo.c
+ * src/backend/optimizer/util /appendinfo.c
*
*-------------------------------------------------------------------------
*/
*
*
* IDENTIFICATION
- * src/backend/optimizer/path /inherit.c
+ * src/backend/optimizer/util /inherit.c
*
*-------------------------------------------------------------------------
*/
* Copyright (c) 2012-2022, PostgreSQL Global Development Group
*
* IDENTIFICATION
- * src/backend/replication/logicalfuncs.c
+ * src/backend/replication/logical/logical funcs.c
*-------------------------------------------------------------------------
*/
*
*
* IDENTIFICATION
- * src/backend/replication/reorderbuffer.c
+ * src/backend/replication/logical/ reorderbuffer.c
*
* NOTES
* This module gets handed individual pieces of transactions in the order
* Copyright (c) 2012-2022, PostgreSQL Global Development Group
*
* IDENTIFICATION
- * src/backend/replication/snapbuild.c
+ * src/backend/replication/logical/ snapbuild.c
*
*-------------------------------------------------------------------------
*/
/*
* Set the current command being applied. Since this function can be
- * called recusively when applying spooled changes, save the current
+ * called recur sively when applying spooled changes, save the current
* command.
*/
saved_command = apply_error_callback_arg.command;
pgstat_report_activity(STATE_IDLE, NULL);
/*
- * Push apply error context callback. Fields will be filled dur ing
- * applying a change.
+ * Push apply error context callback. Fields will be filled while apply ing
+ * a change.
*/
errcallback.callback = apply_error_callback;
errcallback.previous = error_context_stack;
}
ereport(DEBUG1,
- (errmsg("logical replication apply worker for subscription \"%s\" two_phase is %s. ",
+ (errmsg("logical replication apply worker for subscription \"%s\" two_phase is %s",
MySubscription->name,
MySubscription->twophasestate == LOGICALREP_TWOPHASE_STATE_DISABLED ? "DISABLED" :
MySubscription->twophasestate == LOGICALREP_TWOPHASE_STATE_PENDING ? "PENDING" :
* build_attnums_array
* Transforms a bitmap into an array of AttrNumber values.
*
- * This is used for extended statistics only, so all the attribute must be
+ * This is used for extended statistics only, so all the attributes must be
* user-defined. That means offsetting by FirstLowInvalidHeapAttributeNumber
* is not necessary here (and when querying the bitmap).
*/
* This bound is at most 25, and approaches 0 as n approaches 0 or N. The
* case where n approaches 0 cannot happen in practice, since the sample
* size is at least 300. The case where n approaches N corresponds to
- * sampling the whole the t able, in which case it is reasonable to keep
+ * sampling the whole table, in which case it is reasonable to keep
* the whole MCV list (have no lower bound), so it makes sense to apply
* this formula for all inputs, even though the above derivation is
* technically only valid when the right hand side is at least around 10.
/* Copy the first chunk of groups into the result. */
for (i = 0; i < nitems; i++)
{
- /* just pointer to the proper place in the list */
+ /* just point to the proper place in the list */
MCVItem *item = &mcvlist->items[i];
item->values = (Datum *) palloc(sizeof(Datum) * numattrs);
/*
* statext_mcv_load
- * Load the MCV list for the indicated pg_statistic_ext tuple.
+ * Load the MCV list for the indicated pg_statistic_ext_data tuple.
*/
MCVList *
statext_mcv_load(Oid mvoid, bool inh)
Assert(mcvlist->nitems <= STATS_MCVLIST_MAX_ITEMS);
matches = palloc(sizeof(bool) * mcvlist->nitems);
- memset(matches, !is_or, sizeof(bool) * mcvlist->nitems);
+ memset(matches, !is_or, sizeof(bool) * mcvlist->nitems);
/*
* Loop through the list of clauses, and for each of them evaluate all the
}
/*
-
* ProcessSyncRequests() -- Process queued fsync requests.
*/
void
/* ----------
- * progress.c
+ * backend_ progress.c
*
* Command progress reporting infrastructure.
*
* Copyright (c) 2001-2022, PostgreSQL Global Development Group
*
- * src/backend/postmaster/ progress.c
+ * src/backend/utils/activity/backend_ progress.c
* ----------
*/
#include "postgres.h"
*
*
* IDENTIFICATION
- * src/backend/postmaster /backend_status.c
+ * src/backend/utils/activity /backend_status.c
* ----------
*/
#include "postgres.h"
*
*
* IDENTIFICATION
- * src/backend/postmaster /wait_event.c
+ * src/backend/utils/activity /wait_event.c
*
* NOTES
*
/*
* When printing kinds we ignore expression statistics,
- * which is used only internally and can't be specified by
- * user. We don't print the kinds when either none are
+ * which are used only internally and can't be specified
+ * by user. We don't print the kinds when none are
* specified (in which case it has to be statistics on a
* single expr) or when all are specified (in which case
* we assume it's expanded by CREATE STATISTICS).
* Copyright (c) 2015-2022, PostgreSQL Global Development Group
*
* IDENTIFICATION
- * pgoutput.h
+ * src/include/replication/ pgoutput.h
*
*-------------------------------------------------------------------------
*/
/*-------------------------------------------------------------------------
*
- * dynahash
+ * dynahash.h
* POSTGRES dynahash.h file definitions
*
*
* Portions Copyright (c) 1996-2022, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * src/include/utils/dynahash.h
+ * IDENTIFICATION
+ * src/include/utils/dynahash.h
*
*-------------------------------------------------------------------------
*/
SAVETMPS;
/*-------------------------
- * Unfortunately, while HeUTF8 is true for most things > 256, for values
+ * Unfortunately, while HeUTF8 is true for most things > 256, for values
* 128..255 it's not, but perl will treat them as unicode code points if
* the utf8 flag is not set ( see The "Unicode Bug" in perldoc perlunicode
* for more)
/*-------------------------------------------------------------------------
*
- * src/port/ pgcheckdir.c
+ * pgcheckdir.c
*
* A simple subroutine to check whether a directory exists and is empty or not.
* Useful in both initdb and the backend.
* Portions Copyright (c) 1996-2022, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
+ * IDENTIFICATION
+ * src/port/pgcheckdir.c
*-------------------------------------------------------------------------
*/
CREATE TABLE foo (a oid, b oid, c int, FOREIGN KEY (a, b, c) REFERENCES pg_description);
ERROR: permission denied: "pg_description" is a system catalog
-- RangeVarCallbackOwnsRelation()
-CREATE INDEX pg_descripton_test_index ON pg_description (description);
+CREATE INDEX pg_descripti on_test_index ON pg_description (description);
ERROR: permission denied: "pg_description" is a system catalog
-- RangeVarCallbackForAlterRelation()
ALTER TABLE pg_description RENAME TO pg_comment;
ROLLBACK;
-- RangeVarCallbackOwnsRelation()
BEGIN;
-CREATE INDEX pg_descripton_test_index ON pg_description (description);
+CREATE INDEX pg_descripti on_test_index ON pg_description (description);
ROLLBACK;
-- RangeVarCallbackForAlterRelation()
BEGIN;
CREATE TABLE foo (a oid, b oid, c int, FOREIGN KEY (a, b, c) REFERENCES pg_description);
-- RangeVarCallbackOwnsRelation()
-CREATE INDEX pg_descripton_test_index ON pg_description (description);
+CREATE INDEX pg_descripti on_test_index ON pg_description (description);
-- RangeVarCallbackForAlterRelation()
ALTER TABLE pg_description RENAME TO pg_comment;
-- RangeVarCallbackOwnsRelation()
BEGIN;
-CREATE INDEX pg_descripton_test_index ON pg_description (description);
+CREATE INDEX pg_descripti on_test_index ON pg_description (description);
ROLLBACK;
-- RangeVarCallbackForAlterRelation()
(1 row)
-- The entire output of pg_backend_memory_contexts is not stable,
--- we test only the exista nce and basic condition of TopMemoryContext.
+-- we test only the existe nce and basic condition of TopMemoryContext.
select name, ident, parent, level, total_bytes >= free_bytes
from pg_backend_memory_contexts where level = 0;
name | ident | parent | level | ?column?
select count(*) >= 0 as ok from pg_available_extensions;
-- The entire output of pg_backend_memory_contexts is not stable,
--- we test only the exista nce and basic condition of TopMemoryContext.
+-- we test only the existe nce and basic condition of TopMemoryContext.
select name, ident, parent, level, total_bytes >= free_bytes
from pg_backend_memory_contexts where level = 0;
$ENV{REGRESS_OUTPUTDIR} = "$topdir/src/test/recovery/tmp_check";
- my $mstat = 0;
my $dir = "$topdir/src/test/recovery";
my $status = tap_check($dir);
exit $status if $status;
# list is returned if the module does not need to run anything.
sub fetchTests
{
-
my $handle;
open($handle, '<', "GNUmakefile")
|| open($handle, '<', "Makefile")
sub usage
{
print STDERR
- "Usage: vcregress.pl
[ ]\n\n", + "Usage: vcregress.pl
[]\n\n", "Options for :\n",
" bincheck run tests of utilities in src/bin/\n",
" check deploy instance and run regression tests on it\n",
projects / postgresql.git / commitdiff