From c43fc9dedfe20c31ebfedc30e698c91c483f098e Mon Sep 17 00:00:00 2001 From: Andrew Kane Date: Fri, 25 Sep 2026 17:45:28 -0700 Subject: [PATCH] Switched to READ_STREAM_FULL and read_stream_pause [skip ci] --- src/hnswutils.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/hnswutils.c b/src/hnswutils.c index 4356386..1782c22 100644 --- a/src/hnswutils.c +++ b/src/hnswutils.c @@ -829,7 +829,7 @@ HnswReadStreamNextBlock(ReadStream *stream, void *callback_private_data, void *p HnswUnvisited *uv; if (streamData->visited == streamData->unvisitedLength) - return InvalidBlockNumber; + return read_stream_pause(stream); uv = &streamData->unvisited[streamData->visited++]; *offno = ItemPointerGetOffsetNumber(&uv->indextid); @@ -862,7 +862,7 @@ HnswSearchLayer(char *base, HnswQuery * q, List *ep, int ef, int lc, Relation in if (!inMemory) { - int flags = READ_STREAM_USE_BATCHING; + int flags = READ_STREAM_FULL; if (maintenance) flags |= READ_STREAM_MAINTENANCE;