merge main

Author: AskAlexSharov

db/seg/seg_paged_rw.go

@@ -32,46 +32,6 @@ import (
 
 var be = binary.BigEndian
 
-// Global pools for page work items and results - optimized for GC
-var (
-	pageWorkItemPool = sync.Pool{New: func() any { return &pageWorkItem{} }}
-	pageResultPool   = sync.Pool{New: func() any { return &pageResult{} }}
-)
-
-func getPageWorkItem() *pageWorkItem { return pageWorkItemPool.Get().(*pageWorkItem) }
-func putPageWorkItem(item *pageWorkItem) {
-	if item == nil {
-		return
-	}
-	item.seq = 0
-	item.uncompressedData = item.uncompressedData[:0]
-	pageWorkItemPool.Put(item)
-}
-
-func getPageResult() *pageResult { return pageResultPool.Get().(*pageResult) }
-func putPageResult(r *pageResult) {
-	r.seq = 0
-	r.data = r.data[:0]
-	pageResultPool.Put(r)
-}
-
-func drainResultCh(ch chan *pageResult) {
-	for {
-		select {
-		case r := <-ch:
-			putPageResult(r)
-		default:
-			return
-		}
-	}
-}
-
-func drainPendingResults(m map[int]*pageResult) {
-	for _, r := range m {
-		putPageResult(r)
-	}
-}
-
 func GetFromPage(key, compressedPage []byte, compressionBuf []byte, compressionEnabled bool) (v []byte, compressionBufOut []byte) {
 	var err error
 	var page []byte
@@ -619,3 +579,43 @@ func growslice(b []byte, wantLength int) []byte {
 	}
 	return make([]byte, wantLength)
 }
+
+// Global pools for page work items and results - optimized for GC
+var (
+	pageWorkItemPool = sync.Pool{New: func() any { return &pageWorkItem{} }}
+	pageResultPool   = sync.Pool{New: func() any { return &pageResult{} }}
+)
+
+func getPageWorkItem() *pageWorkItem { return pageWorkItemPool.Get().(*pageWorkItem) }
+func putPageWorkItem(item *pageWorkItem) {
+	if item == nil {
+		return
+	}
+	item.seq = 0
+	item.uncompressedData = item.uncompressedData[:0]
+	pageWorkItemPool.Put(item)
+}
+
+func getPageResult() *pageResult { return pageResultPool.Get().(*pageResult) }
+func putPageResult(r *pageResult) {
+	r.seq = 0
+	r.data = r.data[:0]
+	pageResultPool.Put(r)
+}
+
+func drainResultCh(ch chan *pageResult) {
+	for {
+		select {
+		case r := <-ch:
+			putPageResult(r)
+		default:
+			return
+		}
+	}
+}
+
+func drainPendingResults(m map[int]*pageResult) {
+	for _, r := range m {
+		putPageResult(r)
+	}
+}