hstore_gist.c File Reference

#include "postgres.h"
#include "access/gist.h"
#include "access/reloptions.h"
#include "access/stratnum.h"
#include "catalog/pg_type.h"
#include "common/int.h"
#include "hstore.h"
#include "utils/pg_crc.h"

Include dependency graph for hstore_gist.c:

Go to the source code of this file.

Data Structures
struct	GistHstoreOptions
struct	GISTTYPE
struct	SPLITCOST

Macros
#define	BITBYTE   8
#define	SIGLEN_DEFAULT   (sizeof(int32) * 4)
#define	SIGLEN_MAX   GISTMaxIndexKeySize
#define	SIGLENBIT(siglen)   ((siglen) * BITBYTE)
#define	GET_SIGLEN()
#define	LOOPBYTE(siglen)    for (i = 0; i < (siglen); i++)
#define	LOOPBIT(siglen)    for (i = 0; i < SIGLENBIT(siglen); i++)
#define	GETBYTE(x, i)   ( *( (BITVECP)(x) + (int)( (i) / BITBYTE ) ) )
#define	GETBITBYTE(x, i)   ( (*((char*)(x)) >> (i)) & 0x01 )
#define	CLRBIT(x, i)   GETBYTE(x,i) &= ~( 0x01 << ( (i) % BITBYTE ) )
#define	SETBIT(x, i)   GETBYTE(x,i) |= ( 0x01 << ( (i) % BITBYTE ) )
#define	GETBIT(x, i)   ( (GETBYTE(x,i) >> ( (i) % BITBYTE )) & 0x01 )
#define	HASHVAL(val, siglen)   (((unsigned int)(val)) % SIGLENBIT(siglen))
#define	HASH(sign, val, siglen)   SETBIT((sign), HASHVAL(val, siglen))
#define	ALLISTRUE   0x04
#define	ISALLTRUE(x)   ( ((GISTTYPE*)x)->flag & ALLISTRUE )
#define	GTHDRSIZE   (VARHDRSZ + sizeof(int32))
#define	CALCGTSIZE(flag, siglen)   ( GTHDRSIZE+(((flag) & ALLISTRUE) ? 0 : (siglen)) )
#define	GETSIGN(x)   ( (BITVECP)( (char*)x+GTHDRSIZE ) )
#define	SUMBIT(val)
#define	GETENTRY(vec, pos)   ((GISTTYPE *) DatumGetPointer((vec)->vector[(pos)].key))
#define	WISH_F(a, b, c)   (double)( -(double)(((a)-(b))*((a)-(b))*((a)-(b)))*(c) )

Typedefs
typedef char *	BITVECP

Functions
static pg_crc32	crc32_sz (const char *buf, int size)
	PG_FUNCTION_INFO_V1 (ghstore_in)
	PG_FUNCTION_INFO_V1 (ghstore_out)
Datum	ghstore_in (PG_FUNCTION_ARGS)
Datum	ghstore_out (PG_FUNCTION_ARGS)
static GISTTYPE *	ghstore_alloc (bool allistrue, int siglen, BITVECP sign)
	PG_FUNCTION_INFO_V1 (ghstore_consistent)
	PG_FUNCTION_INFO_V1 (ghstore_compress)
	PG_FUNCTION_INFO_V1 (ghstore_decompress)
	PG_FUNCTION_INFO_V1 (ghstore_penalty)
	PG_FUNCTION_INFO_V1 (ghstore_picksplit)
	PG_FUNCTION_INFO_V1 (ghstore_union)
	PG_FUNCTION_INFO_V1 (ghstore_same)
	PG_FUNCTION_INFO_V1 (ghstore_options)
Datum	ghstore_compress (PG_FUNCTION_ARGS)
Datum	ghstore_decompress (PG_FUNCTION_ARGS)
Datum	ghstore_same (PG_FUNCTION_ARGS)
static int32	sizebitvec (BITVECP sign, int siglen)
static int	hemdistsign (BITVECP a, BITVECP b, int siglen)
static int	hemdist (GISTTYPE *a, GISTTYPE *b, int siglen)
static int32	unionkey (BITVECP sbase, GISTTYPE *add, int siglen)
Datum	ghstore_union (PG_FUNCTION_ARGS)
Datum	ghstore_penalty (PG_FUNCTION_ARGS)
static int	comparecost (const void *a, const void *b)
Datum	ghstore_picksplit (PG_FUNCTION_ARGS)
Datum	ghstore_consistent (PG_FUNCTION_ARGS)
Datum	ghstore_options (PG_FUNCTION_ARGS)

