Work in progress: Adds MessagePumpDispatcher::ShouldExit(). This is used to handle the

base/message_pump_glib.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/message_pump_glib.h"
 
 #include <fcntl.h>
 #include <math.h>
 
 #include <glib.h>
 
 #include "base/eintr_wrapper.h"
 #include "base/logging.h"
+#include "base/message_pump_dispatcher.h"
 #include "base/threading/platform_thread.h"
 
 namespace {
 
 // Return a timeout suitable for the glib loop, -1 to block forever,
 // 0 to return right away, or a timeout in milliseconds from now.
 int GetTimeIntervalMilliseconds(const base::TimeTicks& from) {
   if (from.is_null())
     return -1;
 
@@ skipping 240 matching lines @@
   if (GetTimeIntervalMilliseconds(delayed_work_time_) == 0) {
     // The timer has expired. That condition will stay true until we process
     // that delayed work, so we don't need to record this differently.
     return true;
   }
 
   return false;
 }
 
 void MessagePumpGlib::HandleDispatch() {
+  MessagePumpDispatcher* dispatcher = GetDispatcher();
+  if (dispatcher && dispatcher->ShouldExit()) {
+    state_->should_quit = true;
+    return;
+  }
+
   state_->has_work = false;
   if (state_->delegate->DoWork()) {
     // NOTE: on Windows at this point we would call ScheduleWork (see
     // MessagePumpGlib::HandleWorkMessage in message_pump_win.cc). But here,
     // instead of posting a message on the wakeup pipe, we can avoid the
     // syscalls and just signal that we have more work.
     state_->has_work = true;
   }
 
   if (state_->should_quit)
@@ skipping 37 matching lines @@
   // adjusted.  This will cause us to try to do work, but that's ok.
   delayed_work_time_ = delayed_work_time;
   ScheduleWork();
 }
 
 MessagePumpDispatcher* MessagePumpGlib::GetDispatcher() {
   return state_ ? state_->dispatcher : NULL;
 }
 
 }  // namespace base