Remove useless casting to same type

This removes some casts where the input already has the same type as
the type specified by the cast.  Their presence could cause risks of
hiding actual type mismatches in the future or silently discarding
qualifiers.  It also improves readability.  Same kind of idea as
7f798aca1d and ef8fe69360.  (This does not change all such
instances, but only those hand-picked by the author.)

Author: Bertrand Drouvot <bertranddrouvot.pg@gmail.com>
Reviewed-by: Nathan Bossart <nathandbossart@gmail.com>
Reviewed-by: Jacob Champion <jacob.champion@enterprisedb.com>
Reviewed-by: Peter Eisentraut <peter@eisentraut.org>
Discussion: https://www.postgresql.org/message-id/flat/aSQy2JawavlVlEB0%40ip-10-97-1-34.eu-west-3.compute.internal
pull/255/head
Peter Eisentraut 2 weeks ago
parent 35988b31db
commit 4f941d432b
  1. 4
      contrib/btree_gist/btree_utils_num.c
  2. 6
      contrib/cube/cube.c
  3. 2
      contrib/fuzzystrmatch/dmetaphone.c
  4. 2
      contrib/pgcrypto/mbuf.c
  5. 2
      src/backend/access/common/indextuple.c
  6. 8
      src/backend/access/gin/gindatapage.c
  7. 2
      src/backend/access/gin/gininsert.c
  8. 4
      src/backend/access/hash/hash_xlog.c
  9. 2
      src/backend/access/transam/twophase.c
  10. 4
      src/backend/catalog/aclchk.c
  11. 2
      src/backend/commands/tablecmds.c
  12. 2
      src/backend/executor/execExpr.c
  13. 2
      src/backend/executor/execExprInterp.c
  14. 2
      src/backend/executor/execPartition.c
  15. 2
      src/backend/executor/nodeTableFuncscan.c
  16. 4
      src/backend/optimizer/geqo/geqo_pool.c
  17. 4
      src/backend/optimizer/plan/planner.c
  18. 2
      src/backend/optimizer/util/pathnode.c
  19. 2
      src/backend/parser/analyze.c
  20. 4
      src/backend/parser/parse_expr.c
  21. 2
      src/backend/port/sysv_shmem.c
  22. 2
      src/backend/replication/walsender.c
  23. 2
      src/backend/rewrite/rewriteHandler.c
  24. 4
      src/backend/statistics/dependencies.c
  25. 4
      src/backend/statistics/extended_stats.c
  26. 2
      src/backend/statistics/mcv.c
  27. 6
      src/backend/storage/aio/aio.c
  28. 2
      src/backend/storage/aio/method_io_uring.c
  29. 2
      src/backend/storage/ipc/waiteventset.c
  30. 2
      src/backend/storage/lmgr/predicate.c
  31. 8
      src/backend/storage/lmgr/proc.c
  32. 4
      src/backend/utils/adt/arrayfuncs.c
  33. 6
      src/backend/utils/adt/jsonfuncs.c
  34. 2
      src/backend/utils/adt/ruleutils.c
  35. 8
      src/bin/pg_dump/pg_dump.c
  36. 4
      src/common/sha1.c
  37. 2
      src/interfaces/ecpg/ecpglib/descriptor.c
  38. 18
      src/interfaces/ecpg/ecpglib/execute.c
  39. 6
      src/interfaces/ecpg/ecpglib/prepare.c
  40. 2
      src/port/win32ntdll.c
  41. 2
      src/test/modules/test_radixtree/test_radixtree.c

