Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(59)

Side by Side Diff: base/message_pump_win.cc

Issue 8021009: Consolidate message observer API for win and aura (and touch). (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: sync Created 9 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "base/message_pump_win.h" 5 #include "base/message_pump_win.h"
6 6
7 #include <math.h> 7 #include <math.h>
8 8
9 #include "base/message_loop.h" 9 #include "base/message_loop.h"
10 #include "base/metrics/histogram.h" 10 #include "base/metrics/histogram.h"
11 #include "base/win/wrapped_window_proc.h" 11 #include "base/win/wrapped_window_proc.h"
12 12
13 namespace base { 13 namespace base {
14 14
15 static const wchar_t kWndClass[] = L"Chrome_MessagePumpWindow"; 15 static const wchar_t kWndClass[] = L"Chrome_MessagePumpWindow";
16 16
17 // Message sent to get an additional time slice for pumping (processing) another 17 // Message sent to get an additional time slice for pumping (processing) another
18 // task (a series of such messages creates a continuous task pump). 18 // task (a series of such messages creates a continuous task pump).
19 static const int kMsgHaveWork = WM_USER + 1; 19 static const int kMsgHaveWork = WM_USER + 1;
20 20
21 //----------------------------------------------------------------------------- 21 //-----------------------------------------------------------------------------
22 // MessagePumpWin public: 22 // MessagePumpWin public:
23 23
24 void MessagePumpWin::AddObserver(Observer* observer) { 24 void MessagePumpWin::AddObserver(MessagePumpObserver* observer) {
25 observers_.AddObserver(observer); 25 observers_.AddObserver(observer);
26 } 26 }
27 27
28 void MessagePumpWin::RemoveObserver(Observer* observer) { 28 void MessagePumpWin::RemoveObserver(MessagePumpObserver* observer) {
29 observers_.RemoveObserver(observer); 29 observers_.RemoveObserver(observer);
30 } 30 }
31 31
32 void MessagePumpWin::WillProcessMessage(const MSG& msg) { 32 void MessagePumpWin::WillProcessMessage(const MSG& msg) {
33 FOR_EACH_OBSERVER(Observer, observers_, WillProcessMessage(msg)); 33 FOR_EACH_OBSERVER(MessagePumpObserver, observers_, WillProcessEvent(msg));
34 } 34 }
35 35
36 void MessagePumpWin::DidProcessMessage(const MSG& msg) { 36 void MessagePumpWin::DidProcessMessage(const MSG& msg) {
37 FOR_EACH_OBSERVER(Observer, observers_, DidProcessMessage(msg)); 37 FOR_EACH_OBSERVER(MessagePumpObserver, observers_, DidProcessEvent(msg));
38 } 38 }
39 39
40 void MessagePumpWin::RunWithDispatcher( 40 void MessagePumpWin::RunWithDispatcher(
41 Delegate* delegate, Dispatcher* dispatcher) { 41 Delegate* delegate, Dispatcher* dispatcher) {
42 RunState s; 42 RunState s;
43 s.delegate = delegate; 43 s.delegate = delegate;
44 s.dispatcher = dispatcher; 44 s.dispatcher = dispatcher;
45 s.should_quit = false; 45 s.should_quit = false;
46 s.run_depth = state_ ? state_->run_depth + 1 : 1; 46 s.run_depth = state_ ? state_->run_depth + 1 : 1;
47 47
(...skipping 526 matching lines...) Expand 10 before | Expand all | Expand 10 after
574 574
575 void MessagePumpForIO::WillProcessIOEvent() { 575 void MessagePumpForIO::WillProcessIOEvent() {
576 FOR_EACH_OBSERVER(IOObserver, io_observers_, WillProcessIOEvent()); 576 FOR_EACH_OBSERVER(IOObserver, io_observers_, WillProcessIOEvent());
577 } 577 }
578 578
579 void MessagePumpForIO::DidProcessIOEvent() { 579 void MessagePumpForIO::DidProcessIOEvent() {
580 FOR_EACH_OBSERVER(IOObserver, io_observers_, DidProcessIOEvent()); 580 FOR_EACH_OBSERVER(IOObserver, io_observers_, DidProcessIOEvent());
581 } 581 }
582 582
583 } // namespace base 583 } // namespace base
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698