fix: reuse op

cloudwego · Aug 2, 2023 · bd58bbd · bd58bbd
1 parent 12cd849
commit bd58bbd
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/net_polldesc.go b/net_polldesc.go
@@ -21,15 +21,14 @@ import (
 	"context"
 )
 
-// TODO: recycle *pollDesc
 func newPollDesc(fd int) *pollDesc {
 	pd := &pollDesc{}
-	pd.operator = &FDOperator{
-		poll:    pollmanager.Pick(),
-		FD:      fd,
-		OnWrite: pd.onwrite,
-		OnHup:   pd.onhup,
-	}
+	poll := pollmanager.Pick()
+
+	pd.operator = poll.Alloc()
+	pd.operator.FD = fd
+	pd.operator.OnWrite = pd.onwrite
+	pd.operator.OnHup = pd.onhup
 	pd.writeTrigger = make(chan struct{})
 	pd.closeTrigger = make(chan struct{})
 	return pd