@ -181,8 +181,8 @@ gbt_num_union(GBT_NUMKEY *out, const GistEntryVector *entryvec, const gbtree_nin
cur = (GBT_NUMKEY *) DatumGetPointer((entryvec->vector[0].key)); cur = (GBT_NUMKEY *) DatumGetPointer((entryvec->vector[0].key));
o.lower = &((GBT_NUMKEY *) out)[0]; o.lower = &out[0];
o.upper = &((GBT_NUMKEY *) out)[tinfo->size]; o.upper = &out[tinfo->size];
memcpy(out, cur, 2 * tinfo->size); memcpy(out, cur, 2 * tinfo->size);

@ -718,16 +718,16 @@ g_cube_internal_consistent(NDBOX *key,
switch (strategy) switch (strategy)
{ {
case RTOverlapStrategyNumber: case RTOverlapStrategyNumber:
retval = (bool) cube_overlap_v0(key, query); retval = cube_overlap_v0(key, query);
break; break;
case RTSameStrategyNumber: case RTSameStrategyNumber:
case RTContainsStrategyNumber: case RTContainsStrategyNumber:
case RTOldContainsStrategyNumber: case RTOldContainsStrategyNumber:
retval = (bool) cube_contains_v0(key, query); retval = cube_contains_v0(key, query);
break; break;
case RTContainedByStrategyNumber: case RTContainedByStrategyNumber:
case RTOldContainedByStrategyNumber: case RTOldContainedByStrategyNumber:
retval = (bool) cube_overlap_v0(key, query); retval = cube_overlap_v0(key, query);
break; break;
default: default:
retval = false; retval = false;

@ -327,7 +327,7 @@ GetAt(metastring *s, int pos)
if ((pos < 0) || (pos >= s->length)) if ((pos < 0) || (pos >= s->length))
return '\0'; return '\0';
return ((char) *(s->str + pos)); return *(s->str + pos);
} }

@ -133,7 +133,7 @@ mbuf_create_from_data(uint8 *data, int len)
MBuf *mbuf; MBuf *mbuf;
mbuf = palloc(sizeof *mbuf); mbuf = palloc(sizeof *mbuf);
mbuf->data = (uint8 *) data; mbuf->data = data;
mbuf->buf_end = mbuf->data + len; mbuf->buf_end = mbuf->data + len;
mbuf->data_end = mbuf->data + len; mbuf->data_end = mbuf->data + len;
mbuf->read_pos = mbuf->data; mbuf->read_pos = mbuf->data;

@ -172,7 +172,7 @@ index_form_tuple_context(TupleDesc tupleDescriptor,
values, values,
#endif #endif
isnull, isnull,
(char *) tp + hoff, tp + hoff,
data_size, data_size,
&tupmask, &tupmask,
(hasnull ? (bits8 *) tp + sizeof(IndexTupleData) : NULL)); (hasnull ? (bits8 *) tp + sizeof(IndexTupleData) : NULL));

@ -607,11 +607,11 @@ dataBeginPlaceToPageLeaf(GinBtree btree, Buffer buf, GinBtreeStack *stack,
if (append) if (append)
elog(DEBUG2, "appended %d new items to block %u; %d bytes (%d to go)", elog(DEBUG2, "appended %d new items to block %u; %d bytes (%d to go)",
maxitems, BufferGetBlockNumber(buf), (int) leaf->lsize, maxitems, BufferGetBlockNumber(buf), leaf->lsize,
items->nitem - items->curitem - maxitems); items->nitem - items->curitem - maxitems);
else else
elog(DEBUG2, "inserted %d new items to block %u; %d bytes (%d to go)", elog(DEBUG2, "inserted %d new items to block %u; %d bytes (%d to go)",
maxitems, BufferGetBlockNumber(buf), (int) leaf->lsize, maxitems, BufferGetBlockNumber(buf), leaf->lsize,
items->nitem - items->curitem - maxitems); items->nitem - items->curitem - maxitems);
} }
else else
@ -693,11 +693,11 @@ dataBeginPlaceToPageLeaf(GinBtree btree, Buffer buf, GinBtreeStack *stack,
if (append) if (append)
elog(DEBUG2, "appended %d items to block %u; split %d/%d (%d to go)", elog(DEBUG2, "appended %d items to block %u; split %d/%d (%d to go)",
maxitems, BufferGetBlockNumber(buf), (int) leaf->lsize, (int) leaf->rsize, maxitems, BufferGetBlockNumber(buf), leaf->lsize, leaf->rsize,
items->nitem - items->curitem - maxitems); items->nitem - items->curitem - maxitems);
else else
elog(DEBUG2, "inserted %d items to block %u; split %d/%d (%d to go)", elog(DEBUG2, "inserted %d items to block %u; split %d/%d (%d to go)",
maxitems, BufferGetBlockNumber(buf), (int) leaf->lsize, (int) leaf->rsize, maxitems, BufferGetBlockNumber(buf), leaf->lsize, leaf->rsize,
items->nitem - items->curitem - maxitems); items->nitem - items->curitem - maxitems);
} }

