f

src/ae.c

@@ -82,6 +82,7 @@ aeEventLoop *aeCreateEventLoop(int setsize) {
     eventLoop->beforesleep = NULL;
     eventLoop->aftersleep = NULL;
     eventLoop->flags = 0;
+    eventLoop->numevents = 0;
     if (aeApiCreate(eventLoop) == -1) goto err;
     /* Events with mask == AE_NONE are not set. So let's initialize the
      * vector with it. */
@@ -403,6 +404,9 @@ int aeProcessEvents(aeEventLoop *eventLoop, int flags)
             numevents = 0;
         }
 
+        /* Cache the returned numevents. */
+        eventLoop.numevents = numevents;
+
         /* After sleep callback. */
         if (eventLoop->aftersleep != NULL && flags & AE_CALL_AFTER_SLEEP)
             eventLoop->aftersleep(eventLoop);

src/ae.h

@@ -108,6 +108,7 @@ typedef struct aeEventLoop {
     aeBeforeSleepProc *beforesleep;
     aeBeforeSleepProc *aftersleep;
     int flags;
+    int numevents; /* The return value of poll in aeProcessEvents. */
 } aeEventLoop;
 
 /* Prototypes */

src/server.c

@@ -1053,6 +1053,8 @@ void clientsCron(void) {
  * incrementally in Redis databases, such as active key expiring, resizing,
  * rehashing. */
 void databasesCron(void) {
+    serverLog(LL_WARNING, "server event numevents: %d", server.el->numevents);
+
     /* Expire keys by random sampling. Not required for slaves
      * as master will synthesize DELs for us. */
     if (server.active_expire_enabled) {