Header And Logo
|
#include "postgres.h"#include "btree_gist.h"#include "btree_utils_num.h"#include "utils/builtins.h"#include "utils/datetime.h"
Go to the source code of this file.
Data Structures | |
| struct | tsKEY |
Defines | |
| #define | TimestampGetDatumFast(X) PointerGetDatum(&(X)) |
| #define | penalty_check_max_float(val) |
Functions | |
| PG_FUNCTION_INFO_V1 (gbt_ts_compress) | |
| PG_FUNCTION_INFO_V1 (gbt_tstz_compress) | |
| PG_FUNCTION_INFO_V1 (gbt_ts_union) | |
| PG_FUNCTION_INFO_V1 (gbt_ts_picksplit) | |
| PG_FUNCTION_INFO_V1 (gbt_ts_consistent) | |
| PG_FUNCTION_INFO_V1 (gbt_ts_distance) | |
| PG_FUNCTION_INFO_V1 (gbt_tstz_consistent) | |
| PG_FUNCTION_INFO_V1 (gbt_tstz_distance) | |
| PG_FUNCTION_INFO_V1 (gbt_ts_penalty) | |
| PG_FUNCTION_INFO_V1 (gbt_ts_same) | |
| Datum | gbt_ts_compress (PG_FUNCTION_ARGS) |
| Datum | gbt_tstz_compress (PG_FUNCTION_ARGS) |
| Datum | gbt_ts_union (PG_FUNCTION_ARGS) |
| Datum | gbt_ts_picksplit (PG_FUNCTION_ARGS) |
| Datum | gbt_ts_consistent (PG_FUNCTION_ARGS) |
| Datum | gbt_ts_distance (PG_FUNCTION_ARGS) |
| Datum | gbt_tstz_consistent (PG_FUNCTION_ARGS) |
| Datum | gbt_tstz_distance (PG_FUNCTION_ARGS) |
| Datum | gbt_ts_penalty (PG_FUNCTION_ARGS) |
| Datum | gbt_ts_same (PG_FUNCTION_ARGS) |
| static bool | gbt_tsgt (const void *a, const void *b) |
| static bool | gbt_tsge (const void *a, const void *b) |
| static bool | gbt_tseq (const void *a, const void *b) |
| static bool | gbt_tsle (const void *a, const void *b) |
| static bool | gbt_tslt (const void *a, const void *b) |
| static int | gbt_tskey_cmp (const void *a, const void *b) |
| static float8 | gbt_ts_dist (const void *a, const void *b) |
| PG_FUNCTION_INFO_V1 (ts_dist) | |
| Datum | ts_dist (PG_FUNCTION_ARGS) |
| PG_FUNCTION_INFO_V1 (tstz_dist) | |
| Datum | tstz_dist (PG_FUNCTION_ARGS) |
| static Timestamp | tstz_to_ts_gmt (TimestampTz ts) |
Variables | |
| static const gbtree_ninfo | tinfo |
| #define penalty_check_max_float | ( | val | ) |
do { \ if ( val > FLT_MAX ) \ val = FLT_MAX; \ if ( val < -FLT_MAX ) \ val = -FLT_MAX; \ } while(false);
Definition at line 374 of file btree_ts.c.
Referenced by gbt_ts_penalty().
| #define TimestampGetDatumFast | ( | X | ) | PointerGetDatum(&(X)) |
Definition at line 46 of file btree_ts.c.
Referenced by gbt_ts_dist(), gbt_tseq(), gbt_tsge(), gbt_tsgt(), gbt_tskey_cmp(), gbt_tsle(), and gbt_tslt().
| Datum gbt_ts_compress | ( | PG_FUNCTION_ARGS | ) |
Definition at line 240 of file btree_ts.c.
References gbt_num_compress(), PG_GETARG_POINTER, and PG_RETURN_POINTER.
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
GISTENTRY *retval = NULL;
PG_RETURN_POINTER(gbt_num_compress(retval, entry, &tinfo));
}
| Datum gbt_ts_consistent | ( | PG_FUNCTION_ARGS | ) |
Definition at line 277 of file btree_ts.c.
References DatumGetPointer, gbt_num_consistent(), GIST_LEAF, GISTENTRY::key, tsKEY::lower, GBT_NUMKEY_R::lower, PG_GETARG_POINTER, PG_GETARG_TIMESTAMP, PG_GETARG_UINT16, PG_RETURN_BOOL, tsKEY::upper, and GBT_NUMKEY_R::upper.
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
Timestamp query = PG_GETARG_TIMESTAMP(1);
StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
/* Oid subtype = PG_GETARG_OID(3); */
bool *recheck = (bool *) PG_GETARG_POINTER(4);
tsKEY *kkk = (tsKEY *) DatumGetPointer(entry->key);
GBT_NUMKEY_R key;
/* All cases served by this function are exact */
*recheck = false;
key.lower = (GBT_NUMKEY *) &kkk->lower;
key.upper = (GBT_NUMKEY *) &kkk->upper;
PG_RETURN_BOOL(
gbt_num_consistent(&key, (void *) &query, &strategy, GIST_LEAF(entry), &tinfo)
);
}
| static float8 gbt_ts_dist | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 121 of file btree_ts.c.
References Abs, DatumGetIntervalP, DirectFunctionCall2, get_float8_infinity(), i, INTERVAL_TO_SEC, timestamp_mi(), TIMESTAMP_NOT_FINITE, and TimestampGetDatumFast.
{
const Timestamp *aa = (const Timestamp *) a;
const Timestamp *bb = (const Timestamp *) b;
Interval *i;
if (TIMESTAMP_NOT_FINITE(*aa) || TIMESTAMP_NOT_FINITE(*bb))
return get_float8_infinity();
i = DatumGetIntervalP(DirectFunctionCall2(timestamp_mi,
TimestampGetDatumFast(*aa),
TimestampGetDatumFast(*bb)));
return (float8) Abs(INTERVAL_TO_SEC(i));
}
| Datum gbt_ts_distance | ( | PG_FUNCTION_ARGS | ) |
Definition at line 300 of file btree_ts.c.
References DatumGetPointer, gbt_num_distance(), GIST_LEAF, GISTENTRY::key, tsKEY::lower, GBT_NUMKEY_R::lower, PG_GETARG_POINTER, PG_GETARG_TIMESTAMP, PG_RETURN_FLOAT8, tsKEY::upper, and GBT_NUMKEY_R::upper.
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
Timestamp query = PG_GETARG_TIMESTAMP(1);
/* Oid subtype = PG_GETARG_OID(3); */
tsKEY *kkk = (tsKEY *) DatumGetPointer(entry->key);
GBT_NUMKEY_R key;
key.lower = (GBT_NUMKEY *) &kkk->lower;
key.upper = (GBT_NUMKEY *) &kkk->upper;
PG_RETURN_FLOAT8(
gbt_num_distance(&key, (void *) &query, GIST_LEAF(entry), &tinfo)
);
}
| Datum gbt_ts_penalty | ( | PG_FUNCTION_ARGS | ) |
Definition at line 383 of file btree_ts.c.
References DatumGetPointer, tsKEY::lower, penalty_check_max_float, penalty_num, PG_GETARG_POINTER, PG_RETURN_POINTER, and tsKEY::upper.
{
tsKEY *origentry = (tsKEY *) DatumGetPointer(((GISTENTRY *) PG_GETARG_POINTER(0))->key);
tsKEY *newentry = (tsKEY *) DatumGetPointer(((GISTENTRY *) PG_GETARG_POINTER(1))->key);
float *result = (float *) PG_GETARG_POINTER(2);
double orgdbl[2],
newdbl[2];
/*
* We are allways using "double" timestamps here. Precision should be good
* enough.
*/
orgdbl[0] = ((double) origentry->lower);
orgdbl[1] = ((double) origentry->upper);
newdbl[0] = ((double) newentry->lower);
newdbl[1] = ((double) newentry->upper);
penalty_check_max_float(orgdbl[0]);
penalty_check_max_float(orgdbl[1]);
penalty_check_max_float(newdbl[0]);
penalty_check_max_float(newdbl[1]);
penalty_num(result, orgdbl[0], orgdbl[1], newdbl[0], newdbl[1]);
PG_RETURN_POINTER(result);
}
| Datum gbt_ts_picksplit | ( | PG_FUNCTION_ARGS | ) |
Definition at line 415 of file btree_ts.c.
References gbt_num_picksplit(), PG_GETARG_POINTER, and PG_RETURN_POINTER.
{
PG_RETURN_POINTER(gbt_num_picksplit(
(GistEntryVector *) PG_GETARG_POINTER(0),
(GIST_SPLITVEC *) PG_GETARG_POINTER(1),
&tinfo
));
}
| Datum gbt_ts_same | ( | PG_FUNCTION_ARGS | ) |
Definition at line 425 of file btree_ts.c.
References gbt_num_same(), PG_GETARG_POINTER, and PG_RETURN_POINTER.
{
tsKEY *b1 = (tsKEY *) PG_GETARG_POINTER(0);
tsKEY *b2 = (tsKEY *) PG_GETARG_POINTER(1);
bool *result = (bool *) PG_GETARG_POINTER(2);
*result = gbt_num_same((void *) b1, (void *) b2, &tinfo);
PG_RETURN_POINTER(result);
}
| Datum gbt_ts_union | ( | PG_FUNCTION_ARGS | ) |
Definition at line 364 of file btree_ts.c.
References gbt_num_union(), palloc(), PG_GETARG_POINTER, and PG_RETURN_POINTER.
{
GistEntryVector *entryvec = (GistEntryVector *) PG_GETARG_POINTER(0);
void *out = palloc(sizeof(tsKEY));
*(int *) PG_GETARG_POINTER(1) = sizeof(tsKEY);
PG_RETURN_POINTER(gbt_num_union((void *) out, entryvec, &tinfo));
}
| static bool gbt_tseq | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 73 of file btree_ts.c.
References DatumGetBool, DirectFunctionCall2, timestamp_eq(), and TimestampGetDatumFast.
{
const Timestamp *aa = (const Timestamp *) a;
const Timestamp *bb = (const Timestamp *) b;
return DatumGetBool(DirectFunctionCall2(timestamp_eq,
TimestampGetDatumFast(*aa),
TimestampGetDatumFast(*bb)));
}
| static bool gbt_tsge | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 62 of file btree_ts.c.
References DatumGetBool, DirectFunctionCall2, timestamp_ge(), and TimestampGetDatumFast.
{
const Timestamp *aa = (const Timestamp *) a;
const Timestamp *bb = (const Timestamp *) b;
return DatumGetBool(DirectFunctionCall2(timestamp_ge,
TimestampGetDatumFast(*aa),
TimestampGetDatumFast(*bb)));
}
| static bool gbt_tsgt | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 51 of file btree_ts.c.
References DatumGetBool, DirectFunctionCall2, timestamp_gt(), and TimestampGetDatumFast.
{
const Timestamp *aa = (const Timestamp *) a;
const Timestamp *bb = (const Timestamp *) b;
return DatumGetBool(DirectFunctionCall2(timestamp_gt,
TimestampGetDatumFast(*aa),
TimestampGetDatumFast(*bb)));
}
| static int gbt_tskey_cmp | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 107 of file btree_ts.c.
References DatumGetInt32, DirectFunctionCall2, tsKEY::lower, timestamp_cmp(), TimestampGetDatumFast, and tsKEY::upper.
{
tsKEY *ia = (tsKEY *) (((const Nsrt *) a)->t);
tsKEY *ib = (tsKEY *) (((const Nsrt *) b)->t);
int res;
res = DatumGetInt32(DirectFunctionCall2(timestamp_cmp, TimestampGetDatumFast(ia->lower), TimestampGetDatumFast(ib->lower)));
if (res == 0)
return DatumGetInt32(DirectFunctionCall2(timestamp_cmp, TimestampGetDatumFast(ia->upper), TimestampGetDatumFast(ib->upper)));
return res;
}
| static bool gbt_tsle | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 84 of file btree_ts.c.
References DatumGetBool, DirectFunctionCall2, timestamp_le(), and TimestampGetDatumFast.
{
const Timestamp *aa = (const Timestamp *) a;
const Timestamp *bb = (const Timestamp *) b;
return DatumGetBool(DirectFunctionCall2(timestamp_le,
TimestampGetDatumFast(*aa),
TimestampGetDatumFast(*bb)));
}
| static bool gbt_tslt | ( | const void * | a, | |
| const void * | b | |||
| ) | [static] |
Definition at line 95 of file btree_ts.c.
References DatumGetBool, DirectFunctionCall2, timestamp_lt(), and TimestampGetDatumFast.
{
const Timestamp *aa = (const Timestamp *) a;
const Timestamp *bb = (const Timestamp *) b;
return DatumGetBool(DirectFunctionCall2(timestamp_lt,
TimestampGetDatumFast(*aa),
TimestampGetDatumFast(*bb)));
}
| Datum gbt_tstz_compress | ( | PG_FUNCTION_ARGS | ) |
Definition at line 250 of file btree_ts.c.
References DatumGetTimestampTz, FALSE, gistentryinit, gmt, GISTENTRY::key, GISTENTRY::leafkey, tsKEY::lower, GISTENTRY::offset, GISTENTRY::page, palloc(), PG_GETARG_POINTER, PG_RETURN_POINTER, PointerGetDatum, GISTENTRY::rel, tstz_to_ts_gmt(), and tsKEY::upper.
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
GISTENTRY *retval;
if (entry->leafkey)
{
tsKEY *r = (tsKEY *) palloc(sizeof(tsKEY));
TimestampTz ts = DatumGetTimestampTz(entry->key);
Timestamp gmt;
gmt = tstz_to_ts_gmt(ts);
retval = palloc(sizeof(GISTENTRY));
r->lower = r->upper = gmt;
gistentryinit(*retval, PointerGetDatum(r),
entry->rel, entry->page,
entry->offset, FALSE);
}
else
retval = entry;
PG_RETURN_POINTER(retval);
}
| Datum gbt_tstz_consistent | ( | PG_FUNCTION_ARGS | ) |
Definition at line 318 of file btree_ts.c.
References DatumGetPointer, gbt_num_consistent(), GIST_LEAF, GISTENTRY::key, GBT_NUMKEY_R::lower, MAXALIGN, PG_GETARG_POINTER, PG_GETARG_TIMESTAMPTZ, PG_GETARG_UINT16, PG_RETURN_BOOL, gbtree_ninfo::size, tstz_to_ts_gmt(), and GBT_NUMKEY_R::upper.
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
TimestampTz query = PG_GETARG_TIMESTAMPTZ(1);
StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
/* Oid subtype = PG_GETARG_OID(3); */
bool *recheck = (bool *) PG_GETARG_POINTER(4);
char *kkk = (char *) DatumGetPointer(entry->key);
GBT_NUMKEY_R key;
Timestamp qqq;
/* All cases served by this function are exact */
*recheck = false;
key.lower = (GBT_NUMKEY *) &kkk[0];
key.upper = (GBT_NUMKEY *) &kkk[MAXALIGN(tinfo.size)];
qqq = tstz_to_ts_gmt(query);
PG_RETURN_BOOL(
gbt_num_consistent(&key, (void *) &qqq, &strategy, GIST_LEAF(entry), &tinfo)
);
}
| Datum gbt_tstz_distance | ( | PG_FUNCTION_ARGS | ) |
Definition at line 343 of file btree_ts.c.
References DatumGetPointer, gbt_num_distance(), GIST_LEAF, GISTENTRY::key, GBT_NUMKEY_R::lower, MAXALIGN, PG_GETARG_POINTER, PG_GETARG_TIMESTAMPTZ, PG_RETURN_FLOAT8, gbtree_ninfo::size, tstz_to_ts_gmt(), and GBT_NUMKEY_R::upper.
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
TimestampTz query = PG_GETARG_TIMESTAMPTZ(1);
/* Oid subtype = PG_GETARG_OID(3); */
char *kkk = (char *) DatumGetPointer(entry->key);
GBT_NUMKEY_R key;
Timestamp qqq;
key.lower = (GBT_NUMKEY *) &kkk[0];
key.upper = (GBT_NUMKEY *) &kkk[MAXALIGN(tinfo.size)];
qqq = tstz_to_ts_gmt(query);
PG_RETURN_FLOAT8(
gbt_num_distance(&key, (void *) &qqq, GIST_LEAF(entry), &tinfo)
);
}
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_picksplit | ) |
| PG_FUNCTION_INFO_V1 | ( | tstz_dist | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_tstz_consistent | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_compress | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_tstz_distance | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_consistent | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_same | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_penalty | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_distance | ) |
| PG_FUNCTION_INFO_V1 | ( | ts_dist | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_ts_union | ) |
| PG_FUNCTION_INFO_V1 | ( | gbt_tstz_compress | ) |
| Datum ts_dist | ( | PG_FUNCTION_ARGS | ) |
Definition at line 154 of file btree_ts.c.
References abs_interval(), DatumGetIntervalP, Interval::day, DirectFunctionCall2, INT64CONST, Interval::month, palloc(), PG_GETARG_DATUM, PG_GETARG_TIMESTAMP, PG_RETURN_INTERVAL_P, Interval::time, timestamp_mi(), and TIMESTAMP_NOT_FINITE.
{
Timestamp a = PG_GETARG_TIMESTAMP(0);
Timestamp b = PG_GETARG_TIMESTAMP(1);
Interval *r;
if (TIMESTAMP_NOT_FINITE(a) || TIMESTAMP_NOT_FINITE(b))
{
Interval *p = palloc(sizeof(Interval));
p->day = INT_MAX;
p->month = INT_MAX;
#ifdef HAVE_INT64_TIMESTAMP
p->time = INT64CONST(0x7FFFFFFFFFFFFFFF);
#else
p->time = DBL_MAX;
#endif
PG_RETURN_INTERVAL_P(p);
}
else
r = DatumGetIntervalP(DirectFunctionCall2(timestamp_mi,
PG_GETARG_DATUM(0),
PG_GETARG_DATUM(1)));
PG_RETURN_INTERVAL_P(abs_interval(r));
}
| Datum tstz_dist | ( | PG_FUNCTION_ARGS | ) |
Definition at line 183 of file btree_ts.c.
References abs_interval(), DatumGetIntervalP, Interval::day, DirectFunctionCall2, INT64CONST, Interval::month, palloc(), PG_GETARG_DATUM, PG_GETARG_TIMESTAMPTZ, PG_RETURN_INTERVAL_P, Interval::time, timestamp_mi(), and TIMESTAMP_NOT_FINITE.
{
TimestampTz a = PG_GETARG_TIMESTAMPTZ(0);
TimestampTz b = PG_GETARG_TIMESTAMPTZ(1);
Interval *r;
if (TIMESTAMP_NOT_FINITE(a) || TIMESTAMP_NOT_FINITE(b))
{
Interval *p = palloc(sizeof(Interval));
p->day = INT_MAX;
p->month = INT_MAX;
#ifdef HAVE_INT64_TIMESTAMP
p->time = INT64CONST(0x7FFFFFFFFFFFFFFF);
#else
p->time = DBL_MAX;
#endif
PG_RETURN_INTERVAL_P(p);
}
r = DatumGetIntervalP(DirectFunctionCall2(timestamp_mi,
PG_GETARG_DATUM(0),
PG_GETARG_DATUM(1)));
PG_RETURN_INTERVAL_P(abs_interval(r));
}
| static Timestamp tstz_to_ts_gmt | ( | TimestampTz | ts | ) | [static] |
Definition at line 216 of file btree_ts.c.
References DecodeSpecial(), DT_NOBEGIN, gmt, INT64CONST, and val.
Referenced by gbt_tstz_compress(), gbt_tstz_consistent(), and gbt_tstz_distance().
{
Timestamp gmt;
int val,
tz;
gmt = ts;
DecodeSpecial(0, "gmt", &val);
if (ts < DT_NOEND && ts > DT_NOBEGIN)
{
tz = val * 60;
#ifdef HAVE_INT64_TIMESTAMP
gmt -= (tz * INT64CONST(1000000));
#else
gmt -= tz;
#endif
}
return gmt;
}
const gbtree_ninfo tinfo [static] |
{
gbt_t_ts,
sizeof(Timestamp),
gbt_tsgt,
gbt_tsge,
gbt_tseq,
gbt_tsle,
gbt_tslt,
gbt_tskey_cmp,
gbt_ts_dist
}
Definition at line 137 of file btree_ts.c.
1.7.1