src/base/message_loop/message_pump_ozone.cc

   1 // Copyright (c) 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "base/message_loop/message_pump_ozone.h"
   6
   7 #include "base/logging.h"
   8 #include "base/message_loop/message_loop.h"
   9
  10 namespace base {
  11
  12 MessagePumpOzone::MessagePumpOzone()
  13     : MessagePumpLibevent() {
  14 }
  15
  16 MessagePumpOzone::~MessagePumpOzone() {
  17 }
  18
  19 void MessagePumpOzone::AddObserver(MessagePumpObserver* observer) {
  20   observers_.AddObserver(observer);
  21 }
  22
  23 void MessagePumpOzone::RemoveObserver(MessagePumpObserver* observer) {
  24   observers_.RemoveObserver(observer);
  25 }
  26
  27 void MessagePumpOzone::WillProcessEvent(const NativeEvent& event) {
  28   FOR_EACH_OBSERVER(MessagePumpObserver,
  29                     observers_,
  30                     WillProcessEvent(event));
  31 }
  32
  33 void MessagePumpOzone::DidProcessEvent(const NativeEvent& event) {
  34   FOR_EACH_OBSERVER(MessagePumpObserver,
  35                     observers_,
  36                     DidProcessEvent(event));
  37 }
  38
  39 // static
  40 MessagePumpOzone* MessagePumpOzone::Current() {
  41   MessageLoopForUI* loop = MessageLoopForUI::current();
  42   return static_cast<MessagePumpOzone*>(loop->pump_ui());
  43 }
  44
  45 void MessagePumpOzone::AddDispatcherForRootWindow(
  46     MessagePumpDispatcher* dispatcher) {
  47   // Only one root window is supported.
  48   DCHECK_EQ(dispatcher_.size(), 0);
  49   dispatcher_.insert(dispatcher_.begin(), dispatcher);
  50 }
  51
  52 void MessagePumpOzone::RemoveDispatcherForRootWindow(
  53       MessagePumpDispatcher* dispatcher) {
  54   DCHECK_EQ(dispatcher_.size(), 1);
  55   dispatcher_.pop_back();
  56 }
  57
  58 uint32_t MessagePumpOzone::Dispatch(const NativeEvent& dev) {
  59   uint32_t result = POST_DISPATCH_NONE;
  60   WillProcessEvent(dev);
  61   if (!dispatcher_.empty()) {
  62     result = dispatcher_[0]->Dispatch(dev);
  63   }
  64   DidProcessEvent(dev);
  65   return result;
  66 }
  67
  68 // This code assumes that the caller tracks the lifetime of the |dispatcher|.
  69 void MessagePumpOzone::RunWithDispatcher(
  70     Delegate* delegate, MessagePumpDispatcher* dispatcher) {
  71   dispatcher_.push_back(dispatcher);
  72   Run(delegate);
  73   dispatcher_.pop_back();
  74 }
  75
  76 }  // namespace base