| Index: mojo/message_pump/message_pump_mojo.h
|
| diff --git a/mojo/common/message_pump_mojo.h b/mojo/message_pump/message_pump_mojo.h
|
| similarity index 85%
|
| rename from mojo/common/message_pump_mojo.h
|
| rename to mojo/message_pump/message_pump_mojo.h
|
| index 899f9799354b4986d0b85ccf93a3501362375a7c..8fcc48eaa5f85eadd5211e756d6fd05e7ac46788 100644
|
| --- a/mojo/common/message_pump_mojo.h
|
| +++ b/mojo/message_pump/message_pump_mojo.h
|
| @@ -2,10 +2,12 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#ifndef MOJO_COMMON_MESSAGE_PUMP_MOJO_H_
|
| -#define MOJO_COMMON_MESSAGE_PUMP_MOJO_H_
|
| +#ifndef MOJO_MESSAGE_PUMP_MESSAGE_PUMP_MOJO_H_
|
| +#define MOJO_MESSAGE_PUMP_MESSAGE_PUMP_MOJO_H_
|
|
|
| #include <map>
|
| +#include <utility>
|
| +#include <vector>
|
|
|
| #include "base/macros.h"
|
| #include "base/memory/scoped_ptr.h"
|
| @@ -13,8 +15,9 @@
|
| #include "base/observer_list.h"
|
| #include "base/synchronization/lock.h"
|
| #include "base/time/time.h"
|
| -#include "mojo/common/mojo_common_export.h"
|
| -#include "third_party/mojo/src/mojo/public/cpp/system/core.h"
|
| +#include "mojo/public/c/system/result.h"
|
| +#include "mojo/public/c/system/time.h"
|
| +#include "mojo/public/cpp/system/handle.h"
|
|
|
| namespace mojo {
|
| namespace common {
|
| @@ -22,7 +25,7 @@ namespace common {
|
| class MessagePumpMojoHandler;
|
|
|
| // Mojo implementation of MessagePump.
|
| -class MOJO_COMMON_EXPORT MessagePumpMojo : public base::MessagePump {
|
| +class MessagePumpMojo : public base::MessagePump {
|
| public:
|
| class Observer {
|
| public:
|
| @@ -57,8 +60,8 @@ class MOJO_COMMON_EXPORT MessagePumpMojo : public base::MessagePump {
|
|
|
| void RemoveHandler(const Handle& handle);
|
|
|
| - void AddObserver(Observer*);
|
| - void RemoveObserver(Observer*);
|
| + void AddObserver(Observer* observer);
|
| + void RemoveObserver(Observer* observer);
|
|
|
| // MessagePump:
|
| void Run(Delegate* delegate) override;
|
| @@ -82,6 +85,7 @@ class MOJO_COMMON_EXPORT MessagePumpMojo : public base::MessagePump {
|
| };
|
|
|
| typedef std::map<Handle, Handler> HandleToHandler;
|
| + typedef std::vector<std::pair<Handle, Handler>> HandleToHandlerList;
|
|
|
| // Implementation of Run().
|
| void DoRunLoop(RunState* run_state, Delegate* delegate);
|
| @@ -99,7 +103,7 @@ class MOJO_COMMON_EXPORT MessagePumpMojo : public base::MessagePump {
|
|
|
| void SignalControlPipe(const RunState& run_state);
|
|
|
| - WaitState GetWaitState(const RunState& run_state) const;
|
| + void GetWaitState(const RunState& run_state, WaitState* wait_state) const;
|
|
|
| // Returns the deadline for the call to MojoWaitMany().
|
| MojoDeadline GetDeadlineForWait(const RunState& run_state) const;
|
| @@ -125,7 +129,7 @@ class MOJO_COMMON_EXPORT MessagePumpMojo : public base::MessagePump {
|
| // notify it.
|
| int next_handler_id_;
|
|
|
| - ObserverList<Observer> observers_;
|
| + base::ObserverList<Observer> observers_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(MessagePumpMojo);
|
| };
|
| @@ -133,4 +137,4 @@ class MOJO_COMMON_EXPORT MessagePumpMojo : public base::MessagePump {
|
| } // namespace common
|
| } // namespace mojo
|
|
|
| -#endif // MOJO_COMMON_MESSAGE_PUMP_MOJO_H_
|
| +#endif // MOJO_MESSAGE_PUMP_MESSAGE_PUMP_MOJO_H_
|
|
|