Macro Definition Documentation

ALLISTRUE

#define ALLISTRUE   0x04

Definition at line 55 of file hstore_gist.c.

BITBYTE

#define BITBYTE   8

Definition at line 22 of file hstore_gist.c.

CALCGTSIZE

#define CALCGTSIZE	(		flag,
			siglen
	)		( GTHDRSIZE+(((flag) & ALLISTRUE) ? 0 : (siglen)) )

Definition at line 60 of file hstore_gist.c.

CLRBIT

#define CLRBIT	(		x,
			i
	)		GETBYTE(x,i) &= ~( 0x01 << ( (i) % BITBYTE ) )

Definition at line 42 of file hstore_gist.c.

GET_SIGLEN

#define GET_SIGLEN

(

)

Value:

                         (PG_HAS_OPCLASS_OPTIONS() ? \
                         ((GistHstoreOptions *) PG_GET_OPCLASS_OPTIONS())->siglen : \
                         SIGLEN_DEFAULT)

Definition at line 26 of file hstore_gist.c.

                                                                                  : \
                         SIGLEN_DEFAULT)

GETBIT

#define GETBIT	(		x,
			i
	)		( (GETBYTE(x,i) >> ( (i) % BITBYTE )) & 0x01 )

Definition at line 44 of file hstore_gist.c.

GETBITBYTE

#define GETBITBYTE	(		x,
			i
	)		( (*((char*)(x)) >> (i)) & 0x01 )

Definition at line 41 of file hstore_gist.c.

GETBYTE

#define GETBYTE	(		x,
			i
	)		( *( (BITVECP)(x) + (int)( (i) / BITBYTE ) ) )

Definition at line 40 of file hstore_gist.c.

GETENTRY

#define GETENTRY	(		vec,
			pos
	)		((GISTTYPE *) DatumGetPointer((vec)->vector[(pos)].key))

Definition at line 75 of file hstore_gist.c.

GETSIGN

#define GETSIGN

(

x

)

( (BITVECP)( (char*)x+GTHDRSIZE ) )

Definition at line 62 of file hstore_gist.c.

GTHDRSIZE

#define GTHDRSIZE   (VARHDRSZ + sizeof(int32))

Definition at line 59 of file hstore_gist.c.

HASH

#define HASH	(		sign,
			val,
			siglen
	)		SETBIT((sign), HASHVAL(val, siglen))

Definition at line 46 of file hstore_gist.c.

HASHVAL

#define HASHVAL	(		val,
			siglen
	)		(((unsigned int)(val)) % SIGLENBIT(siglen))

Definition at line 45 of file hstore_gist.c.

ISALLTRUE

#define ISALLTRUE

(

x

)

( ((GISTTYPE*)x)->flag & ALLISTRUE )

Definition at line 57 of file hstore_gist.c.

LOOPBIT

#define LOOPBIT

(

siglen

)

for (i = 0; i < SIGLENBIT(siglen); i++)

Definition at line 36 of file hstore_gist.c.

LOOPBYTE

#define LOOPBYTE

(

siglen

)

for (i = 0; i < (siglen); i++)

Definition at line 33 of file hstore_gist.c.

SETBIT

#define SETBIT	(		x,
			i
	)		GETBYTE(x,i) |= ( 0x01 << ( (i) % BITBYTE ) )

Definition at line 43 of file hstore_gist.c.

SIGLEN_DEFAULT

#define SIGLEN_DEFAULT   (sizeof(int32) * 4)

Definition at line 23 of file hstore_gist.c.

SIGLEN_MAX

#define SIGLEN_MAX   GISTMaxIndexKeySize

Definition at line 24 of file hstore_gist.c.