@ -2412,7 +2412,7 @@ _gin_parse_tuple_items(GinTuple *a)
Assert(ndecoded == a->nitems); Assert(ndecoded == a->nitems);
return (ItemPointer) items; return items;
} }
/* /*

@ -590,7 +590,7 @@ hash_xlog_move_page_contents(XLogReaderState *record)
OffsetNumber *unend; OffsetNumber *unend;
unused = (OffsetNumber *) ptr; unused = (OffsetNumber *) ptr;
unend = (OffsetNumber *) ((char *) ptr + len); unend = (OffsetNumber *) (ptr + len);
if ((unend - unused) > 0) if ((unend - unused) > 0)
PageIndexMultiDelete(page, unused, unend - unused); PageIndexMultiDelete(page, unused, unend - unused);
@ -901,7 +901,7 @@ hash_xlog_delete(XLogReaderState *record)
OffsetNumber *unend; OffsetNumber *unend;
unused = (OffsetNumber *) ptr; unused = (OffsetNumber *) ptr;
unend = (OffsetNumber *) ((char *) ptr + len); unend = (OffsetNumber *) (ptr + len);
if ((unend - unused) > 0) if ((unend - unused) > 0)
PageIndexMultiDelete(page, unused, unend - unused); PageIndexMultiDelete(page, unused, unend - unused);

@ -1037,7 +1037,7 @@ save_state_data(const void *data, uint32 len)
records.tail->data = palloc(records.bytes_free); records.tail->data = palloc(records.bytes_free);
} }
memcpy(((char *) records.tail->data) + records.tail->len, data, len); memcpy(records.tail->data + records.tail->len, data, len);
records.tail->len += padlen; records.tail->len += padlen;
records.bytes_free -= padlen; records.bytes_free -= padlen;
records.total_len += padlen; records.total_len += padlen;

@ -580,7 +580,7 @@ ExecuteGrantStmt(GrantStmt *stmt)
elog(ERROR, "AccessPriv node must specify privilege or columns"); elog(ERROR, "AccessPriv node must specify privilege or columns");
priv = string_to_privilege(privnode->priv_name); priv = string_to_privilege(privnode->priv_name);
if (priv & ~((AclMode) all_privileges)) if (priv & ~all_privileges)
ereport(ERROR, ereport(ERROR,
(errcode(ERRCODE_INVALID_GRANT_OPERATION), (errcode(ERRCODE_INVALID_GRANT_OPERATION),
errmsg(errormsg, privilege_to_string(priv)))); errmsg(errormsg, privilege_to_string(priv))));
@ -1059,7 +1059,7 @@ ExecAlterDefaultPrivilegesStmt(ParseState *pstate, AlterDefaultPrivilegesStmt *s
elog(ERROR, "AccessPriv node must specify privilege"); elog(ERROR, "AccessPriv node must specify privilege");
priv = string_to_privilege(privnode->priv_name); priv = string_to_privilege(privnode->priv_name);
if (priv & ~((AclMode) all_privileges)) if (priv & ~all_privileges)
ereport(ERROR, ereport(ERROR,
(errcode(ERRCODE_INVALID_GRANT_OPERATION), (errcode(ERRCODE_INVALID_GRANT_OPERATION),
errmsg(errormsg, privilege_to_string(priv)))); errmsg(errormsg, privilege_to_string(priv))));

@ -6205,7 +6205,7 @@ ATRewriteTable(AlteredTableInfo *tab, Oid OIDNewHeap)
NewColumnValue *ex = lfirst(l); NewColumnValue *ex = lfirst(l);
/* expr already planned */ /* expr already planned */
ex->exprstate = ExecInitExpr((Expr *) ex->expr, NULL); ex->exprstate = ExecInitExpr(ex->expr, NULL);
} }
notnull_attrs = notnull_virtual_attrs = NIL; notnull_attrs = notnull_virtual_attrs = NIL;

@ -4807,7 +4807,7 @@ ExecInitJsonExpr(JsonExpr *jsexpr, ExprState *state,
var->typid = exprType((Node *) argexpr); var->typid = exprType((Node *) argexpr);
var->typmod = exprTypmod((Node *) argexpr); var->typmod = exprTypmod((Node *) argexpr);
ExecInitExprRec((Expr *) argexpr, state, &var->value, &var->isnull); ExecInitExprRec(argexpr, state, &var->value, &var->isnull);
jsestate->args = lappend(jsestate->args, var); jsestate->args = lappend(jsestate->args, var);
} }

@ -3283,7 +3283,7 @@ ExecEvalNextValueExpr(ExprState *state, ExprEvalStep *op)
*op->resvalue = Int32GetDatum((int32) newval); *op->resvalue = Int32GetDatum((int32) newval);
break; break;
case INT8OID: case INT8OID:
*op->resvalue = Int64GetDatum((int64) newval); *op->resvalue = Int64GetDatum(newval);
break; break;
default: default:
elog(ERROR, "unsupported sequence type %u", elog(ERROR, "unsupported sequence type %u",

@ -856,7 +856,7 @@ ExecInitPartitionInfo(ModifyTableState *mtstate, EState *estate,
&found_whole_row); &found_whole_row);
/* We ignore the value of found_whole_row. */ /* We ignore the value of found_whole_row. */
onconfl->oc_WhereClause = onconfl->oc_WhereClause =
ExecInitQual((List *) clause, &mtstate->ps); ExecInitQual(clause, &mtstate->ps);
} }
} }
} }

