diff --git a/src/hnsw.h b/src/hnsw.h index a1ea020..9223688 100644 --- a/src/hnsw.h +++ b/src/hnsw.h @@ -170,7 +170,6 @@ typedef struct HnswShared Oid heaprelid; Oid indexrelid; bool isconcurrent; - int scantuplesortstates; /* Worker progress */ ConditionVariable workersdonecv; diff --git a/src/hnswbuild.c b/src/hnswbuild.c index 35c03d0..70551dd 100644 --- a/src/hnswbuild.c +++ b/src/hnswbuild.c @@ -771,7 +771,6 @@ static void HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request) { ParallelContext *pcxt; - int scantuplesortstates; Snapshot snapshot; Size esthnswshared; HnswShared *hnswshared; @@ -792,8 +791,6 @@ HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request) pcxt = CreateParallelContext("vector", "HnswParallelBuildMain", request, true); #endif - scantuplesortstates = leaderparticipates ? request + 1 : request; - /* Get snapshot for table scan */ if (!isconcurrent) snapshot = SnapshotAny; @@ -834,7 +831,6 @@ HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request) hnswshared->heaprelid = RelationGetRelid(buildstate->heap); hnswshared->indexrelid = RelationGetRelid(buildstate->index); hnswshared->isconcurrent = isconcurrent; - hnswshared->scantuplesortstates = scantuplesortstates; ConditionVariableInit(&hnswshared->workersdonecv); SpinLockInit(&hnswshared->mutex); /* Initialize mutable state */