Change MessagePumpLibevent::Run to handle IO events before doing idle

third_party/libevent/event.c

 /*
  * Copyright (c) 2000-2004 Niels Provos <provos@citi.umich.edu>
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 451 matching lines @@
 }
 
 int
 event_base_loop(struct event_base *base, int flags)
 {
         const struct eventop *evsel = base->evsel;
         void *evbase = base->evbase;
         struct timeval tv;
         struct timeval *tv_p;
         int res, done;
+        int processed_active = 0;
 
         /* clear time cache */
         base->tv_cache.tv_sec = 0;
 
         if (base->sig.ev_signal_added)
                 evsignal_base = base;
         done = 0;
         while (!done) {
                 /* Terminate the loop if we have been asked to */
                 if (base->event_gotterm) {
@@ skipping 34 matching lines @@
                 res = evsel->dispatch(base, evbase, tv_p);
 
                 if (res == -1)
                         return (-1);
                 gettime(base, &base->tv_cache);
 
                 timeout_process(base);
 
                 if (base->event_count_active) {
                         event_process_active(base);
+                        processed_active = 1;
                         if (!base->event_count_active && (flags & EVLOOP_ONCE))
                                 done = 1;
                 } else if (flags & EVLOOP_NONBLOCK)
                         done = 1;
         }
 
         /* clear time cache */
         base->tv_cache.tv_sec = 0;
 
         event_debug(("%s: asked to terminate loop.", __func__));
-        return (0);
+        return (processed_active ? 2 : 0);

[wtc, 2011/06/25 00:39:45]

The return value 0 means success.  1 means no events are
registered.  So I need to use 2 for the new meaning.
I'll find a better solution.

 }
 
 /* Sets up an event for processing once */
 
 struct event_once {
         struct event ev;
 
         void (*cb)(int, short, void *);
         void *arg;
 };
@@ skipping 446 matching lines @@
 /* 
  * No thread-safe interface needed - the information should be the same
  * for all threads.
  */
 
 const char *
 event_get_method(void)
 {
         return (current_base->evsel->name);
 }