SIGLENBIT

#define SIGLENBIT

(

siglen

)

((siglen) * BITBYTE)

Definition at line 25 of file hstore_gist.c.

SUMBIT

#define SUMBIT

(

val

)

Value:

    (       \
	GETBITBYTE((val),0) + \
	GETBITBYTE((val),1) + \
	GETBITBYTE((val),2) + \
	GETBITBYTE((val),3) + \
	GETBITBYTE((val),4) + \
	GETBITBYTE((val),5) + \
	GETBITBYTE((val),6) + \
	GETBITBYTE((val),7)   \
)

Definition at line 64 of file hstore_gist.c.

WISH_F

#define WISH_F	(		a,
			b,
			c
	)		(double)( -(double)(((a)-(b))*((a)-(b))*((a)-(b)))*(c) )

Definition at line 77 of file hstore_gist.c.

Typedef Documentation

BITVECP

typedef char* BITVECP

Definition at line 31 of file hstore_gist.c.

Function Documentation

comparecost()

static int comparecost ( const void *  a, const void *  b  )

static

Definition at line 358 of file hstore_gist.c.

{
    return pg_cmp_s32(((const SPLITCOST *) a)->cost,
                      ((const SPLITCOST *) b)->cost);
}

References a, b, and pg_cmp_s32().

Referenced by ghstore_picksplit().

crc32_sz()

static pg_crc32 crc32_sz ( const char *  buf, int  size  )

static

Definition at line 81 of file hstore_gist.c.

{
    pg_crc32    crc;
 
    INIT_TRADITIONAL_CRC32(crc);
    COMP_TRADITIONAL_CRC32(crc, buf, size);
    FIN_TRADITIONAL_CRC32(crc);
 
    return crc;
}

References buf, COMP_TRADITIONAL_CRC32, crc, FIN_TRADITIONAL_CRC32, and INIT_TRADITIONAL_CRC32.

Referenced by ghstore_compress(), and ghstore_consistent().

ghstore_alloc()

static GISTTYPE * ghstore_alloc ( bool  allistrue, int  siglen, BITVECP  sign  )

static

Definition at line 118 of file hstore_gist.c.

{
    int         flag = allistrue ? ALLISTRUE : 0;
    int         size = CALCGTSIZE(flag, siglen);
    GISTTYPE   *res = palloc(size);
 
    SET_VARSIZE(res, size);
    res->flag = flag;
 
    if (!allistrue)
    {
        if (sign)
            memcpy(GETSIGN(res), sign, siglen);
        else
            memset(GETSIGN(res), 0, siglen);
    }
 
    return res;
}

References ALLISTRUE, CALCGTSIZE, fb(), GISTTYPE::flag, flag(), GETSIGN, palloc(), SET_VARSIZE(), and sign.

Referenced by ghstore_compress(), ghstore_picksplit(), and ghstore_union().

ghstore_compress()

Datum ghstore_compress

(

PG_FUNCTION_ARGS

)

Definition at line 148 of file hstore_gist.c.

{
    GISTENTRY  *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
    int         siglen = GET_SIGLEN();
    GISTENTRY  *retval = entry;
 
    if (entry->leafkey)
    {
        GISTTYPE   *res = ghstore_alloc(false, siglen, NULL);
        HStore     *val = DatumGetHStoreP(entry->key);
        HEntry     *hsent = ARRPTR(val);
        char       *ptr = STRPTR(val);
        int         count = HS_COUNT(val);
        int         i;
 
        for (i = 0; i < count; ++i)
        {
            int         h;
 
            h = crc32_sz((char *) HSTORE_KEY(hsent, ptr, i),
                         HSTORE_KEYLEN(hsent, i));
            HASH(GETSIGN(res), h, siglen);
            if (!HSTORE_VALISNULL(hsent, i))
            {
                h = crc32_sz((char *) HSTORE_VAL(hsent, ptr, i),
                             HSTORE_VALLEN(hsent, i));
                HASH(GETSIGN(res), h, siglen);
            }
        }
 
        retval = palloc_object(GISTENTRY);
        gistentryinit(*retval, PointerGetDatum(res),
                      entry->rel, entry->page,
                      entry->offset,
                      false);
    }
    else if (!ISALLTRUE(DatumGetPointer(entry->key)))
    {
        int32       i;
        GISTTYPE   *res;
        BITVECP     sign = GETSIGN(DatumGetPointer(entry->key));
 
        LOOPBYTE(siglen)
        {
            if ((sign[i] & 0xff) != 0xff)
                PG_RETURN_POINTER(retval);
        }
 
        res = ghstore_alloc(true, siglen, NULL);
 
        retval = palloc_object(GISTENTRY);
        gistentryinit(*retval, PointerGetDatum(res),
                      entry->rel, entry->page,
                      entry->offset,
                      false);
    }
 
    PG_RETURN_POINTER(retval);
}

