HSTORE_VALLEN(entries, i));
if (IsValidJsonNumber(tmp.data, tmp.len))
{
+ Datum numd;
+
val.type = jbvNumeric;
- val.val.numeric = DatumGetNumeric(
- DirectFunctionCall3(numeric_in,
- CStringGetDatum(tmp.data), 0, -1));
+ numd = DirectFunctionCall3(numeric_in,
+ CStringGetDatum(tmp.data),
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
+ val.val.numeric = DatumGetNumeric(numd);
}
else
{
PG_TRY();
{
- num = DatumGetNumeric(DirectFunctionCall3(numeric_in,
- CStringGetDatum(str), 0, -1));
+ Datum numd;
+
+ numd = DirectFunctionCall3(numeric_in,
+ CStringGetDatum(str),
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
+ num = DatumGetNumeric(numd);
}
PG_CATCH();
{
{
LWLockRelease(&apw_state->lock);
ereport(LOG,
- (errmsg("autoprewarm worker is already running under PID %d",
- apw_state->bgworker_pid)));
+ (errmsg("autoprewarm worker is already running under PID %lu",
+ (unsigned long) apw_state->bgworker_pid)));
return;
}
apw_state->bgworker_pid = MyProcPid;
{
LWLockRelease(&apw_state->lock);
ereport(LOG,
- (errmsg("skipping prewarm because block dump file is being written by PID %d",
- apw_state->pid_using_dumpfile)));
+ (errmsg("skipping prewarm because block dump file is being written by PID %lu",
+ (unsigned long) apw_state->pid_using_dumpfile)));
return;
}
LWLockRelease(&apw_state->lock);
{
if (!is_bgworker)
ereport(ERROR,
- (errmsg("could not perform block dump because dump file is being used by PID %d",
- apw_state->pid_using_dumpfile)));
+ (errmsg("could not perform block dump because dump file is being used by PID %lu",
+ (unsigned long) apw_state->pid_using_dumpfile)));
ereport(LOG,
- (errmsg("skipping block dump because it is already being performed by PID %d",
- apw_state->pid_using_dumpfile)));
+ (errmsg("skipping block dump because it is already being performed by PID %lu",
+ (unsigned long) apw_state->pid_using_dumpfile)));
return 0;
}
if (pid != InvalidPid)
ereport(ERROR,
(errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
- errmsg("autoprewarm worker is already running under PID %d",
- pid)));
+ errmsg("autoprewarm worker is already running under PID %lu",
+ (unsigned long) pid)));
apw_start_master_worker();
char tempdirpath[MAXPGPATH];
TempTablespacePath(tempdirpath, tablespace);
- snprintf(path, MAXPGPATH, "%s/%s%d.%u.sharedfileset",
+ snprintf(path, MAXPGPATH, "%s/%s%lu.%u.sharedfileset",
tempdirpath, PG_TEMP_FILE_PREFIX,
- fileset->creator_pid, fileset->number);
+ (unsigned long) fileset->creator_pid, fileset->number);
}
/*
{
JsonbInState *_state = (JsonbInState *) pstate;
JsonbValue v;
+ Datum numd;
switch (tokentype)
{
*/
Assert(token != NULL);
v.type = jbvNumeric;
- v.val.numeric = DatumGetNumeric(DirectFunctionCall3(numeric_in, CStringGetDatum(token), 0, -1));
-
+ numd = DirectFunctionCall3(numeric_in,
+ CStringGetDatum(token),
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
+ v.val.numeric = DatumGetNumeric(numd);
break;
case JSON_TOKEN_TRUE:
v.type = jbvBool;
v.val.boolean = true;
-
break;
case JSON_TOKEN_FALSE:
v.type = jbvBool;
v.val.boolean = false;
-
break;
case JSON_TOKEN_NULL:
v.type = jbvNull;
strchr(outputstr, 'n') != NULL);
if (!numeric_error)
{
- jb.type = jbvNumeric;
- jb.val.numeric = DatumGetNumeric(DirectFunctionCall3(numeric_in, CStringGetDatum(outputstr), 0, -1));
+ Datum numd;
+ jb.type = jbvNumeric;
+ numd = DirectFunctionCall3(numeric_in,
+ CStringGetDatum(outputstr),
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
+ jb.val.numeric = DatumGetNumeric(numd);
pfree(outputstr);
}
else
/* sumX */
temp = DirectFunctionCall3(numeric_recv,
PointerGetDatum(&buf),
- InvalidOid,
- -1);
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
init_var_from_num(DatumGetNumeric(temp), &tmp_var);
accum_sum_add(&(result->sumX), &tmp_var);
/* sumX */
temp = DirectFunctionCall3(numeric_recv,
PointerGetDatum(&buf),
- InvalidOid,
- -1);
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
init_var_from_num(DatumGetNumeric(temp), &sumX_var);
accum_sum_add(&(result->sumX), &sumX_var);
/* sumX2 */
temp = DirectFunctionCall3(numeric_recv,
PointerGetDatum(&buf),
- InvalidOid,
- -1);
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
init_var_from_num(DatumGetNumeric(temp), &sumX2_var);
accum_sum_add(&(result->sumX2), &sumX2_var);
/* sumX */
sumX = DirectFunctionCall3(numeric_recv,
PointerGetDatum(&buf),
- InvalidOid,
- -1);
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
/* sumX2 */
sumX2 = DirectFunctionCall3(numeric_recv,
PointerGetDatum(&buf),
- InvalidOid,
- -1);
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
init_var_from_num(DatumGetNumeric(sumX), &sumX_var);
#ifdef HAVE_INT128
/* sumX */
temp = DirectFunctionCall3(numeric_recv,
PointerGetDatum(&buf),
- InvalidOid,
- -1);
+ ObjectIdGetDatum(InvalidOid),
+ Int32GetDatum(-1));
init_var_from_num(DatumGetNumeric(temp), &num);
#ifdef HAVE_INT128
numericvar_to_int128(&num, &result->sumX);
*/
nulls[12] = true;
nulls[13] = true;
- values[14] = DatumGetInt32(-1);
+ values[14] = Int32GetDatum(-1);
}
else
{
if (varsourcefile[0])
read_gucstate_binary(&srcptr, srcend,
&varsourceline, sizeof(varsourceline));
+ else
+ varsourceline = 0;
read_gucstate_binary(&srcptr, srcend,
&varsource, sizeof(varsource));
read_gucstate_binary(&srcptr, srcend,