diff --git a/db/etl/buffers.go b/db/etl/buffers.go index f62144a8363..09e01ca0566 100644 --- a/db/etl/buffers.go +++ b/db/etl/buffers.go @@ -26,6 +26,7 @@ import ( "sync" "github.com/c2h5oh/datasize" + "github.com/erigontech/erigon/common/dbg" "github.com/erigontech/erigon/common" @@ -48,17 +49,13 @@ var BufferOptimalSize = dbg.EnvDataSize("ETL_OPTIMAL", 256*datasize.MB) /* var // 3_domains * 2 + 3_history * 1 + 4_indices * 2 = 17 etl collectors, 17*(256Mb/8) = 512Mb - for all collectros var etlSmallBufRAM = dbg.EnvDataSize("ETL_SMALL", BufferOptimalSize/8) -var SmallSortableBuffers = NewAllocator(&sync.Pool{ - New: func() any { - return NewSortableBuffer(etlSmallBufRAM).Prealloc(1_024, int(etlSmallBufRAM/32)) - }, -}) var etlLargeBufRAM = BufferOptimalSize var LargeSortableBuffers = NewAllocator(&sync.Pool{ New: func() any { return NewSortableBuffer(etlLargeBufRAM).Prealloc(1_024, int(etlLargeBufRAM/32)) }, }) +var SmallSortableBuffers = LargeSortableBuffers type Buffer interface { // Put does copy `k` and `v`