References ARRPTR, crc32_sz(), DatumGetHStoreP, DatumGetPointer(), fb(), GET_SIGLEN, GETSIGN, ghstore_alloc(), gistentryinit, HASH, HS_COUNT, HSTORE_KEY, HSTORE_KEYLEN, HSTORE_VAL, HSTORE_VALISNULL, HSTORE_VALLEN, i, ISALLTRUE, GISTENTRY::key, GISTENTRY::leafkey, LOOPBYTE, GISTENTRY::offset, GISTENTRY::page, palloc_object, PG_GETARG_POINTER, PG_RETURN_POINTER, PointerGetDatum(), GISTENTRY::rel, sign, STRPTR, and val.

ghstore_consistent()

Datum ghstore_consistent

(

PG_FUNCTION_ARGS

)

Definition at line 509 of file hstore_gist.c.

{
    GISTTYPE   *entry = (GISTTYPE *) DatumGetPointer(((GISTENTRY *) PG_GETARG_POINTER(0))->key);
    StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
#ifdef NOT_USED
    Oid         subtype = PG_GETARG_OID(3);
#endif
    bool       *recheck = (bool *) PG_GETARG_POINTER(4);
    int         siglen = GET_SIGLEN();
    bool        res = true;
    BITVECP     sign;
 
    /* All cases served by this function are inexact */
    *recheck = true;
 
    if (ISALLTRUE(entry))
        PG_RETURN_BOOL(true);
 
    sign = GETSIGN(entry);
 
    if (strategy == HStoreContainsStrategyNumber ||
        strategy == HStoreOldContainsStrategyNumber)
    {
        HStore     *query = PG_GETARG_HSTORE_P(1);
        HEntry     *qe = ARRPTR(query);
        char       *qv = STRPTR(query);
        int         count = HS_COUNT(query);
        int         i;
 
        for (i = 0; res && i < count; ++i)
        {
            int         crc = crc32_sz((char *) HSTORE_KEY(qe, qv, i),
                                       HSTORE_KEYLEN(qe, i));
 
            if (GETBIT(sign, HASHVAL(crc, siglen)))
            {
                if (!HSTORE_VALISNULL(qe, i))
                {
                    crc = crc32_sz((char *) HSTORE_VAL(qe, qv, i),
                                   HSTORE_VALLEN(qe, i));
                    if (!GETBIT(sign, HASHVAL(crc, siglen)))
                        res = false;
                }
            }
            else
                res = false;
        }
    }
    else if (strategy == HStoreExistsStrategyNumber)
    {
        text       *query = PG_GETARG_TEXT_PP(1);
        int         crc = crc32_sz(VARDATA_ANY(query), VARSIZE_ANY_EXHDR(query));
 
        res = (GETBIT(sign, HASHVAL(crc, siglen))) ? true : false;
    }
    else if (strategy == HStoreExistsAllStrategyNumber)
    {
        ArrayType  *query = PG_GETARG_ARRAYTYPE_P(1);
        Datum      *key_datums;
        bool       *key_nulls;
        int         key_count;
        int         i;
 
        deconstruct_array_builtin(query, TEXTOID, &key_datums, &key_nulls, &key_count);
 
        for (i = 0; res && i < key_count; ++i)
        {
            int         crc;
 
            if (key_nulls[i])
                continue;
            crc = crc32_sz(VARDATA(DatumGetPointer(key_datums[i])), VARSIZE(DatumGetPointer(key_datums[i])) - VARHDRSZ);
            if (!(GETBIT(sign, HASHVAL(crc, siglen))))
                res = false;
        }
    }
    else if (strategy == HStoreExistsAnyStrategyNumber)
    {
        ArrayType  *query = PG_GETARG_ARRAYTYPE_P(1);
        Datum      *key_datums;
        bool       *key_nulls;
        int         key_count;
        int         i;
 
        deconstruct_array_builtin(query, TEXTOID, &key_datums, &key_nulls, &key_count);
 
        res = false;
 
        for (i = 0; !res && i < key_count; ++i)
        {
            int         crc;
 
            if (key_nulls[i])
                continue;
            crc = crc32_sz(VARDATA(DatumGetPointer(key_datums[i])), VARSIZE(DatumGetPointer(key_datums[i])) - VARHDRSZ);
            if (GETBIT(sign, HASHVAL(crc, siglen)))
                res = true;
        }
    }
    else
        elog(ERROR, "Unsupported strategy number: %d", strategy);
 
    PG_RETURN_BOOL(res);
}

