RE: [HACKERS] Re:HEAP_MOVED_IN during vacuum - test case

> -----Original Message-----
> From: owner-pgsql-hackers@postgreSQL.org
> [mailto:owner-pgsql-hackers@postgreSQL.org]On Behalf Of Stephen Birch
>
> I have now created a test case that demonstrate the HEAP_MOVED_IN during
> vacuum problem.  Since the tar ball is 182k - I put it on an ftp site
> instead of mailing it.
>
> You can grab it from the following location:
>
>  http://www.ironmountainsystems.com/heap_moved_in/
>

The following patch seems to fix your case.
However I'm not sure it's a right solution.

Regards.

Hiroshi Inoue
Inoue@tpf.co.jp

Index: commands/vacuum.c
===================================================================
RCS file: /home/cvs/pgcurrent/backend/commands/vacuum.c,v
retrieving revision 1.18
diff -c -r1.18 vacuum.c
*** commands/vacuum.c    2000/01/05 03:05:35    1.18
--- commands/vacuum.c    2000/01/10 02:39:35
***************
*** 1049,1054 ****
--- 1049,1055 ----                *idcur;     int            last_fraged_block,                 last_vacuum_block,
+                 last_movedin_block,                 i = 0;     Size        tuple_len;     int            num_moved,
***************
*** 1084,1089 ****
--- 1085,1091 ----     vacuumed_pages = vacuum_pages->vpl_num_pages -
vacuum_pages->vpl_empty_end_pages;     last_vacuum_page = vacuum_pages->vpl_pagedesc[vacuumed_pages - 1];
last_vacuum_block= last_vacuum_page->vpd_blkno;
 
+     last_movedin_block = 0;     Assert(last_vacuum_block >= last_fraged_block);     cur_buffer = InvalidBuffer;
num_moved= 0;
 
***************
*** 1097,1102 ****
--- 1099,1107 ----         /* if it's reapped page and it was used by me - quit */         if (blkno ==
last_fraged_block&& last_fraged_page->vpd_offsets_used >
 
0)             break;
+         /* couldn't shrink any more if this block has MOVED_INd tuples - quit */
+         if (blkno == last_movedin_block)
+             break;
         buf = ReadBuffer(onerel, blkno);         page = BufferGetPage(buf);
***************
*** 1477,1482 ****
--- 1482,1489 ----                     newtup.t_datamcxt = NULL;                     newtup.t_data = (HeapTupleHeader)
PageGetItem(ToPage,newitemid);                     ItemPointerSet(&(newtup.t_self), vtmove[ti].vpd->vpd_blkno,
newoff);
+                     if (vtmove[i].vpd->vpd_blkno > last_movedin_block)
+                         last_movedin_block = vtmove[i].vpd->vpd_blkno;
                     /*                      * Set t_ctid pointing to itself for last tuple in
***************
*** 1610,1615 ****
--- 1617,1624 ----             newtup.t_data = (HeapTupleHeader) PageGetItem(ToPage, newitemid);
ItemPointerSet(&(newtup.t_data->t_ctid),cur_page->vpd_blkno, newoff);             newtup.t_self =
newtup.t_data->t_ctid;
+             if (cur_page->vpd_blkno > last_movedin_block)
+                 last_movedin_block = cur_page->vpd_blkno;
             /*              * Mark old tuple as moved_off by vacuum and store vacuum XID