From da8a640a563d9ec1723731faa5faecb9ad58e834 Mon Sep 17 00:00:00 2001
From: JackDoan <me@jackdoan.com>
Date: Fri, 31 Jul 2026 12:18:12 -0500
Subject: [PATCH] QueueSet.Add errors if QueueSet is closed

---
 overlay/tio/queueset_gso_linux.go  | 3 +++
 overlay/tio/queueset_poll_linux.go | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/overlay/tio/queueset_gso_linux.go b/overlay/tio/queueset_gso_linux.go
index c422fb65..4a26193d 100644
--- a/overlay/tio/queueset_gso_linux.go
+++ b/overlay/tio/queueset_gso_linux.go
@@ -50,6 +50,9 @@ func (c *offloadQueueSet) Queues() []Queue {
 }
 
 func (c *offloadQueueSet) Add(fd int) error {
+	if c.closed.Load() {
+		return errors.New("queue set already closed")
+	}
 	x, err := newOffload(fd, c.shutdownFd, c.usoEnabled, c.l)
 	if err != nil {
 		return err
diff --git a/overlay/tio/queueset_poll_linux.go b/overlay/tio/queueset_poll_linux.go
index 0145ce35..f73deef2 100644
--- a/overlay/tio/queueset_poll_linux.go
+++ b/overlay/tio/queueset_poll_linux.go
@@ -40,6 +40,9 @@ func (c *pollQueueSet) Queues() []Queue {
 }
 
 func (c *pollQueueSet) Add(fd int) error {
+	if c.closed.Load() {
+		return errors.New("queue set already closed")
+	}
 	x, err := newPoll(fd, c.shutdownFd)
 	if err != nil {
 		return err