47#define EXPECT_TRUE(expr) \
51 "%s was unexpectedly false in file \"%s\" line %u", \
52 #expr, __FILE__, __LINE__); \
55#define EXPECT_EQ_U32(result_expr, expected_expr) \
57 uint32 actual_result = (result_expr); \
58 uint32 expected_result = (expected_expr); \
59 if (actual_result != expected_result) \
61 "%s yielded %u, expected %s in file \"%s\" line %u", \
62 #result_expr, actual_result, #expected_expr, __FILE__, __LINE__); \
65#define EXPECT_EQ_U64(result_expr, expected_expr) \
67 uint64 actual_result = (result_expr); \
68 uint64 expected_result = (expected_expr); \
69 if (actual_result != expected_result) \
71 "%s yielded " UINT64_FORMAT ", expected %s in file \"%s\" line %u", \
72 #result_expr, actual_result, #expected_expr, __FILE__, __LINE__); \
100 for (
i = 0;
i < p1->
npts - 1 && !found;
i++)
103 for (
j = 0;
j <
p2->npts - 1 && !found;
j++)
131 lseg->
p[0].
x = pt1->
x;
132 lseg->
p[0].
y = pt1->
y;
133 lseg->
p[1].
x = pt2->
x;
134 lseg->
p[1].
y = pt2->
y;
190 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
191 errmsg(
"invalid input syntax for type %s: \"%s\"",
195 result->
center.
x = atof(coord[0]);
196 result->
center.
y = atof(coord[1]);
197 result->
radius = atof(coord[2]);
245 new_string[
len -
i] =
string[
i];
258 elog(
ERROR,
"trigger_return_old: not fired by trigger manager");
265#define TTDUMMY_INFINITY 999999
297 elog(
ERROR,
"ttdummy: not fired by trigger manager");
299 elog(
ERROR,
"ttdummy: must be fired for row");
301 elog(
ERROR,
"ttdummy: must be fired before event");
303 elog(
ERROR,
"ttdummy: cannot process INSERT event");
321 if (trigger->tgnargs != 2)
322 elog(
ERROR,
"ttdummy (%s): invalid (!= 2) number of arguments %d",
325 args = trigger->tgargs;
326 tupdesc = rel->rd_att;
327 natts = tupdesc->natts;
329 for (
i = 0;
i < 2;
i++)
333 elog(
ERROR,
"ttdummy (%s): there is no attribute %s",
336 elog(
ERROR,
"ttdummy (%s): attribute %s must be of integer type",
348 if (newtuple != NULL)
357 if (oldon != newon || oldoff != newoff)
359 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
360 errmsg(
"ttdummy (%s): you cannot change %s and/or %s columns (use set_ttdummy)",
384 cnulls = (
char *)
palloc(natts *
sizeof(
char));
385 for (
i = 0;
i < natts;
i++)
387 cvals[
i] =
SPI_getbinval((newtuple != NULL) ? newtuple : trigtuple,
388 tupdesc,
i + 1, &isnull);
389 cnulls[
i] = (isnull) ?
'n' :
' ';
395 cvals[
attnum[0] - 1] = newoff;
396 cnulls[
attnum[0] - 1] =
' ';
398 cnulls[
attnum[1] - 1] =
' ';
403 cvals[
attnum[1] - 1] = newoff;
404 cnulls[
attnum[1] - 1] =
' ';
416 query = (
char *)
palloc(100 + 16 * natts);
422 for (
i = 1;
i <= natts;
i++)
424 sprintf(query + strlen(query),
"$%d%s",
425 i, (
i < natts) ?
", " :
")");
449 rettuple = trigtuple;
505 i = sscanf(input_string,
526 char *result = (
char *)
palloc(16 * 4);
528 snprintf(result, 16 * 4,
"%d,%d,%d,%d",
571 ncolumns = tupdesc->
natts;
580 nulls = (
bool *)
palloc(ncolumns *
sizeof(
bool));
586 for (
i = 0;
i < ncolumns;
i++)
610 struct varlena *oldattr = attr;
618 redirect_pointer.
pointer = attr;
621 sizeof(redirect_pointer));
650#if !defined(WIN32) || defined(_MSC_VER)
657 for (
char **s =
environ; *s; s++)
662 for (
int i = 0;
i < nvals;
i++)
679 elog(
ERROR,
"must be superuser to change environment variables");
681 if (
setenv(envvar, envval, 1) != 0)
682 elog(
ERROR,
"could not set environment variable: %m");
696 elog(
ERROR,
"must be superuser to check PID liveness");
698 while (
kill(pid, 0) == 0)
705 elog(
ERROR,
"could not check PID %d liveness: %m", pid);
776 for (
i = 0;
i < 1000;
i++)
783 elog(
ERROR,
"atomic_compare_exchange_u32() never succeeded");
822 for (
i = 0;
i < 100;
i++)
829 elog(
ERROR,
"atomic_compare_exchange_u64() never succeeded");
861 struct test_lock_struct
868 memcpy(struct_w_lock.data_before,
"abcd", 4);
869 memcpy(struct_w_lock.data_after,
"ef12", 4);
878 S_LOCK(&struct_w_lock.lock);
882 s_lock(&struct_w_lock.lock,
"testfile", 17,
"testfunc");
890 S_LOCK(&struct_w_lock.lock);
892 if (!
TAS(&struct_w_lock.lock))
893 elog(
ERROR,
"acquired already held spinlock");
897 elog(
ERROR,
"acquired already held spinlock");
907 if (memcmp(struct_w_lock.data_before,
"abcd", 4) != 0)
908 elog(
ERROR,
"padding before spinlock modified");
909 if (memcmp(struct_w_lock.data_after,
"ef12", 4) != 0)
910 elog(
ERROR,
"padding after spinlock modified");
937 elog(
ERROR,
"test_fdw_handler is not implemented");
998 !((
Const *) arg1)->constisnull &&
1000 !((
Const *) arg2)->constisnull)
1005 req->
rows = val2 - val1 + 1;
1055 bool nulls[2] = {0};
1058 if (src_encoding < 0)
1060 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1061 errmsg(
"invalid source encoding name \"%s\"",
1062 src_encoding_name)));
1063 if (dest_encoding < 0)
1065 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1066 errmsg(
"invalid destination encoding name \"%s\"",
1067 dest_encoding_name)));
1071 elog(
ERROR,
"return type must be a row type");
1077 if (src_encoding == dest_encoding)
1084 if (oklen == srclen)
1086 convertedbytes = oklen;
1099 convertedbytes = oklen;
1102 memcpy(
VARDATA(retval), src, oklen);
1110 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
1111 errmsg(
"default conversion function for encoding \"%s\" to \"%s\" does not exist",
1117 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
1119 errdetail(
"String of %d bytes is too long for encoding conversion.",
1129 (
unsigned char *) src, srclen,
1130 (
unsigned char *) dst, dstsize,
1132 dstlen = strlen(dst);
1139 memcpy(
VARDATA(retval), dst, dstlen);
ArrayType * construct_array_builtin(Datum *elems, int nelems, Oid elmtype)
static uint32 pg_atomic_fetch_and_u32(volatile pg_atomic_uint32 *ptr, uint32 and_)
static bool pg_atomic_compare_exchange_u32(volatile pg_atomic_uint32 *ptr, uint32 *expected, uint32 newval)
static void pg_atomic_write_u64(volatile pg_atomic_uint64 *ptr, uint64 val)
static void pg_atomic_clear_flag(volatile pg_atomic_flag *ptr)
static uint32 pg_atomic_fetch_or_u32(volatile pg_atomic_uint32 *ptr, uint32 or_)
static uint32 pg_atomic_sub_fetch_u32(volatile pg_atomic_uint32 *ptr, int32 sub_)
static uint32 pg_atomic_fetch_sub_u32(volatile pg_atomic_uint32 *ptr, int32 sub_)
static bool pg_atomic_compare_exchange_u64(volatile pg_atomic_uint64 *ptr, uint64 *expected, uint64 newval)
static void pg_atomic_init_u32(volatile pg_atomic_uint32 *ptr, uint32 val)
static uint32 pg_atomic_fetch_add_u32(volatile pg_atomic_uint32 *ptr, int32 add_)
static uint32 pg_atomic_add_fetch_u32(volatile pg_atomic_uint32 *ptr, int32 add_)
static uint64 pg_atomic_fetch_add_u64(volatile pg_atomic_uint64 *ptr, int64 add_)
static bool pg_atomic_test_set_flag(volatile pg_atomic_flag *ptr)
static uint64 pg_atomic_sub_fetch_u64(volatile pg_atomic_uint64 *ptr, int64 sub_)
static bool pg_atomic_unlocked_test_flag(volatile pg_atomic_flag *ptr)
static void pg_atomic_write_u32(volatile pg_atomic_uint32 *ptr, uint32 val)
static uint64 pg_atomic_fetch_and_u64(volatile pg_atomic_uint64 *ptr, uint64 and_)
static uint32 pg_atomic_read_u32(volatile pg_atomic_uint32 *ptr)
static uint64 pg_atomic_fetch_or_u64(volatile pg_atomic_uint64 *ptr, uint64 or_)
static uint64 pg_atomic_add_fetch_u64(volatile pg_atomic_uint64 *ptr, int64 add_)
static uint32 pg_atomic_exchange_u32(volatile pg_atomic_uint32 *ptr, uint32 newval)
static void pg_atomic_init_u64(volatile pg_atomic_uint64 *ptr, uint64 val)
static uint64 pg_atomic_read_u64(volatile pg_atomic_uint64 *ptr)
static uint64 pg_atomic_fetch_sub_u64(volatile pg_atomic_uint64 *ptr, int64 sub_)
static uint64 pg_atomic_exchange_u64(volatile pg_atomic_uint64 *ptr, uint64 newval)
static void pg_atomic_init_flag(volatile pg_atomic_flag *ptr)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define Assert(condition)
#define OidIsValid(objectId)
Datum nextval(PG_FUNCTION_ARGS)
static void PGresult const char * p2
struct varlena * detoast_external_attr(struct varlena *attr)
#define INDIRECT_POINTER_SIZE
int errdetail(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
TupleDesc BlessTupleDesc(TupleDesc tupdesc)
Datum GetAttributeByName(HeapTupleHeader tuple, const char *attname, bool *isNull)
#define PG_GETARG_BYTEA_PP(n)
#define PG_GETARG_TEXT_PP(n)
#define DirectFunctionCall2(func, arg1, arg2)
#define PG_GETARG_POINTER(n)
#define PG_RETURN_CSTRING(x)
#define DirectFunctionCall1(func, arg1)
#define PG_GETARG_CSTRING(n)
#define PG_GETARG_NAME(n)
#define PG_GETARG_HEAPTUPLEHEADER(n)
#define PG_RETURN_TEXT_P(x)
#define PG_RETURN_INT32(x)
#define PG_GETARG_INT32(n)
#define PG_GETARG_BOOL(n)
#define PG_RETURN_DATUM(x)
#define PG_RETURN_POINTER(x)
#define PG_RETURN_BOOL(x)
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
#define PG_GETARG_POINT_P(n)
static Datum LsegPGetDatum(const LSEG *X)
static Datum PointPGetDatum(const Point *X)
#define PG_GETARG_PATH_P(n)
Datum point_distance(PG_FUNCTION_ARGS)
Datum lseg_intersect(PG_FUNCTION_ARGS)
Datum lseg_interpt(PG_FUNCTION_ARGS)
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
void heap_deform_tuple(HeapTuple tuple, TupleDesc tupleDesc, Datum *values, bool *isnull)
#define HeapTupleHeaderGetTypMod(tup)
#define HeapTupleHeaderGetTypeId(tup)
#define HeapTupleHeaderGetDatumLength(tup)
if(TABLE==NULL||TABLE_index==NULL)
static void ItemPointerSetInvalid(ItemPointerData *pointer)
int pg_do_encoding_conversion_buf(Oid proc, int src_encoding, int dest_encoding, unsigned char *src, int srclen, unsigned char *dest, int destlen, bool noError)
void report_invalid_encoding(int encoding, const char *mbstr, int len)
void * MemoryContextAlloc(MemoryContext context, Size size)
MemoryContext TopTransactionContext
void pfree(void *pointer)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
#define CHECK_FOR_INTERRUPTS()
Oid FindDefaultConversionProc(int32 for_encoding, int32 to_encoding)
#define IsA(nodeptr, _type_)
bool IsBinaryCoercible(Oid srctype, Oid targettype)
#define MAX_CONVERSION_GROWTH
#define pg_encoding_to_char
#define pg_char_to_encoding
Selectivity restriction_selectivity(PlannerInfo *root, Oid operatorid, List *args, Oid inputcollid, int varRelid)
Selectivity join_selectivity(PlannerInfo *root, Oid operatorid, List *args, Oid inputcollid, JoinType jointype, SpecialJoinInfo *sjinfo)
void canonicalize_path(char *path)
static bool DatumGetBool(Datum X)
static int64 DatumGetInt64(Datum X)
static Datum PointerGetDatum(const void *X)
static float8 DatumGetFloat8(Datum X)
static Pointer DatumGetPointer(Datum X)
static Datum Int32GetDatum(int32 X)
static int32 DatumGetInt32(Datum X)
char * psprintf(const char *fmt,...)
MemoryContextSwitchTo(old_ctx)
static void test_spinlock(void)
#define EXPECT_TRUE(expr)
Datum regress_setenv(PG_FUNCTION_ARGS)
static void test_atomic_uint32(void)
Datum ttdummy(PG_FUNCTION_ARGS)
#define EXPECT_EQ_U32(result_expr, expected_expr)
Datum test_atomic_ops(PG_FUNCTION_ARGS)
Datum test_support_func(PG_FUNCTION_ARGS)
PG_FUNCTION_INFO_V1(interpt_pp)
Datum int44out(PG_FUNCTION_ARGS)
Datum set_ttdummy(PG_FUNCTION_ARGS)
Datum test_opclass_options_func(PG_FUNCTION_ARGS)
Datum test_fdw_handler(PG_FUNCTION_ARGS)
#define EXPECT_EQ_U64(result_expr, expected_expr)
Datum interpt_pp(PG_FUNCTION_ARGS)
static void regress_lseg_construct(LSEG *lseg, Point *pt1, Point *pt2)
Datum trigger_return_old(PG_FUNCTION_ARGS)
Datum int44in(PG_FUNCTION_ARGS)
Datum get_environ(PG_FUNCTION_ARGS)
Datum test_canonicalize_path(PG_FUNCTION_ARGS)
Datum reverse_name(PG_FUNCTION_ARGS)
Datum widget_in(PG_FUNCTION_ARGS)
Datum wait_pid(PG_FUNCTION_ARGS)
Datum widget_out(PG_FUNCTION_ARGS)
static void test_atomic_flag(void)
Datum pt_in_widget(PG_FUNCTION_ARGS)
Datum test_enc_conversion(PG_FUNCTION_ARGS)
static void test_atomic_uint64(void)
Datum make_tuple_indirect(PG_FUNCTION_ARGS)
Datum binary_coercible(PG_FUNCTION_ARGS)
Datum overpaid(PG_FUNCTION_ARGS)
int s_lock(volatile slock_t *lock, const char *file, int line, const char *func)
#define S_INIT_LOCK(lock)
void pg_usleep(long microsec)
int SPI_fnumber(TupleDesc tupdesc, const char *fname)
Oid SPI_gettypeid(TupleDesc tupdesc, int fnumber)
const char * SPI_result_code_string(int code)
HeapTuple SPI_modifytuple(Relation rel, HeapTuple tuple, int natts, int *attnum, Datum *Values, const char *Nulls)
SPIPlanPtr SPI_prepare(const char *src, int nargs, Oid *argtypes)
int SPI_keepplan(SPIPlanPtr plan)
int SPI_execp(SPIPlanPtr plan, Datum *Values, const char *Nulls, long tcount)
Datum SPI_getbinval(HeapTuple tuple, TupleDesc tupdesc, int fnumber, bool *isnull)
char * SPI_getrelname(Relation rel)
#define SpinLockInit(lock)
#define SpinLockRelease(lock)
#define SpinLockAcquire(lock)
Point p[FLEXIBLE_ARRAY_MEMBER]
struct PlannerInfo * root
struct SpecialJoinInfo * sjinfo
#define TRIGGER_FIRED_BEFORE(event)
#define CALLED_AS_TRIGGER(fcinfo)
#define TRIGGER_FIRED_FOR_ROW(event)
#define TRIGGER_FIRED_BY_INSERT(event)
#define TRIGGER_FIRED_BY_UPDATE(event)
#define ReleaseTupleDesc(tupdesc)
static FormData_pg_attribute * TupleDescAttr(TupleDesc tupdesc, int i)
TupleDesc lookup_rowtype_tupdesc(Oid type_id, int32 typmod)
#define VARATT_IS_EXTERNAL_ONDISK(PTR)
#define VARATT_IS_EXTERNAL_INDIRECT(PTR)
#define SET_VARTAG_EXTERNAL(PTR, tag)
#define VARDATA_EXTERNAL(PTR)
#define SET_VARSIZE(PTR, len)
#define VARSIZE_ANY_EXHDR(PTR)
text * cstring_to_text(const char *s)
char * text_to_cstring(const text *t)
int pg_encoding_verifymbstr(int encoding, const char *mbstr, int len)