References ARRPTR, crc, crc32_sz(), DatumGetPointer(), deconstruct_array_builtin(), elog, ERROR, fb(), GET_SIGLEN, GETBIT, GETSIGN, HASHVAL, HS_COUNT, HSTORE_KEY, HSTORE_KEYLEN, HSTORE_VAL, HSTORE_VALISNULL, HSTORE_VALLEN, HStoreContainsStrategyNumber, HStoreExistsAllStrategyNumber, HStoreExistsAnyStrategyNumber, HStoreExistsStrategyNumber, HStoreOldContainsStrategyNumber, i, ISALLTRUE, PG_GETARG_ARRAYTYPE_P, PG_GETARG_HSTORE_P, PG_GETARG_OID, PG_GETARG_POINTER, PG_GETARG_TEXT_PP, PG_GETARG_UINT16, PG_RETURN_BOOL, sign, STRPTR, VARDATA(), VARDATA_ANY(), VARHDRSZ, VARSIZE(), and VARSIZE_ANY_EXHDR().

ghstore_decompress()

Datum ghstore_decompress

(

PG_FUNCTION_ARGS

)

Definition at line 213 of file hstore_gist.c.

{
    PG_RETURN_POINTER(PG_GETARG_POINTER(0));
}

References PG_GETARG_POINTER, and PG_RETURN_POINTER.

ghstore_in()

Datum ghstore_in

(

PG_FUNCTION_ARGS

)

Definition at line 98 of file hstore_gist.c.

{
    ereport(ERROR,
            (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
             errmsg("cannot accept a value of type %s", "ghstore")));
 
    PG_RETURN_VOID();           /* keep compiler quiet */
}

References ereport, errcode(), errmsg(), ERROR, fb(), and PG_RETURN_VOID.

ghstore_options()

Datum ghstore_options

(

PG_FUNCTION_ARGS

)

Definition at line 615 of file hstore_gist.c.

{
    local_relopts *relopts = (local_relopts *) PG_GETARG_POINTER(0);
 
    init_local_reloptions(relopts, sizeof(GistHstoreOptions));
    add_local_int_reloption(relopts, "siglen",
                            "signature length in bytes",
                            SIGLEN_DEFAULT, 1, SIGLEN_MAX,
                            offsetof(GistHstoreOptions, siglen));
 
    PG_RETURN_VOID();
}

References add_local_int_reloption(), fb(), init_local_reloptions(), PG_GETARG_POINTER, PG_RETURN_VOID, SIGLEN_DEFAULT, and SIGLEN_MAX.

ghstore_out()

Datum ghstore_out

(

PG_FUNCTION_ARGS

)

Definition at line 108 of file hstore_gist.c.

{
    ereport(ERROR,
            (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
             errmsg("cannot display a value of type %s", "ghstore")));
 
    PG_RETURN_VOID();           /* keep compiler quiet */
}

References ereport, errcode(), errmsg(), ERROR, fb(), and PG_RETURN_VOID.

ghstore_penalty()