@ -363,7 +363,7 @@ tfuncInitialize(TableFuncScanState *tstate, ExprContext *econtext, Datum doc)
char *ns_uri; char *ns_uri;
char *ns_name; char *ns_name;
value = ExecEvalExpr((ExprState *) expr, econtext, &isnull); value = ExecEvalExpr(expr, econtext, &isnull);
if (isnull) if (isnull)
ereport(ERROR, ereport(ERROR,
(errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED), (errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),

@ -47,8 +47,8 @@ alloc_pool(PlannerInfo *root, int pool_size, int string_length)
/* pool */ /* pool */
new_pool = (Pool *) palloc(sizeof(Pool)); new_pool = (Pool *) palloc(sizeof(Pool));
new_pool->size = (int) pool_size; new_pool->size = pool_size;
new_pool->string_length = (int) string_length; new_pool->string_length = string_length;
/* all chromosome */ /* all chromosome */
new_pool->data = (Chromosome *) palloc(pool_size * sizeof(Chromosome)); new_pool->data = (Chromosome *) palloc(pool_size * sizeof(Chromosome));

@ -3949,7 +3949,7 @@ make_grouping_rel(PlannerInfo *root, RelOptInfo *input_rel,
* target list and HAVING quals are parallel-safe. * target list and HAVING quals are parallel-safe.
*/ */
if (input_rel->consider_parallel && target_parallel_safe && if (input_rel->consider_parallel && target_parallel_safe &&
is_parallel_safe(root, (Node *) havingQual)) is_parallel_safe(root, havingQual))
grouped_rel->consider_parallel = true; grouped_rel->consider_parallel = true;
/* /*
@ -8525,7 +8525,7 @@ create_unique_paths(PlannerInfo *root, RelOptInfo *rel, SpecialJoinInfo *sjinfo)
tle = tlist_member(uniqexpr, newtlist); tle = tlist_member(uniqexpr, newtlist);
if (!tle) if (!tle)
{ {
tle = makeTargetEntry((Expr *) uniqexpr, tle = makeTargetEntry(uniqexpr,
nextresno, nextresno,
NULL, NULL,
false); false);

@ -3865,7 +3865,7 @@ reparameterize_path(PlannerInfo *root, Path *path,
case T_SeqScan: case T_SeqScan:
return create_seqscan_path(root, rel, required_outer, 0); return create_seqscan_path(root, rel, required_outer, 0);
case T_SampleScan: case T_SampleScan:
return (Path *) create_samplescan_path(root, rel, required_outer); return create_samplescan_path(root, rel, required_outer);
case T_IndexScan: case T_IndexScan:
case T_IndexOnlyScan: case T_IndexOnlyScan:
{ {

@ -429,7 +429,7 @@ transformStmt(ParseState *pstate, Node *parseTree)
*/ */
result = makeNode(Query); result = makeNode(Query);
result->commandType = CMD_UTILITY; result->commandType = CMD_UTILITY;
result->utilityStmt = (Node *) parseTree; result->utilityStmt = parseTree;
break; break;
} }

@ -327,7 +327,7 @@ transformExprRecurse(ParseState *pstate, Node *expr)
case T_CaseTestExpr: case T_CaseTestExpr:
case T_Var: case T_Var:
{ {
result = (Node *) expr; result = expr;
break; break;
} }
@ -4079,7 +4079,7 @@ transformJsonParseArg(ParseState *pstate, Node *jsexpr, JsonFormat *format,
if (*exprtype == UNKNOWNOID || typcategory == TYPCATEGORY_STRING) if (*exprtype == UNKNOWNOID || typcategory == TYPCATEGORY_STRING)
{ {
expr = coerce_to_target_type(pstate, (Node *) expr, *exprtype, expr = coerce_to_target_type(pstate, expr, *exprtype,
TEXTOID, -1, TEXTOID, -1,
COERCION_IMPLICIT, COERCION_IMPLICIT,
COERCE_IMPLICIT_CAST, -1); COERCE_IMPLICIT_CAST, -1);

@ -206,7 +206,7 @@ InternalIpcMemoryCreate(IpcMemoryKey memKey, Size size)
*/ */
if (shmctl(shmid, IPC_RMID, NULL) < 0) if (shmctl(shmid, IPC_RMID, NULL) < 0)
elog(LOG, "shmctl(%d, %d, 0) failed: %m", elog(LOG, "shmctl(%d, %d, 0) failed: %m",
(int) shmid, IPC_RMID); shmid, IPC_RMID);
} }
} }

@ -3074,7 +3074,7 @@ InitWalSenderSlot(void)
SpinLockRelease(&walsnd->mutex); SpinLockRelease(&walsnd->mutex);
/* don't need the lock anymore */ /* don't need the lock anymore */
MyWalSnd = (WalSnd *) walsnd; MyWalSnd = walsnd;
break; break;
} }

@ -3784,7 +3784,7 @@ rewriteTargetView(Query *parsetree, Relation view)
parsetree->hasSubLinks = checkExprHasSubLink(viewqual); parsetree->hasSubLinks = checkExprHasSubLink(viewqual);
} }
else else
AddQual(parsetree, (Node *) viewqual); AddQual(parsetree, viewqual);
} }
/* /*

@ -785,7 +785,7 @@ dependency_is_compatible_clause(Node *clause, Index relid, AttrNumber *attnum)
* A boolean expression "x" can be interpreted as "x = true", so * A boolean expression "x" can be interpreted as "x = true", so
* proceed with seeing if it's a suitable Var. * proceed with seeing if it's a suitable Var.
*/ */
clause_expr = (Node *) clause; clause_expr = clause;
} }
/* /*
@ -1212,7 +1212,7 @@ dependency_is_compatible_expression(Node *clause, Index relid, List *statlist, N
* A boolean expression "x" can be interpreted as "x = true", so * A boolean expression "x" can be interpreted as "x = true", so
* proceed with seeing if it's a suitable Var. * proceed with seeing if it's a suitable Var.
*/ */
clause_expr = (Node *) clause; clause_expr = clause;
} }
/* /*

@ -2054,13 +2054,13 @@ examine_opclause_args(List *args, Node **exprp, Const **cstp,
if (IsA(rightop, Const)) if (IsA(rightop, Const))
{ {
expr = (Node *) leftop; expr = leftop;
cst = (Const *) rightop; cst = (Const *) rightop;
expronleft = true; expronleft = true;
} }
else if (IsA(leftop, Const)) else if (IsA(leftop, Const))
{ {
expr = (Node *) rightop; expr = rightop;
cst = (Const *) leftop; cst = (Const *) leftop;
expronleft = false; expronleft = false;
} }

@ -1037,7 +1037,7 @@ statext_mcv_deserialize(bytea *data)
/* pointer to the data part (skip the varlena header) */ /* pointer to the data part (skip the varlena header) */
raw = (char *) data; raw = (char *) data;
ptr = VARDATA_ANY(raw); ptr = VARDATA_ANY(raw);
endptr = (char *) raw + VARSIZE_ANY(data); endptr = raw + VARSIZE_ANY(data);
/* get the header and perform further sanity checks */ /* get the header and perform further sanity checks */
memcpy(&mcvlist->magic, ptr, sizeof(uint32)); memcpy(&mcvlist->magic, ptr, sizeof(uint32));

