mirror of
https://github.com/postgres/postgres.git
synced 2025-04-25 21:42:33 +03:00
Fix assorted inconsistencies.
There were a number of issues in the recent commits which include typos, code and comments mismatch, leftover function declarations. Fix them. Reported-by: Alexander Lakhin Author: Alexander Lakhin, Amit Kapila and Amit Langote Reviewed-by: Amit Kapila Discussion: https://postgr.es/m/ef0c0232-0c1d-3a35-63d4-0ebd06e31387@gmail.com
This commit is contained in:
parent
35b2d4bc0e
commit
92c4abc736
@ -52,9 +52,6 @@
|
|||||||
* (v) make sure the lock level is set correctly for that operation
|
* (v) make sure the lock level is set correctly for that operation
|
||||||
* (vi) don't forget to document the option
|
* (vi) don't forget to document the option
|
||||||
*
|
*
|
||||||
* Note that we don't handle "oids" in relOpts because it is handled by
|
|
||||||
* interpretOidsOption().
|
|
||||||
*
|
|
||||||
* The default choice for any new option should be AccessExclusiveLock.
|
* The default choice for any new option should be AccessExclusiveLock.
|
||||||
* In some cases the lock level can be reduced from there, but the lock
|
* In some cases the lock level can be reduced from there, but the lock
|
||||||
* level chosen should always conflict with itself to ensure that multiple
|
* level chosen should always conflict with itself to ensure that multiple
|
||||||
|
@ -239,8 +239,8 @@ initscan(HeapScanDesc scan, ScanKey key, bool keep_startblock)
|
|||||||
* behaviors, independently of the size of the table; also there is a GUC
|
* behaviors, independently of the size of the table; also there is a GUC
|
||||||
* variable that can disable synchronized scanning.)
|
* variable that can disable synchronized scanning.)
|
||||||
*
|
*
|
||||||
* Note that heap_parallelscan_initialize has a very similar test; if you
|
* Note that table_block_parallelscan_initialize has a very similar test;
|
||||||
* change this, consider changing that one, too.
|
* if you change this, consider changing that one, too.
|
||||||
*/
|
*/
|
||||||
if (!RelationUsesLocalBuffers(scan->rs_base.rs_rd) &&
|
if (!RelationUsesLocalBuffers(scan->rs_base.rs_rd) &&
|
||||||
scan->rs_nblocks > NBuffers / 4)
|
scan->rs_nblocks > NBuffers / 4)
|
||||||
@ -1396,15 +1396,6 @@ heap_getnextslot(TableScanDesc sscan, ScanDirection direction, TupleTableSlot *s
|
|||||||
* If the tuple is found but fails the time qual check, then false is returned
|
* If the tuple is found but fails the time qual check, then false is returned
|
||||||
* but tuple->t_data is left pointing to the tuple.
|
* but tuple->t_data is left pointing to the tuple.
|
||||||
*
|
*
|
||||||
* keep_buf determines what is done with the buffer in the false-result cases.
|
|
||||||
* When the caller specifies keep_buf = true, we retain the pin on the buffer
|
|
||||||
* and return it in *userbuf (so the caller must eventually unpin it); when
|
|
||||||
* keep_buf = false, the pin is released and *userbuf is set to InvalidBuffer.
|
|
||||||
*
|
|
||||||
* stats_relation is the relation to charge the heap_fetch operation against
|
|
||||||
* for statistical purposes. (This could be the heap rel itself, an
|
|
||||||
* associated index, or NULL to not count the fetch at all.)
|
|
||||||
*
|
|
||||||
* heap_fetch does not follow HOT chains: only the exact TID requested will
|
* heap_fetch does not follow HOT chains: only the exact TID requested will
|
||||||
* be fetched.
|
* be fetched.
|
||||||
*
|
*
|
||||||
@ -7085,7 +7076,7 @@ heap_compute_xid_horizon_for_tuples(Relation rel,
|
|||||||
* Conjecture: if hitemid is dead then it had xids before the xids
|
* Conjecture: if hitemid is dead then it had xids before the xids
|
||||||
* marked on LP_NORMAL items. So we just ignore this item and move
|
* marked on LP_NORMAL items. So we just ignore this item and move
|
||||||
* onto the next, for the purposes of calculating
|
* onto the next, for the purposes of calculating
|
||||||
* latestRemovedxids.
|
* latestRemovedXid.
|
||||||
*/
|
*/
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
@ -286,7 +286,7 @@ heapam_tuple_insert_speculative(Relation relation, TupleTableSlot *slot,
|
|||||||
|
|
||||||
static void
|
static void
|
||||||
heapam_tuple_complete_speculative(Relation relation, TupleTableSlot *slot,
|
heapam_tuple_complete_speculative(Relation relation, TupleTableSlot *slot,
|
||||||
uint32 spekToken, bool succeeded)
|
uint32 specToken, bool succeeded)
|
||||||
{
|
{
|
||||||
bool shouldFree = true;
|
bool shouldFree = true;
|
||||||
HeapTuple tuple = ExecFetchSlotHeapTuple(slot, true, &shouldFree);
|
HeapTuple tuple = ExecFetchSlotHeapTuple(slot, true, &shouldFree);
|
||||||
|
@ -350,7 +350,7 @@ end_heap_rewrite(RewriteState state)
|
|||||||
*
|
*
|
||||||
* It's obvious that we must do this when not WAL-logging. It's less
|
* It's obvious that we must do this when not WAL-logging. It's less
|
||||||
* obvious that we have to do it even if we did WAL-log the pages. The
|
* obvious that we have to do it even if we did WAL-log the pages. The
|
||||||
* reason is the same as in tablecmds.c's copy_relation_data(): we're
|
* reason is the same as in storage.c's RelationCopyStorage(): we're
|
||||||
* writing data that's not in shared buffers, and so a CHECKPOINT
|
* writing data that's not in shared buffers, and so a CHECKPOINT
|
||||||
* occurring during the rewriteheap operation won't have fsync'd data we
|
* occurring during the rewriteheap operation won't have fsync'd data we
|
||||||
* wrote before the checkpoint.
|
* wrote before the checkpoint.
|
||||||
|
@ -91,8 +91,8 @@ int synchronous_commit = SYNCHRONOUS_COMMIT_ON;
|
|||||||
* need to return the same answers in the parallel worker as they would have
|
* need to return the same answers in the parallel worker as they would have
|
||||||
* in the user backend, so we need some additional bookkeeping.
|
* in the user backend, so we need some additional bookkeeping.
|
||||||
*
|
*
|
||||||
* XactTopTransactionId stores the XID of our toplevel transaction, which
|
* XactTopFullTransactionId stores the XID of our toplevel transaction, which
|
||||||
* will be the same as TopTransactionState.transactionId in an ordinary
|
* will be the same as TopTransactionState.fullTransactionId in an ordinary
|
||||||
* backend; but in a parallel backend, which does not have the entire
|
* backend; but in a parallel backend, which does not have the entire
|
||||||
* transaction state, it will instead be copied from the backend that started
|
* transaction state, it will instead be copied from the backend that started
|
||||||
* the parallel operation.
|
* the parallel operation.
|
||||||
|
@ -314,8 +314,6 @@ static bool recoveryStopAfter;
|
|||||||
*
|
*
|
||||||
* recoveryTargetTLI: the currently understood target timeline; changes
|
* recoveryTargetTLI: the currently understood target timeline; changes
|
||||||
*
|
*
|
||||||
* recoveryTargetIsLatest: was the requested target timeline 'latest'?
|
|
||||||
*
|
|
||||||
* expectedTLEs: a list of TimeLineHistoryEntries for recoveryTargetTLI and the timelines of
|
* expectedTLEs: a list of TimeLineHistoryEntries for recoveryTargetTLI and the timelines of
|
||||||
* its known parents, newest first (so recoveryTargetTLI is always the
|
* its known parents, newest first (so recoveryTargetTLI is always the
|
||||||
* first list member). Only these TLIs are expected to be seen in the WAL
|
* first list member). Only these TLIs are expected to be seen in the WAL
|
||||||
|
@ -1024,7 +1024,7 @@ log_newpage_buffer(Buffer buffer, bool page_std)
|
|||||||
/*
|
/*
|
||||||
* WAL-log a range of blocks in a relation.
|
* WAL-log a range of blocks in a relation.
|
||||||
*
|
*
|
||||||
* An image of all pages with block numbers 'startblk' <= X < 'endblock' is
|
* An image of all pages with block numbers 'startblk' <= X < 'endblk' is
|
||||||
* written to the WAL. If the range is large, this is done in multiple WAL
|
* written to the WAL. If the range is large, this is done in multiple WAL
|
||||||
* records.
|
* records.
|
||||||
*
|
*
|
||||||
|
@ -177,7 +177,6 @@ typedef struct CopyStateData
|
|||||||
*/
|
*/
|
||||||
AttrNumber num_defaults;
|
AttrNumber num_defaults;
|
||||||
FmgrInfo oid_in_function;
|
FmgrInfo oid_in_function;
|
||||||
Oid oid_typioparam;
|
|
||||||
FmgrInfo *in_functions; /* array of input functions for each attrs */
|
FmgrInfo *in_functions; /* array of input functions for each attrs */
|
||||||
Oid *typioparams; /* array of element types for in_functions */
|
Oid *typioparams; /* array of element types for in_functions */
|
||||||
int *defmap; /* array of default att numbers */
|
int *defmap; /* array of default att numbers */
|
||||||
|
@ -379,7 +379,7 @@ static void ATExecCheckNotNull(AlteredTableInfo *tab, Relation rel,
|
|||||||
const char *colName, LOCKMODE lockmode);
|
const char *colName, LOCKMODE lockmode);
|
||||||
static bool NotNullImpliedByRelConstraints(Relation rel, Form_pg_attribute attr);
|
static bool NotNullImpliedByRelConstraints(Relation rel, Form_pg_attribute attr);
|
||||||
static bool ConstraintImpliedByRelConstraint(Relation scanrel,
|
static bool ConstraintImpliedByRelConstraint(Relation scanrel,
|
||||||
List *partConstraint, List *existedConstraints);
|
List *testConstraint, List *provenConstraint);
|
||||||
static ObjectAddress ATExecColumnDefault(Relation rel, const char *colName,
|
static ObjectAddress ATExecColumnDefault(Relation rel, const char *colName,
|
||||||
Node *newDefault, LOCKMODE lockmode);
|
Node *newDefault, LOCKMODE lockmode);
|
||||||
static ObjectAddress ATExecAddIdentity(Relation rel, const char *colName,
|
static ObjectAddress ATExecAddIdentity(Relation rel, const char *colName,
|
||||||
@ -5522,8 +5522,8 @@ ATPrepAddColumn(List **wqueue, Relation rel, bool recurse, bool recursing,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Add a column to a table; this handles the AT_AddOids cases as well. The
|
* Add a column to a table. The return value is the address of the
|
||||||
* return value is the address of the new column in the parent relation.
|
* new column in the parent relation.
|
||||||
*/
|
*/
|
||||||
static ObjectAddress
|
static ObjectAddress
|
||||||
ATExecAddColumn(List **wqueue, AlteredTableInfo *tab, Relation rel,
|
ATExecAddColumn(List **wqueue, AlteredTableInfo *tab, Relation rel,
|
||||||
|
@ -1867,7 +1867,7 @@ void
|
|||||||
slot_getsomeattrs_int(TupleTableSlot *slot, int attnum)
|
slot_getsomeattrs_int(TupleTableSlot *slot, int attnum)
|
||||||
{
|
{
|
||||||
/* Check for caller errors */
|
/* Check for caller errors */
|
||||||
Assert(slot->tts_nvalid < attnum); /* slot_getsomeattr checked */
|
Assert(slot->tts_nvalid < attnum); /* checked in slot_getsomeattrs */
|
||||||
Assert(attnum > 0);
|
Assert(attnum > 0);
|
||||||
|
|
||||||
if (unlikely(attnum > slot->tts_tupleDescriptor->natts))
|
if (unlikely(attnum > slot->tts_tupleDescriptor->natts))
|
||||||
|
@ -2316,7 +2316,9 @@ ExecInitModifyTable(ModifyTable *node, EState *estate, int eflags)
|
|||||||
* verify that the proposed target relations are valid and open their
|
* verify that the proposed target relations are valid and open their
|
||||||
* indexes for insertion of new index entries. Note we *must* set
|
* indexes for insertion of new index entries. Note we *must* set
|
||||||
* estate->es_result_relation_info correctly while we initialize each
|
* estate->es_result_relation_info correctly while we initialize each
|
||||||
* sub-plan; ExecContextForcesOids depends on that!
|
* sub-plan; external modules such as FDWs may depend on that (see
|
||||||
|
* contrib/postgres_fdw/postgres_fdw.c: postgresBeginDirectModify()
|
||||||
|
* as one example).
|
||||||
*/
|
*/
|
||||||
saved_resultRelInfo = estate->es_result_relation_info;
|
saved_resultRelInfo = estate->es_result_relation_info;
|
||||||
|
|
||||||
|
@ -236,7 +236,7 @@ struct IntegerSet
|
|||||||
*
|
*
|
||||||
* 'iter_values' is an array of integers ready to be returned to the
|
* 'iter_values' is an array of integers ready to be returned to the
|
||||||
* caller; 'iter_num_values' is the length of that array, and
|
* caller; 'iter_num_values' is the length of that array, and
|
||||||
* 'iter_valueno' is the next index. 'iter_node' and 'item_itemno' point
|
* 'iter_valueno' is the next index. 'iter_node' and 'iter_itemno' point
|
||||||
* to the leaf node, and item within the leaf node, to get the next batch
|
* to the leaf node, and item within the leaf node, to get the next batch
|
||||||
* of values from.
|
* of values from.
|
||||||
*
|
*
|
||||||
|
@ -404,7 +404,7 @@ static void BackendRun(Port *port) pg_attribute_noreturn();
|
|||||||
static void ExitPostmaster(int status) pg_attribute_noreturn();
|
static void ExitPostmaster(int status) pg_attribute_noreturn();
|
||||||
static int ServerLoop(void);
|
static int ServerLoop(void);
|
||||||
static int BackendStartup(Port *port);
|
static int BackendStartup(Port *port);
|
||||||
static int ProcessStartupPacket(Port *port, bool SSLdone);
|
static int ProcessStartupPacket(Port *port, bool secure_done);
|
||||||
static void SendNegotiateProtocolVersion(List *unrecognized_protocol_options);
|
static void SendNegotiateProtocolVersion(List *unrecognized_protocol_options);
|
||||||
static void processCancelRequest(Port *port, void *pkt);
|
static void processCancelRequest(Port *port, void *pkt);
|
||||||
static int initMasks(fd_set *rmask);
|
static int initMasks(fd_set *rmask);
|
||||||
|
@ -921,7 +921,7 @@ register_dirty_segment(SMgrRelation reln, ForkNumber forknum, MdfdVec *seg)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* register_unlink() -- Schedule a file to be deleted after next checkpoint
|
* register_unlink_segment() -- Schedule a file to be deleted after next checkpoint
|
||||||
*/
|
*/
|
||||||
static void
|
static void
|
||||||
register_unlink_segment(RelFileNodeBackend rnode, ForkNumber forknum,
|
register_unlink_segment(RelFileNodeBackend rnode, ForkNumber forknum,
|
||||||
|
@ -116,8 +116,6 @@ extern void heap_setscanlimits(TableScanDesc scan, BlockNumber startBlk,
|
|||||||
extern void heapgetpage(TableScanDesc scan, BlockNumber page);
|
extern void heapgetpage(TableScanDesc scan, BlockNumber page);
|
||||||
extern void heap_rescan(TableScanDesc scan, ScanKey key, bool set_params,
|
extern void heap_rescan(TableScanDesc scan, ScanKey key, bool set_params,
|
||||||
bool allow_strat, bool allow_sync, bool allow_pagemode);
|
bool allow_strat, bool allow_sync, bool allow_pagemode);
|
||||||
extern void heap_rescan_set_params(TableScanDesc scan, ScanKey key,
|
|
||||||
bool allow_strat, bool allow_sync, bool allow_pagemode);
|
|
||||||
extern void heap_endscan(TableScanDesc scan);
|
extern void heap_endscan(TableScanDesc scan);
|
||||||
extern HeapTuple heap_getnext(TableScanDesc scan, ScanDirection direction);
|
extern HeapTuple heap_getnext(TableScanDesc scan, ScanDirection direction);
|
||||||
extern bool heap_getnextslot(TableScanDesc sscan,
|
extern bool heap_getnextslot(TableScanDesc sscan,
|
||||||
|
@ -690,7 +690,7 @@ typedef struct TableAmRoutine
|
|||||||
* block using the TsmRoutine's NextSampleTuple() callback.
|
* block using the TsmRoutine's NextSampleTuple() callback.
|
||||||
*
|
*
|
||||||
* The callback needs to perform visibility checks, and only return
|
* The callback needs to perform visibility checks, and only return
|
||||||
* visible tuples. That obviously can mean calling NextSampletuple()
|
* visible tuples. That obviously can mean calling NextSampleTuple()
|
||||||
* multiple times.
|
* multiple times.
|
||||||
*
|
*
|
||||||
* The TsmRoutine interface assumes that there's a maximum offset on a
|
* The TsmRoutine interface assumes that there's a maximum offset on a
|
||||||
@ -1596,7 +1596,7 @@ table_relation_size(Relation rel, ForkNumber forkNumber)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* table_needs_toast_table - does this relation need a toast table?
|
* table_relation_needs_toast_table - does this relation need a toast table?
|
||||||
*/
|
*/
|
||||||
static inline bool
|
static inline bool
|
||||||
table_relation_needs_toast_table(Relation rel)
|
table_relation_needs_toast_table(Relation rel)
|
||||||
|
@ -514,7 +514,6 @@ extern ExprContext *MakePerTupleExprContext(EState *estate);
|
|||||||
|
|
||||||
extern void ExecAssignExprContext(EState *estate, PlanState *planstate);
|
extern void ExecAssignExprContext(EState *estate, PlanState *planstate);
|
||||||
extern TupleDesc ExecGetResultType(PlanState *planstate);
|
extern TupleDesc ExecGetResultType(PlanState *planstate);
|
||||||
extern TupleTableSlot ExecGetResultSlot(PlanState *planstate);
|
|
||||||
extern const TupleTableSlotOps *ExecGetResultSlotOps(PlanState *planstate,
|
extern const TupleTableSlotOps *ExecGetResultSlotOps(PlanState *planstate,
|
||||||
bool *isfixed);
|
bool *isfixed);
|
||||||
extern void ExecAssignProjectionInfo(PlanState *planstate,
|
extern void ExecAssignProjectionInfo(PlanState *planstate,
|
||||||
|
@ -44,7 +44,7 @@ typedef enum SyncRequestHandler
|
|||||||
*/
|
*/
|
||||||
typedef struct FileTag
|
typedef struct FileTag
|
||||||
{
|
{
|
||||||
int16 handler; /* SyncRequstHandler value, saving space */
|
int16 handler; /* SyncRequestHandler value, saving space */
|
||||||
int16 forknum; /* ForkNumber, saving space */
|
int16 forknum; /* ForkNumber, saving space */
|
||||||
RelFileNode rnode;
|
RelFileNode rnode;
|
||||||
uint32 segno;
|
uint32 segno;
|
||||||
|
@ -581,7 +581,7 @@ test_huge_distances(void)
|
|||||||
intset_add_member(intset, values[i]);
|
intset_add_member(intset, values[i]);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Test iterset_is_member() around each of these values
|
* Test intset_is_member() around each of these values
|
||||||
*/
|
*/
|
||||||
for (int i = 0; i < num_values; i++)
|
for (int i = 0; i < num_values; i++)
|
||||||
{
|
{
|
||||||
|
Loading…
x
Reference in New Issue
Block a user