Datum ghstore_penalty

(

PG_FUNCTION_ARGS

)

Definition at line 337 of file hstore_gist.c.

{
    GISTENTRY  *origentry = (GISTENTRY *) PG_GETARG_POINTER(0); /* always ISSIGNKEY */
    GISTENTRY  *newentry = (GISTENTRY *) PG_GETARG_POINTER(1);
    float      *penalty = (float *) PG_GETARG_POINTER(2);
    int         siglen = GET_SIGLEN();
    GISTTYPE   *origval = (GISTTYPE *) DatumGetPointer(origentry->key);
    GISTTYPE   *newval = (GISTTYPE *) DatumGetPointer(newentry->key);
 
    *penalty = hemdist(origval, newval, siglen);
    PG_RETURN_POINTER(penalty);
}

References DatumGetPointer(), fb(), GET_SIGLEN, hemdist(), newval, PG_GETARG_POINTER, and PG_RETURN_POINTER.

ghstore_picksplit()

Datum ghstore_picksplit

(

PG_FUNCTION_ARGS

)

Definition at line 366 of file hstore_gist.c.

{
    GistEntryVector *entryvec = (GistEntryVector *) PG_GETARG_POINTER(0);
    OffsetNumber maxoff = entryvec->n - 2;
 
    GIST_SPLITVEC *v = (GIST_SPLITVEC *) PG_GETARG_POINTER(1);
    int         siglen = GET_SIGLEN();
    OffsetNumber k,
                j;
    GISTTYPE   *datum_l,
               *datum_r;
    BITVECP     union_l,
                union_r;
    int32       size_alpha,
                size_beta;
    int32       size_waste,
                waste = -1;
    int32       nbytes;
    OffsetNumber seed_1 = 0,
                seed_2 = 0;
    OffsetNumber *left,
               *right;
    BITVECP     ptr;
    int         i;
    SPLITCOST  *costvector;
    GISTTYPE   *_k,
               *_j;
 
    nbytes = (maxoff + 2) * sizeof(OffsetNumber);
    v->spl_left = (OffsetNumber *) palloc(nbytes);
    v->spl_right = (OffsetNumber *) palloc(nbytes);
 
    for (k = FirstOffsetNumber; k < maxoff; k = OffsetNumberNext(k))
    {
        _k = GETENTRY(entryvec, k);
        for (j = OffsetNumberNext(k); j <= maxoff; j = OffsetNumberNext(j))
        {
            size_waste = hemdist(_k, GETENTRY(entryvec, j), siglen);
            if (size_waste > waste)
            {
                waste = size_waste;
                seed_1 = k;
                seed_2 = j;
            }
        }
    }
 
    left = v->spl_left;
    v->spl_nleft = 0;
    right = v->spl_right;
    v->spl_nright = 0;
 
    if (seed_1 == 0 || seed_2 == 0)
    {
        seed_1 = 1;
        seed_2 = 2;
    }
 
    /* form initial .. */
    datum_l = ghstore_alloc(ISALLTRUE(GETENTRY(entryvec, seed_1)), siglen,
                            GETSIGN(GETENTRY(entryvec, seed_1)));
    datum_r = ghstore_alloc(ISALLTRUE(GETENTRY(entryvec, seed_2)), siglen,
                            GETSIGN(GETENTRY(entryvec, seed_2)));
 
    maxoff = OffsetNumberNext(maxoff);
    /* sort before ... */
    costvector = palloc_array(SPLITCOST, maxoff);
    for (j = FirstOffsetNumber; j <= maxoff; j = OffsetNumberNext(j))
    {
        costvector[j - 1].pos = j;
        _j = GETENTRY(entryvec, j);
        size_alpha = hemdist(datum_l, _j, siglen);
        size_beta = hemdist(datum_r, _j, siglen);
        costvector[j - 1].cost = abs(size_alpha - size_beta);
    }
    qsort(costvector, maxoff, sizeof(SPLITCOST), comparecost);
 
    union_l = GETSIGN(datum_l);
    union_r = GETSIGN(datum_r);
 
    for (k = 0; k < maxoff; k++)
    {
        j = costvector[k].pos;
        if (j == seed_1)
        {
            *left++ = j;
            v->spl_nleft++;
            continue;
        }
        else if (j == seed_2)
        {
            *right++ = j;
            v->spl_nright++;
            continue;
        }
        _j = GETENTRY(entryvec, j);
        size_alpha = hemdist(datum_l, _j, siglen);
        size_beta = hemdist(datum_r, _j, siglen);
 
        if (size_alpha < size_beta + WISH_F(v->spl_nleft, v->spl_nright, 0.0001))
        {
            if (ISALLTRUE(datum_l) || ISALLTRUE(_j))
            {
                if (!ISALLTRUE(datum_l))
                    memset(union_l, 0xff, siglen);
            }
            else
            {
                ptr = GETSIGN(_j);
                LOOPBYTE(siglen)
                    union_l[i] |= ptr[i];
            }
            *left++ = j;
            v->spl_nleft++;
        }
        else
        {
            if (ISALLTRUE(datum_r) || ISALLTRUE(_j))
            {
                if (!ISALLTRUE(datum_r))
                    memset(union_r, 0xff, siglen);
            }
            else
            {
                ptr = GETSIGN(_j);
                LOOPBYTE(siglen)
                    union_r[i] |= ptr[i];
            }
            *right++ = j;
            v->spl_nright++;
        }
    }
 
    *right = *left = FirstOffsetNumber;
 
    v->spl_ldatum = PointerGetDatum(datum_l);
    v->spl_rdatum = PointerGetDatum(datum_r);
 
    PG_RETURN_POINTER(v);
}

