liuyu/pgvector
1
0
Fork 0
mirror of https://github.com/pgvector/pgvector.git synced 2026-07-11 23:26:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove unused 'scantuplesortstates' field

Browse Source
This commit is contained in:
Heikki Linnakangas
2024-01-18 19:56:17 +02:00
committed by Andrew Kane
parent 88213186a5
commit d96e486274
2 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/hnsw.h
View File

@@ -212,7 +212,6 @@ typedef struct HnswShared
Oid heaprelid; Oid heaprelid;
Oid indexrelid; Oid indexrelid;
bool isconcurrent; bool isconcurrent;
int scantuplesortstates;
/* Worker progress */ /* Worker progress */
ConditionVariable workersdonecv; ConditionVariable workersdonecv;

4
src/hnswbuild.c
View File

@@ -897,7 +897,6 @@ static void
HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request) HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request)
{ {
ParallelContext *pcxt; ParallelContext *pcxt;
int scantuplesortstates;
Snapshot snapshot; Snapshot snapshot;
Size esthnswshared; Size esthnswshared;
Size esthnswarea; Size esthnswarea;
@@ -921,8 +920,6 @@ HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request)
pcxt = CreateParallelContext("vector", "HnswParallelBuildMain", request, true); pcxt = CreateParallelContext("vector", "HnswParallelBuildMain", request, true);
#endif #endif
scantuplesortstates = leaderparticipates ? request + 1 : request;
/* Get snapshot for table scan */ /* Get snapshot for table scan */
if (!isconcurrent) if (!isconcurrent)
snapshot = SnapshotAny; snapshot = SnapshotAny;
@@ -973,7 +970,6 @@ HnswBeginParallel(HnswBuildState * buildstate, bool isconcurrent, int request)
hnswshared->heaprelid = RelationGetRelid(buildstate->heap); hnswshared->heaprelid = RelationGetRelid(buildstate->heap);
hnswshared->indexrelid = RelationGetRelid(buildstate->index); hnswshared->indexrelid = RelationGetRelid(buildstate->index);
hnswshared->isconcurrent = isconcurrent; hnswshared->isconcurrent = isconcurrent;
hnswshared->scantuplesortstates = scantuplesortstates;
ConditionVariableInit(&hnswshared->workersdonecv); ConditionVariableInit(&hnswshared->workersdonecv);
SpinLockInit(&hnswshared->mutex); SpinLockInit(&hnswshared->mutex);
/* Initialize mutable state */ /* Initialize mutable state */