database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-07-28 23:42:10 +03:00
Code Activity

Initialize the entryRes array between each call to triConsistent.

Browse Source 
The shimTriConstistentFn, which calls the opclass's consistent function with
all combinations of TRUE/FALSE for any MAYBE argument, modifies the entryRes
array passed by the caller. Change startScanKey to re-initialize it between
each call to accommodate that.

It's actually a bad habit by shimTriConsistentFn to modify its argument. But
the only caller that doesn't already re-initialize the entryRes array was
startScanKey, and it's easy for startScanKey to do so. Add a comment to
shimTriConsistentFn about that.

Note: this does not give a free pass to opclass-provided consistent
functions to modify the entryRes argument; shimTriConsistent assumes that
they don't, even though it does it itself.

While at it, refactor startScanKey to allocate the requiredEntries and
additionalEntries after it knows exactly how large they need to be. Saves a
little bit of memory, and looks nicer anyway.

Per complaint by Tom Lane, buildfarm and the pg_trgm regression test.
This commit is contained in:
Heikki Linnakangas
2014-02-07 18:41:01 +02:00
parent dbc649fd77
commit 6aa2bdf6a0
2 changed files with 29 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
src/backend/access/gin/ginget.c
View File

@ -445,6 +445,7 @@ startScanKey(GinState *ginstate, GinScanOpaque so, GinScanKey key)
{
MemoryContext oldCtx = CurrentMemoryContext;
int i;
int j;
int *entryIndexes;
ItemPointerSetMin(&key->curItem);
@ -472,10 +473,6 @@ startScanKey(GinState *ginstate, GinScanOpaque so, GinScanKey key)
* entries can form a match, without any items from the required set. The
* rest go to the additional set.
*/
key->requiredEntries = palloc(key->nentries * sizeof(GinScanEntry));
key->additionalEntries = palloc(key->nentries * sizeof(GinScanEntry));
key->nrequired = key->nadditional = 0;
if (key->nentries > 1)
{
MemoryContextSwitchTo(so->tempCtx);
@ -483,31 +480,44 @@ startScanKey(GinState *ginstate, GinScanOpaque so, GinScanKey key)
entryIndexes = (int *) palloc(sizeof(int) * key->nentries);
for (i = 0; i < key->nentries; i++)
entryIndexes[i] = i;
qsort_arg(entryIndexes, key->nentries, sizeof(int),
entryIndexByFrequencyCmp, key);
for (i = 0; i < key->nentries; i++)
key->entryRes[i] = GIN_MAYBE;
for (i = 0; i < key->nentries; i++)
for (i = 0; i < key->nentries - 1; i++)
{
key->requiredEntries[key->nrequired++] = key->scanEntry[entryIndexes[i]];
key->entryRes[entryIndexes[i]] = GIN_FALSE;
/* Pass all entries <= i as FALSE, and the rest as MAYBE */
for (j = 0; j <= i; j++)
key->entryRes[entryIndexes[j]] = GIN_FALSE;
for (j = i + 1; j < key->nentries; j++)
key->entryRes[entryIndexes[j]] = GIN_MAYBE;
if (key->triConsistentFn(key) == GIN_FALSE)
break;
}
for (i = i + 1; i < key->nentries; i++)
key->additionalEntries[key->nadditional++] = key->scanEntry[entryIndexes[i]];
/* i is now the last required entry. */
MemoryContextSwitchTo(oldCtx);
key->nrequired = i + 1;
key->nadditional = key->nentries - key->nrequired;
key->requiredEntries = palloc(key->nrequired * sizeof(GinScanEntry));
key->additionalEntries = palloc(key->nadditional * sizeof(GinScanEntry));
j = 0;
for (i = 0; i < key->nrequired; i++)
key->requiredEntries[i] = key->scanEntry[entryIndexes[j++]];
for (i = 0; i < key->nadditional; i++)
key->additionalEntries[i] = key->scanEntry[entryIndexes[j++]];
/* clean up after consistentFn calls (also frees entryIndexes) */
MemoryContextSwitchTo(oldCtx);
MemoryContextReset(so->tempCtx);
}
else
{
key->requiredEntries[key->nrequired++] = key->scanEntry[0];
key->nrequired = 1;
key->nadditional = 0;
key->requiredEntries = palloc(1 * sizeof(GinScanEntry));
key->requiredEntries[0] = key->scanEntry[0];
}
}