diff --git a/benchmark/ioevent/fd_channel_vs_pipe_event_watcher/fd_channel_vs_pipe_event_watcher.cc b/benchmark/ioevent/fd_channel_vs_pipe_event_watcher/fd_channel_vs_pipe_event_watcher.cc
index 7a33fa580..29ad822a9 100644
--- a/benchmark/ioevent/fd_channel_vs_pipe_event_watcher/fd_channel_vs_pipe_event_watcher.cc
+++ b/benchmark/ioevent/fd_channel_vs_pipe_event_watcher/fd_channel_vs_pipe_event_watcher.cc
@@ -105,9 +105,9 @@ std::pair<int, int> PipeEventWatcherRunOnce() {
 }
 
 int main(int argc, char* argv[]) {
-    numPipes = 1000;
-    numActive = 10;
-    numWrites = 1000;
+    numPipes = 5000;
+    numActive = 100;
+    numWrites = 5000;
 
     g_pipes.resize(2 * numPipes);
     for (int i = 0; i < numPipes; ++i) {
diff --git a/evpp/event_loop.cc b/evpp/event_loop.cc
index 55bac0a1d..fcca15ff9 100644
--- a/evpp/event_loop.cc
+++ b/evpp/event_loop.cc
@@ -175,6 +175,7 @@ void EventLoop::QueueInLoop(const Functor& cb) {
 
     if (!notified_.load()) {
         watcher_->Notify();
+        notified_.store(true);
     }
 }