1 files changed, 2 insertions, 28 deletions
diff --git a/pkg/fdnotifier/fdnotifier.go b/pkg/fdnotifier/fdnotifier.go
index 731fa4dad..f0b028b0b 100644
--- a/pkg/fdnotifier/fdnotifier.go
+++ b/pkg/fdnotifier/fdnotifier.go
@@ -40,10 +40,6 @@ type notifier struct {
 	// notifications.
 	epFD int
 
-	// eventFD is used to restart epoll_wait in waitAndNotify after
-	// reconfiguring epFD.
-	eventFD int
-
 	// mu protects fdMap.
 	mu sync.Mutex
 
@@ -59,20 +55,9 @@ func newNotifier() (*notifier, error) {
 		return nil, err
 	}
 
-	eventFD, err := eventFDCreate()
-	if err != nil {
-		syscall.Close(epfd)
-		return nil, err
-	}
-
 	w := &notifier{
-		epFD:    epfd,
-		eventFD: eventFD,
-		fdMap:   make(map[int32]*fdInfo),
-	}
-
-	if err := w.waitFD(int32(w.eventFD), &fdInfo{}, waiter.EventIn); err != nil {
-		return nil, err
+		epFD:  epfd,
+		fdMap: make(map[int32]*fdInfo),
 	}
 
 	go w.waitAndNotify() // S/R-SAFE: no waiter exists during save / load.
@@ -106,11 +91,6 @@ func (n *notifier) waitFD(fd int32, fi *fdInfo, mask waiter.EventMask) error {
 		}
 	}
 
-	// Restart epoll_wait in waitAndNotify.
-	if err := eventFDWrite(n.eventFD, 1); err != nil {
-		return err
-	}
-
 	return nil
 }
 
@@ -176,12 +156,6 @@ func (n *notifier) waitAndNotify() error {
 
 		n.mu.Lock()
 		for i := 0; i < v; i++ {
-			if e[i].Fd == int32(n.eventFD) {
-				if _, err := eventFDRead(n.eventFD); err != nil {
-					return err
-				}
-				continue
-			}
 			if fi, ok := n.fdMap[e[i].Fd]; ok {
 				fi.queue.Notify(waiter.EventMaskFromLinux(e[i].Events))
 			}