References comparecost(), fb(), FirstOffsetNumber, GET_SIGLEN, GETENTRY, GETSIGN, ghstore_alloc(), hemdist(), i, ISALLTRUE, j, LOOPBYTE, GistEntryVector::n, OffsetNumberNext, palloc(), palloc_array, PG_GETARG_POINTER, PG_RETURN_POINTER, PointerGetDatum(), qsort, GIST_SPLITVEC::spl_ldatum, GIST_SPLITVEC::spl_left, GIST_SPLITVEC::spl_nleft, GIST_SPLITVEC::spl_nright, GIST_SPLITVEC::spl_rdatum, GIST_SPLITVEC::spl_right, and WISH_F.

ghstore_same()

Datum ghstore_same

(

PG_FUNCTION_ARGS

)

Definition at line 219 of file hstore_gist.c.

{
    GISTTYPE   *a = (GISTTYPE *) PG_GETARG_POINTER(0);
    GISTTYPE   *b = (GISTTYPE *) PG_GETARG_POINTER(1);
    bool       *result = (bool *) PG_GETARG_POINTER(2);
    int         siglen = GET_SIGLEN();
 
 
    if (ISALLTRUE(a) && ISALLTRUE(b))
        *result = true;
    else if (ISALLTRUE(a))
        *result = false;
    else if (ISALLTRUE(b))
        *result = false;
    else
    {
        int32       i;
        BITVECP     sa = GETSIGN(a),
                    sb = GETSIGN(b);
 
        *result = true;
        LOOPBYTE(siglen)
        {
            if (sa[i] != sb[i])
            {
                *result = false;
                break;
            }
        }
    }
    PG_RETURN_POINTER(result);
}

References a, b, fb(), GET_SIGLEN, GETSIGN, i, ISALLTRUE, LOOPBYTE, PG_GETARG_POINTER, and PG_RETURN_POINTER.

ghstore_union()

Datum ghstore_union

(

PG_FUNCTION_ARGS

)

Definition at line 310 of file hstore_gist.c.

{
    GistEntryVector *entryvec = (GistEntryVector *) PG_GETARG_POINTER(0);
    int32       len = entryvec->n;
 
    int        *size = (int *) PG_GETARG_POINTER(1);
    int         siglen = GET_SIGLEN();
    int32       i;
    GISTTYPE   *result = ghstore_alloc(false, siglen, NULL);
    BITVECP     base = GETSIGN(result);
 
    for (i = 0; i < len; i++)
    {
        if (unionkey(base, GETENTRY(entryvec, i), siglen))
        {
            result->flag |= ALLISTRUE;
            SET_VARSIZE(result, CALCGTSIZE(ALLISTRUE, siglen));
            break;
        }
    }
 
    *size = VARSIZE(result);
 
    PG_RETURN_POINTER(result);
}

