try to keep capacity

xtaci · Oct 4, 2024 · 0989b9d · 0989b9d
1 parent 25dbaee
commit 0989b9d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/aio_bsd.go b/aio_bsd.go
@@ -106,7 +106,7 @@ func (p *poller) wakeup() error {
 
 // Wait waits for events happen on the file descriptors.
 func (p *poller) Wait(chSignal chan Signal) {
-	var pe pollerEvents
+	var eventSet pollerEvents
 	events := make([]syscall.Kevent_t, maxEvents)
 	sig := Signal{
 		done: make(chan struct{}, 1),
@@ -176,12 +176,12 @@ func (p *poller) Wait(chSignal chan Signal) {
 						e.ev |= EV_WRITE
 					}
 
-					pe = append(pe, e)
+					eventSet = append(eventSet, e)
 				}
 			}
 
 			// notify watcher
-			sig.events = pe
+			sig.events = eventSet
 
 			select {
 			case chSignal <- sig:
@@ -192,7 +192,7 @@ func (p *poller) Wait(chSignal chan Signal) {
 			// wait for the watcher to finish processing
 			select {
 			case <-sig.done:
-				pe = pe[:0]
+				eventSet = eventSet[:0:cap(eventSet)]
 			case <-p.die:
 				return
 			}

diff --git a/aio_linux.go b/aio_linux.go
@@ -186,7 +186,7 @@ func (p *poller) Wait(chSignal chan Signal) {
 			// wait for the watcher to finish processing
 			select {
 			case <-sig.done:
-				eventSet = eventSet[:0]
+				eventSet = eventSet[:0:cap(eventSet)]
 			case <-p.die:
 				return
 			}