LockBuffer(srcBuf, BUFFER_LOCK_SHARE);
srcPage = BufferGetPage(srcBuf);
- /* Use P_NEW to extend the destination relation. */
dstBuf = ReadBufferWithoutRelcache(dstlocator, forkNum, blkno,
- RBM_NORMAL, bstrategy_dst,
+ RBM_ZERO_AND_LOCK, bstrategy_dst,
permanent);
- LockBuffer(dstBuf, BUFFER_LOCK_EXCLUSIVE);
dstPage = BufferGetPage(dstBuf);
START_CRIT_SECTION();
UnlockReleaseBuffer(dstBuf);
UnlockReleaseBuffer(srcBuf);
}
+
+ FreeAccessStrategy(bstrategy_src);
+ FreeAccessStrategy(bstrategy_dst);
}
/* ---------------------------------------------------------------------