| Index: mojo/public/cpp/bindings/lib/router.h
|
| diff --git a/mojo/public/cpp/bindings/lib/router.h b/mojo/public/cpp/bindings/lib/router.h
|
| index 12aa7e72af65f113b2395f08948c004cf07a1759..f7ce51315f8ef9e265cc8f6e10083da9271e0253 100644
|
| --- a/mojo/public/cpp/bindings/lib/router.h
|
| +++ b/mojo/public/cpp/bindings/lib/router.h
|
| @@ -8,10 +8,8 @@
|
| #include <stdint.h>
|
|
|
| #include <map>
|
| -#include <queue>
|
|
|
| -#include "base/macros.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| +#include "base/logging.h"
|
| #include "base/memory/weak_ptr.h"
|
| #include "base/threading/thread_checker.h"
|
| #include "mojo/public/cpp/bindings/callback.h"
|
| @@ -26,7 +24,6 @@
|
| public:
|
| Router(ScopedMessagePipeHandle message_pipe,
|
| FilterChain filters,
|
| - bool expects_sync_requests,
|
| const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter());
|
| ~Router() override;
|
|
|
| @@ -107,29 +104,13 @@
|
| // Returns true if this Router has any pending callbacks.
|
| bool has_pending_responders() const {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| - return !async_responders_.empty() || !sync_responses_.empty();
|
| + return !async_responders_.empty() || !sync_responders_.empty();
|
| }
|
|
|
| private:
|
| // Maps from the id of a response to the MessageReceiver that handles the
|
| // response.
|
| - using AsyncResponderMap = std::map<uint64_t, scoped_ptr<MessageReceiver>>;
|
| -
|
| - struct SyncResponseInfo {
|
| - public:
|
| - explicit SyncResponseInfo(bool* in_response_received);
|
| - ~SyncResponseInfo();
|
| -
|
| - scoped_ptr<Message> response;
|
| -
|
| - // Points to a stack-allocated variable.
|
| - bool* response_received;
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(SyncResponseInfo);
|
| - };
|
| -
|
| - using SyncResponseMap = std::map<uint64_t, scoped_ptr<SyncResponseInfo>>;
|
| + typedef std::map<uint64_t, MessageReceiver*> ResponderMap;
|
|
|
| class HandleIncomingMessageThunk : public MessageReceiver {
|
| public:
|
| @@ -144,22 +125,15 @@
|
| };
|
|
|
| bool HandleIncomingMessage(Message* message);
|
| - void HandleQueuedMessages();
|
| -
|
| - bool HandleMessageInternal(Message* message);
|
|
|
| HandleIncomingMessageThunk thunk_;
|
| FilterChain filters_;
|
| Connector connector_;
|
| MessageReceiverWithResponderStatus* incoming_receiver_;
|
| - AsyncResponderMap async_responders_;
|
| - SyncResponseMap sync_responses_;
|
| + ResponderMap async_responders_;
|
| + ResponderMap sync_responders_;
|
| uint64_t next_request_id_;
|
| bool testing_mode_;
|
| - std::queue<scoped_ptr<Message>> pending_messages_;
|
| - // Whether a task has been posted to trigger processing of
|
| - // |pending_messages_|.
|
| - bool pending_task_for_messages_;
|
| base::ThreadChecker thread_checker_;
|
| base::WeakPtrFactory<Router> weak_factory_;
|
| };
|
|
|