kqueue: revert to v1.3.21

lesismal · Feb 22, 2024 · 6d052f1 · 6d052f1
1 parent 407c9e4
commit 6d052f1
Showing 1 changed file with 8 additions and 9 deletions.
diff --git a/poller_kqueue.go b/poller_kqueue.go
@@ -104,23 +104,22 @@ func (p *poller) trigger() {
 func (p *poller) addRead(fd int) {
 	p.mux.Lock()
 	p.eventList = append(p.eventList, syscall.Kevent_t{Ident: uint64(fd), Flags: syscall.EV_ADD, Filter: syscall.EVFILT_READ})
-	p.eventList = append(p.eventList, syscall.Kevent_t{Ident: uint64(fd), Flags: syscall.EV_ADD, Filter: syscall.EVFILT_WRITE})
 	p.mux.Unlock()
 	p.trigger()
 }
 
 func (p *poller) resetRead(fd int) {
-	// p.mux.Lock()
-	// p.eventList = append(p.eventList, syscall.Kevent_t{Ident: uint64(fd), Flags: syscall.EV_DELETE, Filter: syscall.EVFILT_WRITE})
-	// p.mux.Unlock()
-	// p.trigger()
+	p.mux.Lock()
+	p.eventList = append(p.eventList, syscall.Kevent_t{Ident: uint64(fd), Flags: syscall.EV_DELETE, Filter: syscall.EVFILT_WRITE})
+	p.mux.Unlock()
+	p.trigger()
 }
 
 func (p *poller) modWrite(fd int) {
-	// p.mux.Lock()
-	// p.eventList = append(p.eventList, syscall.Kevent_t{Ident: uint64(fd), Flags: syscall.EV_ADD, Filter: syscall.EVFILT_WRITE})
-	// p.mux.Unlock()
-	// p.trigger()
+	p.mux.Lock()
+	p.eventList = append(p.eventList, syscall.Kevent_t{Ident: uint64(fd), Flags: syscall.EV_ADD, Filter: syscall.EVFILT_WRITE})
+	p.mux.Unlock()
+	p.trigger()
 }
 
 func (p *poller) deleteEvent(fd int) {