mirror of
https://github.com/pgvector/pgvector.git
synced 2026-07-09 22:30:58 +08:00
Moved wait [skip ci]
This commit is contained in:
@@ -257,10 +257,6 @@ RepairGraphEntryPoint(HnswVacuumState * vacuumstate)
|
|||||||
* ideal.
|
* ideal.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
/* Wait for inserts to complete */
|
|
||||||
LockPage(index, HNSW_METAPAGE_BLKNO, ExclusiveLock);
|
|
||||||
UnlockPage(index, HNSW_METAPAGE_BLKNO, ExclusiveLock);
|
|
||||||
|
|
||||||
if (!BlockNumberIsValid(highestPoint->blkno))
|
if (!BlockNumberIsValid(highestPoint->blkno))
|
||||||
highestPoint = NULL;
|
highestPoint = NULL;
|
||||||
|
|
||||||
@@ -319,6 +315,10 @@ RepairGraph(HnswVacuumState * vacuumstate)
|
|||||||
|
|
||||||
RepairGraphEntryPoint(vacuumstate);
|
RepairGraphEntryPoint(vacuumstate);
|
||||||
|
|
||||||
|
/* Wait for inserts to complete */
|
||||||
|
LockPage(index, HNSW_METAPAGE_BLKNO, ExclusiveLock);
|
||||||
|
UnlockPage(index, HNSW_METAPAGE_BLKNO, ExclusiveLock);
|
||||||
|
|
||||||
while (BlockNumberIsValid(blkno))
|
while (BlockNumberIsValid(blkno))
|
||||||
{
|
{
|
||||||
Buffer buf;
|
Buffer buf;
|
||||||
|
|||||||
Reference in New Issue
Block a user