Fix GiST's killing tuple: GISTScanOpaque->curpos wasn't

correctly set. As result, killtuple() marks as dead
wrong tuple on page. Bug was introduced by me while fixing
possible duplicates during GiST index scan.

diff --git a/src/backend/access/gist/gistget.c b/src/backend/access/gist/gistget.c
index 4d4ba07739a884915b53186c0131762dc7ce2dd8..4742e45c13b0f5c6d0100f99348c76b35acd606a 100644 (file)
--- a/src/backend/access/gist/gistget.c
+++ b/src/backend/access/gist/gistget.c
@@ -153,7 +153,11 @@ gistnext(IndexScanDesc scan, ScanDirection dir, ItemPointer tids, int maxtids, b
        {
                while( ntids < maxtids && so->curPageData < so->nPageData )
                {
-                       tids[ ntids ] = scan->xs_ctup.t_self = so->pageData[ so->curPageData ];
+                       tids[ ntids ] = scan->xs_ctup.t_self = so->pageData[ so->curPageData ].heapPtr;
+                       ItemPointerSet(&scan->currentItemData,
+                                                          BufferGetBlockNumber(so->curbuf), 
+                                                          so->pageData[ so->curPageData ].pageOffset);
+
                                
                        so->curPageData ++;
                        ntids++;
@@ -247,8 +251,13 @@ gistnext(IndexScanDesc scan, ScanDirection dir, ItemPointer tids, int maxtids, b
                        {
                                while( ntids < maxtids && so->curPageData < so->nPageData )
                                {
-                                       tids[ ntids ] = scan->xs_ctup.t_self = so->pageData[ so->curPageData ];
+                                       tids[ ntids ] = scan->xs_ctup.t_self = 
+                                               so->pageData[ so->curPageData ].heapPtr;
                                
+                                       ItemPointerSet(&scan->currentItemData,
+                                                                  BufferGetBlockNumber(so->curbuf), 
+                                                                  so->pageData[ so->curPageData ].pageOffset);
+
                                        so->curPageData ++;
                                        ntids++;
                                }
@@ -293,13 +302,11 @@ gistnext(IndexScanDesc scan, ScanDirection dir, ItemPointer tids, int maxtids, b
                                 * we can efficiently resume the index scan later.
                                 */
 
-                               ItemPointerSet(&(scan->currentItemData),
-                                                          BufferGetBlockNumber(so->curbuf), n);
-
                                if (!(ignore_killed_tuples && ItemIdDeleted(PageGetItemId(p, n))))
                                {
                                        it = (IndexTuple) PageGetItem(p, PageGetItemId(p, n));
-                                       so->pageData[ so->nPageData ] = it->t_tid;
+                                       so->pageData[ so->nPageData ].heapPtr = it->t_tid;
+                                       so->pageData[ so->nPageData ].pageOffset = n;
                                        so->nPageData ++;
                                }
                        }

diff --git a/src/backend/access/gist/gistscan.c b/src/backend/access/gist/gistscan.c
index 0414e3b3e1840d95fba8c5066df6721cfb3088ee..3b1ce37217e5225ca2bf7a09f8a8dbe50e86bdec 100644 (file)
--- a/src/backend/access/gist/gistscan.c
+++ b/src/backend/access/gist/gistscan.c
@@ -154,7 +154,7 @@ gistmarkpos(PG_FUNCTION_ARGS)
        so->markNPageData = so->nPageData;
        so->markCurPageData = so->curPageData;
        if ( so->markNPageData > 0 )
-               memcpy( so->markPageData, so->pageData, sizeof(ItemPointerData) * so->markNPageData );          
+               memcpy( so->markPageData, so->pageData, sizeof(MatchedItemPtr) * so->markNPageData );           
 
        PG_RETURN_VOID();
 }
@@ -208,7 +208,7 @@ gistrestrpos(PG_FUNCTION_ARGS)
        so->nPageData = so->markNPageData;
        so->curPageData = so->markNPageData;
        if ( so->markNPageData > 0 )
-               memcpy( so->pageData, so->markPageData, sizeof(ItemPointerData) * so->markNPageData );          
+               memcpy( so->pageData, so->markPageData, sizeof(MatchedItemPtr) * so->markNPageData );           
 
        PG_RETURN_VOID();
 }

diff --git a/src/include/access/gist_private.h b/src/include/access/gist_private.h
index 1407bbad1a476fc615de2ad33ec97fa195e82525..7409fb6f99ca3cc6c9307f51a891a3480318b238 100644 (file)
--- a/src/include/access/gist_private.h
+++ b/src/include/access/gist_private.h
@@ -60,6 +60,12 @@ typedef struct GISTSTATE
        TupleDesc       tupdesc;
 } GISTSTATE;
 
+typedef struct MatchedItemPtr 
+{
+       ItemPointerData         heapPtr;
+       OffsetNumber            pageOffset; /* offset in index page */
+} MatchedItemPtr;
+
 /*
  *     When we're doing a scan, we need to keep track of the parent stack
  *     for the marked and current items.
@@ -74,10 +80,10 @@ typedef struct GISTScanOpaqueData
        Buffer          curbuf;
        Buffer          markbuf;
 
-       ItemPointerData pageData[BLCKSZ/sizeof(IndexTupleData)];
+       MatchedItemPtr  pageData[BLCKSZ/sizeof(IndexTupleData)];
        OffsetNumber    nPageData;
        OffsetNumber    curPageData;
-       ItemPointerData markPageData[BLCKSZ/sizeof(IndexTupleData)];
+       MatchedItemPtr  markPageData[BLCKSZ/sizeof(IndexTupleData)];
        OffsetNumber    markNPageData;
        OffsetNumber    markCurPageData;
 } GISTScanOpaqueData;