From 4e4a85a891e73b49838c72a0701abbc10983cb05 Mon Sep 17 00:00:00 2001
From: JackDoan <me@jackdoan.com>
Date: Thu, 13 Nov 2025 12:43:45 -0600
Subject: [PATCH] beeg chains

---
 overlay/virtqueue/split_virtqueue.go | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/overlay/virtqueue/split_virtqueue.go b/overlay/virtqueue/split_virtqueue.go
index 4c939a4..7b91b1b 100644
--- a/overlay/virtqueue/split_virtqueue.go
+++ b/overlay/virtqueue/split_virtqueue.go
@@ -34,7 +34,6 @@ type SplitQueue struct {
 	// used buffer notifications. It blocks until the goroutine ended.
 	stop func() error
 
-	pageSize int
 	itemSize int
 
 	epoll eventfd.Epoll
@@ -49,10 +48,15 @@ func NewSplitQueue(queueSize int) (_ *SplitQueue, err error) {
 		return nil, err
 	}
 
+	itemSize := os.Getpagesize() * 4 //todo config
+
+	if itemSize%os.Getpagesize() != 0 {
+		return nil, errors.New("split queue size must be multiple of os.Getpagesize()")
+	}
+
 	sq := SplitQueue{
 		size:     queueSize,
-		pageSize: os.Getpagesize(),
-		itemSize: os.Getpagesize(), //todo config
+		itemSize: itemSize,
 	}
 
 	// Clean up a partially initialized queue when something fails.
@@ -302,7 +306,7 @@ func (sq *SplitQueue) OfferOutDescriptorChains(prepend []byte, outBuffers [][]by
 	// TODO change this
 	// Each descriptor can only hold a whole memory page, so split large out
 	// buffers into multiple smaller ones.
-	outBuffers = splitBuffers(outBuffers, sq.pageSize)
+	outBuffers = splitBuffers(outBuffers, sq.itemSize)
 
 	chains := make([]uint16, len(outBuffers))