gbt_bit_xfrm(bytea *leaf)
{
bytea *out = leaf;
- int s = VARBITBYTES(leaf) + VARHDRSZ;
+ int s = INTALIGN(VARBITBYTES(leaf) + VARHDRSZ);
out = palloc(s);
VARATT_SIZEP(out) = s;
gbt_bit_consistent(PG_FUNCTION_ARGS)
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
- GBT_VARKEY *ktst = (GBT_VARKEY *) DatumGetPointer(entry->key);
- GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(entry->key));
+ GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(entry->key);
void *qtst = (void *) DatumGetPointer(PG_GETARG_DATUM(1));
void *query = (void *) DatumGetByteaP(PG_GETARG_DATUM(1));
StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
pfree(q);
}
- if (ktst != key)
- pfree(key);
if (qtst != query)
pfree(query);
PG_RETURN_BOOL(retval);
gbt_bytea_consistent(PG_FUNCTION_ARGS)
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
- GBT_VARKEY *ktst = (GBT_VARKEY *) DatumGetPointer(entry->key);
- GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(entry->key));
+ GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(entry->key);
void *qtst = (void *) DatumGetPointer(PG_GETARG_DATUM(1));
void *query = (void *) DatumGetByteaP(PG_GETARG_DATUM(1));
StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
retval = gbt_var_consistent(&r, query, &strategy, GIST_LEAF(entry), &tinfo);
- if (ktst != key)
- pfree(key);
if (qtst != query)
pfree(query);
PG_RETURN_BOOL(retval);
AS 'MODULE_PATHNAME'
LANGUAGE 'C';
+CREATE FUNCTION gbt_var_decompress(internal)
+RETURNS internal
+AS 'MODULE_PATHNAME'
+LANGUAGE 'C';
+
CREATE FUNCTION gbt_oid_penalty(internal,internal,internal)
RETURNS internal
AS 'MODULE_PATHNAME'
FUNCTION 1 gbt_text_consistent (internal, text, int2),
FUNCTION 2 gbt_text_union (bytea, internal),
FUNCTION 3 gbt_text_compress (internal),
- FUNCTION 4 gbt_decompress (internal),
+ FUNCTION 4 gbt_var_decompress (internal),
FUNCTION 5 gbt_text_penalty (internal, internal, internal),
FUNCTION 6 gbt_text_picksplit (internal, internal),
FUNCTION 7 gbt_text_same (internal, internal, internal),
FUNCTION 1 gbt_bpchar_consistent (internal, bpchar , int2),
FUNCTION 2 gbt_text_union (bytea, internal),
FUNCTION 3 gbt_bpchar_compress (internal),
- FUNCTION 4 gbt_decompress (internal),
+ FUNCTION 4 gbt_var_decompress (internal),
FUNCTION 5 gbt_text_penalty (internal, internal, internal),
FUNCTION 6 gbt_text_picksplit (internal, internal),
FUNCTION 7 gbt_text_same (internal, internal, internal),
FUNCTION 1 gbt_bytea_consistent (internal, bytea, int2),
FUNCTION 2 gbt_bytea_union (bytea, internal),
FUNCTION 3 gbt_bytea_compress (internal),
- FUNCTION 4 gbt_decompress (internal),
+ FUNCTION 4 gbt_var_decompress (internal),
FUNCTION 5 gbt_bytea_penalty (internal, internal, internal),
FUNCTION 6 gbt_bytea_picksplit (internal, internal),
FUNCTION 7 gbt_bytea_same (internal, internal, internal),
FUNCTION 1 gbt_numeric_consistent (internal, numeric, int2),
FUNCTION 2 gbt_numeric_union (bytea, internal),
FUNCTION 3 gbt_numeric_compress (internal),
- FUNCTION 4 gbt_decompress (internal),
+ FUNCTION 4 gbt_var_decompress (internal),
FUNCTION 5 gbt_numeric_penalty (internal, internal, internal),
FUNCTION 6 gbt_numeric_picksplit (internal, internal),
FUNCTION 7 gbt_numeric_same (internal, internal, internal),
FUNCTION 1 gbt_bit_consistent (internal, bit, int2),
FUNCTION 2 gbt_bit_union (bytea, internal),
FUNCTION 3 gbt_bit_compress (internal),
- FUNCTION 4 gbt_decompress (internal),
+ FUNCTION 4 gbt_var_decompress (internal),
FUNCTION 5 gbt_bit_penalty (internal, internal, internal),
FUNCTION 6 gbt_bit_picksplit (internal, internal),
FUNCTION 7 gbt_bit_same (internal, internal, internal),
FUNCTION 1 gbt_bit_consistent (internal, bit, int2),
FUNCTION 2 gbt_bit_union (bytea, internal),
FUNCTION 3 gbt_bit_compress (internal),
- FUNCTION 4 gbt_decompress (internal),
+ FUNCTION 4 gbt_var_decompress (internal),
FUNCTION 5 gbt_bit_penalty (internal, internal, internal),
FUNCTION 6 gbt_bit_picksplit (internal, internal),
FUNCTION 7 gbt_bit_same (internal, internal, internal),
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
- GBT_VARKEY *ktst = (GBT_VARKEY *) DatumGetPointer(entry->key);
- GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(entry->key));
+ GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(entry->key);
void *qtst = (void *) DatumGetPointer(PG_GETARG_DATUM(1));
void *query = (void *) DatumGetNumeric(PG_GETARG_DATUM(1));
StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
retval = gbt_var_consistent(&r, query, &strategy, GIST_LEAF(entry), &tinfo);
- if (ktst != key)
- pfree(key);
if (qtst != query)
pfree(query);
PG_RETURN_BOOL(retval);
static int32
gbt_textcmp(const bytea *a, const bytea *b)
{
- return strcmp(VARDATA(a), VARDATA(b));
+ return DatumGetInt32(DirectFunctionCall2(bttextcmp, PointerGetDatum(a), PointerGetDatum(b)));
}
-
-/*
- * Converts data of leaf using strxfrm ( locale support )
-*/
-
-static bytea *
-gbt_text_xfrm(bytea *leaf)
-{
- bytea *out = leaf;
- int32 ilen = VARSIZE(leaf) - VARHDRSZ;
- int32 olen;
- char *sin;
- char *sou;
-
- sin = palloc(ilen + 1);
- memcpy(sin, (void *) VARDATA(leaf), ilen);
- sin[ilen] = '\0';
-
- olen = strxfrm(NULL, &sin[0], 0) + 1;
- sou = palloc(olen);
- olen = strxfrm(sou, &sin[0], olen);
- olen += VARHDRSZ;
- out = palloc(olen + 1);
- out->vl_len = olen + 1;
- memcpy((void *) VARDATA(out), sou, olen - VARHDRSZ);
- ((char *) out)[olen] = '\0';
-
- pfree(sou);
- pfree(sin);
-
- return out;
-}
-
-
-static GBT_VARKEY *
-gbt_text_l2n(GBT_VARKEY * leaf)
-{
-
- GBT_VARKEY *out = leaf;
- GBT_VARKEY_R r = gbt_var_key_readable(leaf);
- bytea *o;
-
- o = gbt_text_xfrm(r.lower);
- r.lower = r.upper = o;
- out = gbt_var_key_copy(&r, TRUE);
- pfree(o);
-
- return out;
-
-}
-
-
-
-
-
static const gbtree_vinfo tinfo =
{
gbt_t_text,
gbt_textle,
gbt_textlt,
gbt_textcmp,
- gbt_text_l2n
+ NULL
};
{
Datum d = DirectFunctionCall1(rtrim1, entry->key);
- GISTENTRY *trim = palloc(sizeof(GISTENTRY));
+ GISTENTRY trim;
- gistentryinit(*trim, d,
+ gistentryinit(trim, d,
entry->rel, entry->page,
entry->offset, VARSIZE(DatumGetPointer(d)), TRUE);
- retval = gbt_var_compress(trim, &tinfo);
+ retval = gbt_var_compress(&trim, &tinfo);
- pfree(trim);
pfree(DatumGetPointer(d));
}
else
gbt_text_consistent(PG_FUNCTION_ARGS)
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
- GBT_VARKEY *ktst = (GBT_VARKEY *) DatumGetPointer(entry->key);
- GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(entry->key));
+ GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(entry->key);
void *qtst = (void *) DatumGetPointer(PG_GETARG_DATUM(1));
void *query = (void *) DatumGetTextP(PG_GETARG_DATUM(1));
StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
bool retval = FALSE;
GBT_VARKEY_R r = gbt_var_key_readable(key);
- if (GIST_LEAF(entry))
- retval = gbt_var_consistent(&r, query, &strategy, TRUE, &tinfo);
- else
- {
- bytea *q = gbt_text_xfrm((bytea *) query);
+ retval = gbt_var_consistent(&r, query, &strategy, GIST_LEAF(entry), &tinfo);
- retval = gbt_var_consistent(&r, (void *) q, &strategy, FALSE, &tinfo);
- if (q != query)
- pfree(q);
- }
-
- if (ktst != key)
- pfree(key);
if (qtst != query)
pfree(query);
gbt_bpchar_consistent(PG_FUNCTION_ARGS)
{
GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
- GBT_VARKEY *ktst = (GBT_VARKEY *) DatumGetPointer(entry->key);
- GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(entry->key));
+ GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(entry->key);
void *qtst = (void *) DatumGetPointer(PG_GETARG_DATUM(1));
void *query = (void *) DatumGetPointer(PG_DETOAST_DATUM(PG_GETARG_DATUM(1)));
void *trim = (void *) DatumGetPointer(DirectFunctionCall1(rtrim1, PointerGetDatum(query)));
bool retval = FALSE;
GBT_VARKEY_R r = gbt_var_key_readable(key);
- if (GIST_LEAF(entry))
- retval = gbt_var_consistent(&r, trim, &strategy, TRUE, &tinfo);
- else
- {
- bytea *q = gbt_text_xfrm((bytea *) trim);
-
- retval = gbt_var_consistent(&r, (void *) q, &strategy, FALSE, &tinfo);
- if (q != trim)
- pfree(q);
- }
+ retval = gbt_var_consistent(&r, trim, &strategy, GIST_LEAF(entry), &tinfo);
pfree(trim);
- if (ktst != key)
- pfree(key);
if (qtst != query)
pfree(query);
PG_RETURN_BOOL(retval);
#include "utils/pg_locale.h"
#include "btree_utils_var.h"
+PG_FUNCTION_INFO_V1(gbt_var_decompress);
+Datum gbt_var_decompress(PG_FUNCTION_ARGS);
+
+
+Datum
+gbt_var_decompress(PG_FUNCTION_ARGS)
+{
+ GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
+ GBT_VARKEY *key = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(entry->key));
+
+ if (key != (GBT_VARKEY *) DatumGetPointer(entry->key))
+ {
+ GISTENTRY *retval = (GISTENTRY *) palloc(sizeof(GISTENTRY));
+
+ gistentryinit(*retval, PointerGetDatum(key),
+ entry->rel, entry->page,
+ entry->offset, VARSIZE(key), FALSE);
+
+ PG_RETURN_POINTER(retval);
+ }
+
+ PG_RETURN_POINTER(entry);
+}
+
/* Returns a better readable representaion of variable key ( sets pointer ) */
extern GBT_VARKEY_R
entry->offset, VARSIZE(r), TRUE);
}
else
- {
retval = entry;
-
- }
-
return (retval);
}
int i = 0,
numranges = entryvec->n;
- GBT_VARKEY *cur,
- *tst = NULL;
+ GBT_VARKEY *cur;
Datum out;
GBT_VARKEY_R rk;
*size = sizeof(GBT_VARKEY);
- tst = (GBT_VARKEY *) DatumGetPointer((entryvec->vector[0].key));
- cur = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM((entryvec->vector[0].key)));
+ cur = (GBT_VARKEY *) DatumGetPointer(entryvec->vector[0].key);
rk = gbt_var_key_readable(cur);
out = PointerGetDatum(gbt_var_key_copy(&rk, TRUE));
- if (tst != cur)
- pfree(cur);
for (i = 1; i < numranges; i++)
{
- tst = (GBT_VARKEY *) DatumGetPointer((entryvec->vector[i].key));
- cur = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM((entryvec->vector[i].key)));
+ cur = (GBT_VARKEY *) DatumGetPointer(entryvec->vector[i].key);
gbt_var_bin_union(&out, cur, tinfo);
- if (tst != cur)
- pfree(cur);
}
gbt_var_same(bool *result, const Datum d1, const Datum d2, const gbtree_vinfo * tinfo)
{
- GBT_VARKEY *tst1 = (GBT_VARKEY *) DatumGetPointer(d1);
- GBT_VARKEY *t1 = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(d1));
- GBT_VARKEY *tst2 = (GBT_VARKEY *) DatumGetPointer(d2);
- GBT_VARKEY *t2 = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(d2));
+ GBT_VARKEY *t1 = (GBT_VARKEY *) DatumGetPointer(d1);
+ GBT_VARKEY *t2 = (GBT_VARKEY *) DatumGetPointer(d2);
GBT_VARKEY_R r1,
r2;
else
*result = (t1 == NULL && t2 == NULL) ? TRUE : FALSE;
- if (tst1 != t1)
- pfree(t1);
- if (tst2 != t2)
- pfree(t2);
-
PG_RETURN_POINTER(result);
}
gbt_var_penalty(float *res, const GISTENTRY *o, const GISTENTRY *n, const gbtree_vinfo * tinfo)
{
- GBT_VARKEY *orgt = (GBT_VARKEY *) DatumGetPointer(o->key);
- GBT_VARKEY *orge = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(o->key));
- GBT_VARKEY *newt = (GBT_VARKEY *) DatumGetPointer(n->key);
- GBT_VARKEY *newe = (GBT_VARKEY *) DatumGetPointer(PG_DETOAST_DATUM(n->key));
+ GBT_VARKEY *orge = (GBT_VARKEY *) DatumGetPointer(o->key);
+ GBT_VARKEY *newe = (GBT_VARKEY *) DatumGetPointer(n->key);
GBT_VARKEY_R ok,
nk;
GBT_VARKEY *tmp = NULL;
if (tmp && tmp != newe)
pfree(tmp);
- if (newe != newt)
- pfree(newe);
-
- if (orge != orgt)
- pfree(orge);
return res;
-
}
OffsetNumber i,
maxoff = entryvec->n - 1;
Vsrt *arr;
- int pfrcntr = 0,
- svcntr = 0,
+ int svcntr = 0,
nbytes;
- char *tst,
- *cur;
- char **pfr = NULL;
+ char *cur;
GBT_VARKEY **sv = NULL;
arr = (Vsrt *) palloc((maxoff + 1) * sizeof(Vsrt));
v->spl_nleft = 0;
v->spl_nright = 0;
- pfr = palloc(sizeof(GBT_VARKEY *) * (maxoff + 1));
sv = palloc(sizeof(bytea *) * (maxoff + 1));
/* Sort entries */
{
GBT_VARKEY_R ro;
- tst = (char *) DatumGetPointer((entryvec->vector[i].key));
- cur = (char *) DatumGetPointer(PG_DETOAST_DATUM((entryvec->vector[i].key)));
- if (tst != cur)
- {
- pfr[pfrcntr] = cur;
- pfrcntr++;
- }
+ cur = (char *) DatumGetPointer(entryvec->vector[i].key);
ro = gbt_var_key_readable((GBT_VARKEY *) cur);
if (ro.lower == ro.upper) /* leaf */
{
}
}
- /* Free detoasted keys */
- for (i = 0; i < pfrcntr; i++)
- pfree(pfr[i]);
-
/* Free strxfrm'ed leafs */
for (i = 0; i < svcntr; i++)
pfree(sv[i]);
- if (pfr)
- pfree(pfr);
-
if (sv)
pfree(sv);
projects / postgresql.git / commitdiff