pfree(o);
return out;
-
}
static const gbtree_vinfo tinfo =
penalty_num(result, origentry->lower, origentry->upper, newentry->lower, newentry->upper);
PG_RETURN_POINTER(result);
-
}
Datum
penalty_num(result, origentry->lower, origentry->upper, newentry->lower, newentry->upper);
PG_RETURN_POINTER(result);
-
}
Datum
penalty_num(result, origentry->lower, origentry->upper, newentry->lower, newentry->upper);
PG_RETURN_POINTER(result);
-
}
Datum
penalty_num(result, origentry->lower, origentry->upper, newentry->lower, newentry->upper);
PG_RETURN_POINTER(result);
-
}
Datum
}
PG_RETURN_POINTER(retval);
-
}
Datum
penalty_num(result, iorg[0], iorg[1], inew[0], inew[1]);
PG_RETURN_POINTER(result);
-
}
Datum
penalty_num(result, iorg[0], iorg[1], inew[0], inew[1]);
PG_RETURN_POINTER(result);
-
}
Datum
penalty_num(result, iorg[0], iorg[1], inew[0], inew[1]);
PG_RETURN_POINTER(result);
-
}
Datum
penalty_num(result, orgdbl[0], orgdbl[1], newdbl[0], newdbl[1]);
PG_RETURN_POINTER(result);
-
}
/* clean up GUC settings, if we changed any */
restoreLocalGucs(nestlevel);
-
}
}
PG_FINALLY();
ereport(ERROR,
(errcode(ERRCODE_UNDEFINED_OBJECT),
errmsg("undefined connection name")));
-
}
static void
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("syntax error")));
return ERR;
-
}
}
errmsg("syntax error")));
return ERR;
-
}
}
while (lenstack)
if (qbuffer)
free(qbuffer);
-
}
/* Number of output arguments (columns) for pg_stat_statements_info */
tuplestore_putvalues(rsinfo->setResult, rsinfo->setDesc, values, nulls);
}
-
PG_RETURN_VOID();
}
nv, (is_char_type > 0) ? "'" : "", (k < nkeys) ? ", " : "");
}
strcat(sql, " where ");
-
}
else
/* DELETE */
snprintf(sql, sizeof(sql), "delete from %s where ", relname);
-
}
/*
/* data of the bloom filter */
char data[FLEXIBLE_ARRAY_MEMBER];
-
} BloomFilter;
BufferGetBlockNumber(stack->buffer),
BufferGetBlockNumber(rbuffer));
}
-
}
else
{
{
xlrec.cmin = InvalidCommandId;
xlrec.cmax = HeapTupleHeaderGetRawCommandId(hdr);
-
}
xlrec.combocid = InvalidCommandId;
}
elog(ERROR, "unexpected HeapTupleSatisfiesVacuum result");
break;
}
-
}
vacrel->offnum = InvalidOffsetNumber;
/* split point identifying fields (returned by _bt_findsplitloc) */
OffsetNumber firstrightoff; /* first origpage item on rightpage */
bool newitemonleft; /* new item goes on left, or right? */
-
} SplitPoint;
typedef struct
offsetof(BTOptions, vacuum_cleanup_index_scale_factor)},
{"deduplicate_items", RELOPT_TYPE_BOOL,
offsetof(BTOptions, deduplicate_items)}
-
};
return (bytea *) build_reloptions(reloptions, validate,
RELOPT_KIND_BTREE,
sizeof(BTOptions),
tab, lengthof(tab));
-
}
/*
/* Use generic heapkeyspace pivot tuple handling */
}
-
}
/* Handle heapkeyspace pivot tuples (excluding minus infinity items) */
{
appendStringInfo(buf, "delete: latestRemovedXid %u, nitems: %u",
xlrec->latestRemovedXid, xlrec->ntodelete);
-
}
static void
RELOPT_KIND_SPGIST,
sizeof(SpGistOptions),
tab, lengthof(tab));
-
}
/*
elog(ERROR, "unrecognized table_tuple_update status: %u", result);
break;
}
-
}
/* there are no WAL records following the checkpoint */
ereport(LOG,
(errmsg("redo is not required")));
-
}
/*
address.objectId = get_domain_constraint_oid(domaddr.objectId,
constrname, missing_ok);
address.objectSubId = 0;
-
}
break;
case OBJECT_DATABASE:
systable_endscan(rcscan);
table_close(defaclrel, AccessShareLock);
break;
-
}
defacl = (Form_pg_default_acl) GETSTRUCT(tup);
if (!missingIsNull)
pfree(DatumGetPointer(missingval));
-
}
table_close(attrrel, RowExclusiveLock);
heap_freetuple(atttup);
FmgrInfo *out_functions; /* lookup info for output functions */
MemoryContext rowcontext; /* per-row evaluation context */
uint64 bytes_processed; /* number of bytes processed so far */
-
} CopyToStateData;
/* DestReceiver for COPY (query) TO */
*/
if (slotname)
ReplicationSlotDropAtPubNode(wrconn, slotname, false);
-
}
PG_FINALLY();
{
ereport(ERROR,
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("specifying a table access method is not supported on a partitioned table")));
-
}
else if (RELKIND_HAS_TABLE_AM(relkind))
accessMethod = default_table_access_method;
stmt->relation->inh), /* recursive? */
false, /* recursing? */
0 /* expected inhcount */ );
-
}
/*
errmsg("data type %s has no default operator class for access method \"%s\"",
format_type_be(atttype), "btree"),
errhint("You must specify a btree operator class or define a default btree operator class for the data type.")));
-
}
}
else
paramexec_space = dsa_get_address(area, fpes->param_exec);
RestoreParamExecParams(paramexec_space, queryDesc->estate);
-
}
pwcxt.toc = toc;
pwcxt.seg = seg;
{
skip_tuple = !ExecBRDeleteTriggers(estate, epqstate, resultRelInfo,
tid, NULL, NULL);
-
}
if (!skip_tuple)
2,
InvalidOid,
(void *) aggstate, NULL);
-
}
/*
ExecReScan(node->js.ps.lefttree);
if (node->js.ps.righttree->chgParam == NULL)
ExecReScan(node->js.ps.righttree);
-
}
v_tupleheaderp =
l_load_struct_gep(b, v_heapslot, FIELDNO_HEAPTUPLETABLESLOT_TUPLE,
"tupleheader");
-
}
else if (ops == &TTSOpsMinimalTuple)
{
LLVMAddCase(v_switch, v_attno, attcheckattnoblocks[attnum]);
}
-
}
else
{
"");
LLVMBuildBr(b, opblocks[opno + 1]);
-
}
LLVMPositionBuilderAtEnd(b, b_no_init);
hbaline->pam_use_hostname = true;
else
hbaline->pam_use_hostname = false;
-
}
else if (strcmp(name, "ldapurl") == 0)
{
for (i = 0; i < num_gene; i++)
if (tour1[i] != offspring[i])
num_diffs++;
-
}
return num_diffs;
/* mark this node as incorporated */
edge_table[(int) new_gene[i - 1]].unused_edges = -1;
-
} /* for (i=1; i<num_gene; i++) */
return edge_failures;
-
}
/* remove_gene
elog(ERROR, "minimum_count not set");
else if (edge_table[(int) friend].unused_edges == minimum_edges)
minimum_count++;
-
} /* for (i=0; i<edge.unused_edges; i++) */
}
p = (p + 1) % num_gene; /* increment tour2-index */
}
-
}
#endif /* defined(OX1) */
/* city isn't used yet, so inherit from tour2 */
offspring[k] = tour2[k];
}
-
}
#endif /* defined(OX2) */
j++;
}
-
}
if (!(found))
indx[mx_fail] = k;
mx_fail++;
}
-
} /* ... for */
j++;
}
-
} /* ... for */
-
} /* ... if */
j++;
}
-
} /* ... if */
i++;
} /* end while */
-
}
} /* ... for */
{ /* next city in tour2 has been used */
tour2_index++;
}
-
}
else
{ /* next position in offspring is filled */
offspring_index++;
}
-
}
-
}
#endif /* defined(PX) */
dNumPartialGroups));
}
}
-
}
if (can_sort && cheapest_partial_path != NULL)
if (start_time == BgWorkerStart_PostmasterStart)
return true;
/* fall through */
-
}
return false;
ereport(ERROR,
(errcode(ERRCODE_READ_ONLY_SQL_TRANSACTION),
errmsg("cannot manipulate replication origins during recovery")));
-
}
* records so incremental cleanup can be performed.
*/
return true;
-
}
/* ---
defmap[num_defaults] = attnum;
num_defaults++;
}
-
}
for (i = 0; i < num_defaults; i++)
}
ReleaseSysCache(cftuple);
- } /* loop all subscribed publications */
-
+ } /* loop all subscribed publications */
}
/*
(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
errmsg("unrecognized value for CREATE_REPLICATION_SLOT option \"%s\": \"%s\"",
defel->defname, action)));
-
}
else if (strcmp(defel->defname, "reserve_wal") == 0)
{
{
pfree(state->dependencies);
pfree(state);
-
}
/* generate next combination */
PrintBufferLeakWarning(res->buffer);
RefCountErrors++;
}
-
}
Assert(RefCountErrors == 0);
break;
}
}
-
}
else
{
return buf;
}
UnlockBufHdr(buf, local_buf_state);
-
}
}
* session's temporary tables.
*/
TransactionId temp_oldest_nonremovable;
-
} ComputeXidHorizonsResult;
/*
/* Catalog tables need to consider all backends in this db */
h->catalog_oldest_nonremovable =
TransactionIdOlder(h->catalog_oldest_nonremovable, xmin);
-
}
}
#ifdef LOCK_DEBUG
pg_atomic_fetch_add_u32(&lock->nwaiters, 1);
#endif
-
}
/*
/* update the line pointer to reference the new offset */
lp->lp_off = upper;
-
}
/* move the remaining tuples. */
/* update the line pointer to reference the new offset */
lp->lp_off = upper;
-
}
/* Copy the remaining chunk */
HASH_ELEM | HASH_BLOBS | HASH_CONTEXT);
pendingUnlinks = NIL;
}
-
}
/*
}
else
pq_putemptymessage('n'); /* NoData */
-
}
/*
lev = LOGSTMT_ALL;
break;
}
-
}
break;
}
pfree(prs.words);
-
}
else
pushStop(state);
PG_RETURN_DATUM(DirectFunctionCall2(websearch_to_tsquery_byid,
ObjectIdGetDatum(cfgId),
PointerGetDatum(in)));
-
}
else
addHLParsedLex(prs, query, lexs, NULL);
} while (norms);
-
} while (type > 0);
FunctionCall1(&(prsobj->prsend), PointerGetDatum(prsdata));
memcpy(ptr, prs->fragdelim, prs->fragdelimlen);
ptr += prs->fragdelimlen;
}
-
}
if (wrd->replace)
{
NULL);
return entry_ref->pending;
-
}
/*
};
return convert_any_priv_string(priv_type_text, database_priv_map);
-
}
pfree(result.data);
PG_RETURN_TEXT_P(rval);
-
}
/*
sem.object_field_start = jsonb_in_object_field_start;
pg_parse_json_or_ereport(lex, &sem);
-
}
break;
case JSONBTYPE_JSONB:
PG_RETURN_TEXT_P(cstring_to_text_with_len(state->strval->data,
state->strval->len));
-
}
/*
*/
range_count3++;
r2 = ++i2 >= range_count2 ? NULL : ranges2[i2];
-
}
else if (range_overlaps_internal(rangetyp, r1, r2))
{
break;
else
r2 = ++i2 >= range_count2 ? NULL : ranges2[i2];
-
}
else
{
target += len;
retlen += len;
}
-
}
else
{
get_rule_expr_paren((Node *) xexpr->args, context, false, node);
break;
}
-
}
if (xexpr->op == IS_XMLSERIALIZE)
appendStringInfo(buf, " AS %s",
*/
if (estinfo != NULL && varinfo2->isdefault)
estinfo->flags |= SELFLAG_USED_DEFAULT;
-
}
/* we're done with this relation */
lowunits, format_type_be(TIMESTAMPOID))));
intresult = 0;
}
-
}
else
{
lowunits, format_type_be(TIMESTAMPTZOID))));
intresult = 0;
}
-
}
else if (type == RESERV)
{
else
pnode->right = node;
}
-
}
else
{
* we'd better do so before we start marking the members as belonging
* to the list.
*/
-
}
PG_CATCH();
{
att->attbyval,
att->attlen);
}
-
}
/*
appendStringInfo(buf, "%*s", padding, psdisp);
else
appendBinaryStringInfo(buf, psdisp, displen);
-
}
else if (padding != 0)
appendStringInfoSpaces(buf,
appendStringInfo(buf, "(%s)",
MyProcPort->remote_port);
}
-
}
else if (padding != 0)
appendStringInfoSpaces(buf,
/* checking should not be deferred again */
Assert(!check_wal_consistency_checking_deferred);
}
-
}
/*
block->nchunks = 0;
block->nfree = 0;
block->freeptr = ((char *) block) + Generation_BLOCKHDRSZ;
-
}
/*
* owner. (This needs to run after, e.g., ShutdownXLOG.)
*/
on_shmem_exit(ReleaseAuxProcessResourcesCallback, 0);
-
}
/*
{
stup.srctape = srcTapeIndex;
tuplesort_heap_replace_top(state, &stup);
-
}
else
{
if (!check_locale_encoding(lc_ctype, encodingid) ||
!check_locale_encoding(lc_collate, encodingid))
exit(1); /* check_locale_encoding printed the error */
-
}
printf(_("The default text search configuration will be set to \"%s\".\n"),
default_text_search_config);
-
}
pg_fatal("could not re-open the output file \"%s\": %m",
filename);
}
-
}
PQclear(res);
}
extractPageInfo(xlogreader);
-
} while (xlogreader->EndRecPtr < endpoint);
/*
close(fd);
return;
}
-
-
}
if (rc < 0)
report_backup_error(context, "could not read file \"%s\": %m",
PQgetvalue(result, i, 4));
printTableAddFooter(&cont, buf.data);
-
}
PQclear(result);
}
case 4:
printfPQExpBuffer(&buf, _("Triggers firing on replica only:"));
break;
-
}
printTableAddFooter(&cont, buf.data);
have_heading = true;
buf[0] = *p;
buf[1] = '\0';
break;
-
}
esc = false;
}
lex->token_type = JSON_TOKEN_FALSE;
else
return JSON_INVALID_TOKEN;
-
}
} /* end of switch */
}
lex->token_terminator = s + pg_encoding_mblen_bounded(lex->input_encoding, s);
return JSON_ESCAPING_INVALID;
}
-
}
else if (lex->strval != NULL)
{
appendStringInfoChar(lex->strval, *s);
}
-
}
if (hi_surrogate != -1)
if (opt_border == 2)
fputs(dformat->rightvrule, fout);
fputc('\n', fout);
-
} while (more_lines);
}
ecpg_free(dbname);
dbname = ecpg_strdup(envname, lineno);
}
-
}
if (dbname == NULL && connection_name == NULL)
}
pval += size;
-
}
break;
if (sqlda->sqln == desc_counter)
desc_counter = 0;
}
-
}
else
{
}
return PQtransactionStatus(con->connection);
-
}
bool
{
(*endstr)++;
continue;
-
}
/* otherwise, something is not right... */
else
{
tm->tm_year = span.month / MONTHS_PER_YEAR;
tm->tm_mon = span.month % MONTHS_PER_YEAR;
-
}
else
{
errno = PGTYPES_NUM_BAD_NUMERIC;
return INT_MAX;
-
}
int
{
if (TIMESTAMP_NOT_FINITE(*tin))
*tout = *tin;
-
-
else
{
if (span->month != 0)
*tm = &tt;
fsec_t fsec;
-
if (timestamp2tm(*tin, NULL, tm, &fsec, NULL) != 0)
return -1;
tm->tm_mon += span->month;
return -1;
}
-
*tin += span->time;
*tout = *tin;
}
- return 0;
+ return 0;
}
tspan.month = -span->month;
tspan.time = -span->time;
-
return PGTYPEStimestamp_add_interval(tin, &tspan, tout);
}
(void) connectDBComplete(conn);
return conn;
-
}
/*
for (i = 0; i < trigdata->tg_trigger->tgnargs; i++)
Tcl_ListObjAppendElement(NULL, tcl_cmd,
Tcl_NewStringObj(utf_e2u(trigdata->tg_trigger->tgargs[i]), -1));
-
}
PG_CATCH();
{
strcpy(r, codepage);
}
}
-
}
#endif
}
return strlen(buf);
-
}
projects / users / rhaas / postgres.git / commitdiff