References ALLISTRUE, CALCGTSIZE, fb(), GISTTYPE::flag, GET_SIGLEN, GETENTRY, GETSIGN, ghstore_alloc(), i, len, GistEntryVector::n, PG_GETARG_POINTER, PG_RETURN_POINTER, SET_VARSIZE(), unionkey(), and VARSIZE().

hemdist()

static int hemdist ( GISTTYPE *  a, GISTTYPE *  b, int  siglen  )

static

Definition at line 281 of file hstore_gist.c.

{
    if (ISALLTRUE(a))
    {
        if (ISALLTRUE(b))
            return 0;
        else
            return SIGLENBIT(siglen) - sizebitvec(GETSIGN(b), siglen);
    }
    else if (ISALLTRUE(b))
        return SIGLENBIT(siglen) - sizebitvec(GETSIGN(a), siglen);
 
    return hemdistsign(GETSIGN(a), GETSIGN(b), siglen);
}

References a, b, GETSIGN, hemdistsign(), ISALLTRUE, SIGLENBIT, and sizebitvec().

Referenced by ghstore_penalty(), and ghstore_picksplit().

hemdistsign()

static int hemdistsign ( BITVECP  a, BITVECP  b, int  siglen  )

static

Definition at line 267 of file hstore_gist.c.

{
    int         i,
                dist = 0;
 
    LOOPBIT(siglen)
    {
        if (GETBIT(a, i) != GETBIT(b, i))
            dist++;
    }
    return dist;
}

References a, b, fb(), GETBIT, i, and LOOPBIT.

Referenced by hemdist().

PG_FUNCTION_INFO_V1() [1/10]

PG_FUNCTION_INFO_V1

(

ghstore_compress

)

PG_FUNCTION_INFO_V1() [2/10]

PG_FUNCTION_INFO_V1

(

ghstore_consistent

)

PG_FUNCTION_INFO_V1() [3/10]

PG_FUNCTION_INFO_V1

(

ghstore_decompress

)

PG_FUNCTION_INFO_V1() [4/10]

PG_FUNCTION_INFO_V1

(

ghstore_in

)

PG_FUNCTION_INFO_V1() [5/10]

PG_FUNCTION_INFO_V1

(

ghstore_options

)

PG_FUNCTION_INFO_V1() [6/10]

PG_FUNCTION_INFO_V1

(

ghstore_out

)

PG_FUNCTION_INFO_V1() [7/10]

PG_FUNCTION_INFO_V1

(

ghstore_penalty

)

PG_FUNCTION_INFO_V1() [8/10]

PG_FUNCTION_INFO_V1

(

ghstore_picksplit

)

PG_FUNCTION_INFO_V1() [9/10]

PG_FUNCTION_INFO_V1

(

ghstore_same

)

PG_FUNCTION_INFO_V1() [10/10]

PG_FUNCTION_INFO_V1

(

ghstore_union

)

sizebitvec()

static int32 sizebitvec ( BITVECP  sign, int  siglen  )

static

Definition at line 253 of file hstore_gist.c.

{
    int32       size = 0,
                i;
 
    LOOPBYTE(siglen)
    {
        size += SUMBIT(sign);
        sign = (BITVECP) (((char *) sign) + 1);
    }
    return size;
}

References i, LOOPBYTE, sign, and SUMBIT.

Referenced by hemdist().

unionkey()

static int32 unionkey ( BITVECP  sbase, GISTTYPE *  add, int  siglen  )

static

Definition at line 297 of file hstore_gist.c.

{
    int32       i;
    BITVECP     sadd = GETSIGN(add);
 
    if (ISALLTRUE(add))
        return 1;
    LOOPBYTE(siglen)
        sbase[i] |= sadd[i];
    return 0;
}

References fb(), GETSIGN, i, ISALLTRUE, and LOOPBYTE.

Referenced by ghstore_union().