@ -603,7 +603,7 @@ pgaio_io_wait(PgAioHandle *ioh, uint64 ref_generation)
if (pgaio_io_was_recycled(ioh, ref_generation, &state)) if (pgaio_io_was_recycled(ioh, ref_generation, &state))
return; return;
switch ((PgAioHandleState) state) switch (state)
{ {
case PGAIO_HS_IDLE: case PGAIO_HS_IDLE:
case PGAIO_HS_HANDED_OUT: case PGAIO_HS_HANDED_OUT:
@ -908,7 +908,7 @@ static const char *
pgaio_io_state_get_name(PgAioHandleState s) pgaio_io_state_get_name(PgAioHandleState s)
{ {
#define PGAIO_HS_TOSTR_CASE(sym) case PGAIO_HS_##sym: return #sym #define PGAIO_HS_TOSTR_CASE(sym) case PGAIO_HS_##sym: return #sym
switch ((PgAioHandleState) s) switch (s)
{ {
PGAIO_HS_TOSTR_CASE(IDLE); PGAIO_HS_TOSTR_CASE(IDLE);
PGAIO_HS_TOSTR_CASE(HANDED_OUT); PGAIO_HS_TOSTR_CASE(HANDED_OUT);
@ -933,7 +933,7 @@ pgaio_io_get_state_name(PgAioHandle *ioh)
const char * const char *
pgaio_result_status_string(PgAioResultStatus rs) pgaio_result_status_string(PgAioResultStatus rs)
{ {
switch ((PgAioResultStatus) rs) switch (rs)
{ {
case PGAIO_RS_UNKNOWN: case PGAIO_RS_UNKNOWN:
return "UNKNOWN"; return "UNKNOWN";

@ -300,7 +300,7 @@ pgaio_uring_shmem_init(bool first_time)
if (pgaio_uring_caps.mem_init_size > 0) if (pgaio_uring_caps.mem_init_size > 0)
{ {
ring_mem_remain = pgaio_uring_ring_shmem_size(); ring_mem_remain = pgaio_uring_ring_shmem_size();
ring_mem_next = (char *) shmem; ring_mem_next = shmem;
/* align to page boundary, see also pgaio_uring_ring_shmem_size() */ /* align to page boundary, see also pgaio_uring_ring_shmem_size() */
ring_mem_next = (char *) TYPEALIGN(sysconf(_SC_PAGESIZE), ring_mem_next); ring_mem_next = (char *) TYPEALIGN(sysconf(_SC_PAGESIZE), ring_mem_next);

@ -1477,7 +1477,7 @@ WaitEventSetWaitBlock(WaitEventSet *set, int cur_timeout,
struct pollfd *cur_pollfd; struct pollfd *cur_pollfd;
/* Sleep */ /* Sleep */
rc = poll(set->pollfds, set->nevents, (int) cur_timeout); rc = poll(set->pollfds, set->nevents, cur_timeout);
/* Check return code */ /* Check return code */
if (rc < 0) if (rc < 0)

@ -4988,7 +4988,7 @@ predicatelock_twophase_recover(FullTransactionId fxid, uint16 info,
HASH_ENTER, &found); HASH_ENTER, &found);
Assert(sxid != NULL); Assert(sxid != NULL);
Assert(!found); Assert(!found);
sxid->myXact = (SERIALIZABLEXACT *) sxact; sxid->myXact = sxact;
/* /*
* Update global xmin. Note that this is a special case compared to * Update global xmin. Note that this is a special case compared to

@ -244,7 +244,7 @@ InitProcGlobal(void)
MemSet(ptr, 0, requestSize); MemSet(ptr, 0, requestSize);
procs = (PGPROC *) ptr; procs = (PGPROC *) ptr;
ptr = (char *) ptr + TotalProcs * sizeof(PGPROC); ptr = ptr + TotalProcs * sizeof(PGPROC);
ProcGlobal->allProcs = procs; ProcGlobal->allProcs = procs;
/* XXX allProcCount isn't really all of them; it excludes prepared xacts */ /* XXX allProcCount isn't really all of them; it excludes prepared xacts */
@ -258,13 +258,13 @@ InitProcGlobal(void)
* how hotly they are accessed. * how hotly they are accessed.
*/ */
ProcGlobal->xids = (TransactionId *) ptr; ProcGlobal->xids = (TransactionId *) ptr;
ptr = (char *) ptr + (TotalProcs * sizeof(*ProcGlobal->xids)); ptr = ptr + (TotalProcs * sizeof(*ProcGlobal->xids));
ProcGlobal->subxidStates = (XidCacheStatus *) ptr; ProcGlobal->subxidStates = (XidCacheStatus *) ptr;
ptr = (char *) ptr + (TotalProcs * sizeof(*ProcGlobal->subxidStates)); ptr = ptr + (TotalProcs * sizeof(*ProcGlobal->subxidStates));
ProcGlobal->statusFlags = (uint8 *) ptr; ProcGlobal->statusFlags = (uint8 *) ptr;
ptr = (char *) ptr + (TotalProcs * sizeof(*ProcGlobal->statusFlags)); ptr = ptr + (TotalProcs * sizeof(*ProcGlobal->statusFlags));
/* make sure wer didn't overflow */ /* make sure wer didn't overflow */
Assert((ptr > (char *) procs) && (ptr <= (char *) procs + requestSize)); Assert((ptr > (char *) procs) && (ptr <= (char *) procs + requestSize));

@ -2257,7 +2257,7 @@ array_set_element(Datum arraydatum,
resultarray = (char *) palloc(arraytyplen); resultarray = (char *) palloc(arraytyplen);
memcpy(resultarray, DatumGetPointer(arraydatum), arraytyplen); memcpy(resultarray, DatumGetPointer(arraydatum), arraytyplen);
elt_ptr = (char *) resultarray + indx[0] * elmlen; elt_ptr = resultarray + indx[0] * elmlen;
ArrayCastAndSet(dataValue, elmlen, elmbyval, elmalign, elt_ptr); ArrayCastAndSet(dataValue, elmlen, elmbyval, elmalign, elt_ptr);
return PointerGetDatum(resultarray); return PointerGetDatum(resultarray);
} }
@ -2418,7 +2418,7 @@ array_set_element(Datum arraydatum,
olditemlen = att_addlength_pointer(0, elmlen, elt_ptr); olditemlen = att_addlength_pointer(0, elmlen, elt_ptr);
olditemlen = att_align_nominal(olditemlen, elmalign); olditemlen = att_align_nominal(olditemlen, elmalign);
} }
lenafter = (int) (olddatasize - lenbefore - olditemlen); lenafter = olddatasize - lenbefore - olditemlen;
} }
if (isNull) if (isNull)

@ -5414,8 +5414,7 @@ setPathObject(JsonbIterator **it, const Datum *path_elems, const bool *path_null
newkey.val.string.len = VARSIZE_ANY_EXHDR(pathelem); newkey.val.string.len = VARSIZE_ANY_EXHDR(pathelem);
(void) pushJsonbValue(st, WJB_KEY, &newkey); (void) pushJsonbValue(st, WJB_KEY, &newkey);
(void) push_path(st, level, path_elems, path_nulls, push_path(st, level, path_elems, path_nulls, path_len, newval);
path_len, newval);
/* Result is closed with WJB_END_OBJECT outside of this function */ /* Result is closed with WJB_END_OBJECT outside of this function */
} }
@ -5583,8 +5582,7 @@ setPathArray(JsonbIterator **it, const Datum *path_elems, const bool *path_nulls
if (idx > 0) if (idx > 0)
push_null_elements(st, idx - nelems); push_null_elements(st, idx - nelems);
(void) push_path(st, level, path_elems, path_nulls, push_path(st, level, path_elems, path_nulls, path_len, newval);
path_len, newval);
/* Result is closed with WJB_END_OBJECT outside of this function */ /* Result is closed with WJB_END_OBJECT outside of this function */
} }

@ -10151,7 +10151,7 @@ get_rule_expr(Node *node, deparse_context *context,
if (needcomma) if (needcomma)
appendStringInfoString(buf, ", "); appendStringInfoString(buf, ", ");
get_rule_expr((Node *) e, context, true); get_rule_expr(e, context, true);
appendStringInfo(buf, " AS %s", appendStringInfo(buf, " AS %s",
quote_identifier(map_xml_name_to_sql_identifier(argname))); quote_identifier(map_xml_name_to_sql_identifier(argname)));
needcomma = true; needcomma = true;

@ -2182,7 +2182,7 @@ selectDumpableCast(CastInfo *cast, Archive *fout)
* This would be DUMP_COMPONENT_ACL for from-initdb casts, but they do not * This would be DUMP_COMPONENT_ACL for from-initdb casts, but they do not
* support ACLs currently. * support ACLs currently.
*/ */
if (cast->dobj.catId.oid <= (Oid) g_last_builtin_oid) if (cast->dobj.catId.oid <= g_last_builtin_oid)
cast->dobj.dump = DUMP_COMPONENT_NONE; cast->dobj.dump = DUMP_COMPONENT_NONE;
else else
cast->dobj.dump = fout->dopt->include_everything ? cast->dobj.dump = fout->dopt->include_everything ?
@ -2214,7 +2214,7 @@ selectDumpableProcLang(ProcLangInfo *plang, Archive *fout)
plang->dobj.dump = DUMP_COMPONENT_NONE; plang->dobj.dump = DUMP_COMPONENT_NONE;
else else
{ {
if (plang->dobj.catId.oid <= (Oid) g_last_builtin_oid) if (plang->dobj.catId.oid <= g_last_builtin_oid)
plang->dobj.dump = fout->remoteVersion < 90600 ? plang->dobj.dump = fout->remoteVersion < 90600 ?
DUMP_COMPONENT_NONE : DUMP_COMPONENT_ACL; DUMP_COMPONENT_NONE : DUMP_COMPONENT_ACL;
else else
@ -2247,7 +2247,7 @@ selectDumpableAccessMethod(AccessMethodInfo *method, Archive *fout)
* This would be DUMP_COMPONENT_ACL for from-initdb access methods, but * This would be DUMP_COMPONENT_ACL for from-initdb access methods, but
* they do not support ACLs currently. * they do not support ACLs currently.
*/ */
if (method->dobj.catId.oid <= (Oid) g_last_builtin_oid) if (method->dobj.catId.oid <= g_last_builtin_oid)
method->dobj.dump = DUMP_COMPONENT_NONE; method->dobj.dump = DUMP_COMPONENT_NONE;
else else
method->dobj.dump = fout->dopt->include_everything ? method->dobj.dump = fout->dopt->include_everything ?
@ -2273,7 +2273,7 @@ selectDumpableExtension(ExtensionInfo *extinfo, DumpOptions *dopt)
* change permissions on their member objects, if they wish to, and have * change permissions on their member objects, if they wish to, and have
* those changes preserved. * those changes preserved.
*/ */
if (extinfo->dobj.catId.oid <= (Oid) g_last_builtin_oid) if (extinfo->dobj.catId.oid <= g_last_builtin_oid)
extinfo->dobj.dump = extinfo->dobj.dump_contains = DUMP_COMPONENT_ACL; extinfo->dobj.dump = extinfo->dobj.dump_contains = DUMP_COMPONENT_ACL;
else else
{ {

@ -277,7 +277,7 @@ sha1_result(uint8 *digest0, pg_sha1_ctx *ctx)
{ {
uint8 *digest; uint8 *digest;
digest = (uint8 *) digest0; digest = digest0;
#ifdef WORDS_BIGENDIAN #ifdef WORDS_BIGENDIAN
memmove(digest, &ctx->h.b8[0], 20); memmove(digest, &ctx->h.b8[0], 20);
@ -337,7 +337,7 @@ pg_sha1_update(pg_sha1_ctx *ctx, const uint8 *data, size_t len)
size_t off; size_t off;
size_t copysiz; size_t copysiz;
input = (const uint8 *) data; input = data;
off = 0; off = 0;
while (off < len) while (off < len)

@ -113,7 +113,7 @@ get_int_item(int lineno, void *var, enum ECPGttype vartype, int value)
*(short *) var = (short) value; *(short *) var = (short) value;
break; break;
case ECPGt_int: case ECPGt_int:
*(int *) var = (int) value; *(int *) var = value;
break; break;
case ECPGt_long: case ECPGt_long:
*(long *) var = (long) value; *(long *) var = (long) value;

@ -54,7 +54,7 @@ quote_postgres(char *arg, bool quote, int lineno)
{ {
length = strlen(arg); length = strlen(arg);
buffer_len = 2 * length + 1; buffer_len = 2 * length + 1;
res = (char *) ecpg_alloc(buffer_len + 3, lineno); res = ecpg_alloc(buffer_len + 3, lineno);
if (!res) if (!res)
return res; return res;
escaped_len = PQescapeString(res + 1, arg, buffer_len); escaped_len = PQescapeString(res + 1, arg, buffer_len);
@ -263,7 +263,7 @@ ecpg_is_type_an_array(int type, const struct statement *stmt, const struct varia
return cache_entry->isarray; return cache_entry->isarray;
} }
array_query = (char *) ecpg_alloc(strlen("select typlen from pg_type where oid= and typelem<>0") + 11, stmt->lineno); array_query = ecpg_alloc(strlen("select typlen from pg_type where oid= and typelem<>0") + 11, stmt->lineno);
if (array_query == NULL) if (array_query == NULL)
return ECPG_ARRAY_ERROR; return ECPG_ARRAY_ERROR;
@ -391,7 +391,7 @@ ecpg_store_result(const PGresult *results, int act_field,
} }
ecpg_log("ecpg_store_result on line %d: allocating memory for %d tuples\n", stmt->lineno, ntuples); ecpg_log("ecpg_store_result on line %d: allocating memory for %d tuples\n", stmt->lineno, ntuples);
var->value = (char *) ecpg_auto_alloc(len, stmt->lineno); var->value = ecpg_auto_alloc(len, stmt->lineno);
if (!var->value) if (!var->value)
return false; return false;
*((char **) var->pointer) = var->value; *((char **) var->pointer) = var->value;
@ -402,7 +402,7 @@ ecpg_store_result(const PGresult *results, int act_field,
{ {
int len = var->ind_offset * ntuples; int len = var->ind_offset * ntuples;
var->ind_value = (char *) ecpg_auto_alloc(len, stmt->lineno); var->ind_value = ecpg_auto_alloc(len, stmt->lineno);
if (!var->ind_value) if (!var->ind_value)
return false; return false;
*((char **) var->ind_pointer) = var->ind_value; *((char **) var->ind_pointer) = var->ind_value;
@ -822,7 +822,7 @@ ecpg_store_input(const int lineno, const bool force_indicator, const struct vari
struct ECPGgeneric_bytea *variable = struct ECPGgeneric_bytea *variable =
(struct ECPGgeneric_bytea *) (var->value); (struct ECPGgeneric_bytea *) (var->value);
if (!(mallocedval = (char *) ecpg_alloc(variable->len, lineno))) if (!(mallocedval = ecpg_alloc(variable->len, lineno)))
return false; return false;
memcpy(mallocedval, variable->arr, variable->len); memcpy(mallocedval, variable->arr, variable->len);
@ -835,7 +835,7 @@ ecpg_store_input(const int lineno, const bool force_indicator, const struct vari
struct ECPGgeneric_varchar *variable = struct ECPGgeneric_varchar *variable =
(struct ECPGgeneric_varchar *) (var->value); (struct ECPGgeneric_varchar *) (var->value);
if (!(newcopy = (char *) ecpg_alloc(variable->len + 1, lineno))) if (!(newcopy = ecpg_alloc(variable->len + 1, lineno)))
return false; return false;
strncpy(newcopy, variable->arr, variable->len); strncpy(newcopy, variable->arr, variable->len);
@ -1128,9 +1128,7 @@ insert_tobeinserted(int position, int ph_len, struct statement *stmt, char *tobe
{ {
char *newcopy; char *newcopy;
if (!(newcopy = (char *) ecpg_alloc(strlen(stmt->command) if (!(newcopy = ecpg_alloc(strlen(stmt->command) + strlen(tobeinserted) + 1, stmt->lineno)))
+ strlen(tobeinserted)
+ 1, stmt->lineno)))
{ {
ecpg_free(tobeinserted); ecpg_free(tobeinserted);
return false; return false;
@ -1536,7 +1534,7 @@ ecpg_build_params(struct statement *stmt)
int buffersize = sizeof(int) * CHAR_BIT * 10 / 3; /* a rough guess of the int buffersize = sizeof(int) * CHAR_BIT * 10 / 3; /* a rough guess of the
* size we need */ * size we need */
if (!(tobeinserted = (char *) ecpg_alloc(buffersize, stmt->lineno))) if (!(tobeinserted = ecpg_alloc(buffersize, stmt->lineno)))
{ {
ecpg_free_params(stmt, false); ecpg_free_params(stmt, false);
return false; return false;

@ -138,14 +138,14 @@ replace_variables(char **text, int lineno)
char *buffer, char *buffer,
*newcopy; *newcopy;
if (!(buffer = (char *) ecpg_alloc(buffersize, lineno))) if (!(buffer = ecpg_alloc(buffersize, lineno)))
return false; return false;
snprintf(buffer, buffersize, "$%d", counter++); snprintf(buffer, buffersize, "$%d", counter++);
for (len = 1; (*text)[ptr + len] && isvarchar((*text)[ptr + len]); len++) for (len = 1; (*text)[ptr + len] && isvarchar((*text)[ptr + len]); len++)
/* skip */ ; /* skip */ ;
if (!(newcopy = (char *) ecpg_alloc(strlen(*text) - len + strlen(buffer) + 1, lineno))) if (!(newcopy = ecpg_alloc(strlen(*text) - len + strlen(buffer) + 1, lineno)))
{ {
ecpg_free(buffer); ecpg_free(buffer);
return false; return false;
@ -302,7 +302,7 @@ deallocate_one(int lineno, enum COMPAT_MODE c, struct connection *con,
char *text; char *text;
PGresult *query; PGresult *query;
text = (char *) ecpg_alloc(strlen("deallocate \"\" ") + strlen(this->name), this->stmt->lineno); text = ecpg_alloc(strlen("deallocate \"\" ") + strlen(this->name), this->stmt->lineno);
if (text) if (text)
{ {

@ -62,7 +62,7 @@ initialize_ntdll(void)
return -1; return -1;
} }
*(pg_funcptr_t *) routines[i].address = address; *routines[i].address = address;
} }
initialized = true; initialized = true;

@ -219,7 +219,7 @@ test_basic(rt_node_class_test_elem *test_info, int shift, bool asc)
TestValueType update = keys[i] + 1; TestValueType update = keys[i] + 1;
/* rt_set should report the key found */ /* rt_set should report the key found */
EXPECT_TRUE(rt_set(radixtree, keys[i], (TestValueType *) &update)); EXPECT_TRUE(rt_set(radixtree, keys[i], &update));
} }
/* delete and re-insert keys */ /* delete and re-insert keys */

Loading…
Cancel
Save