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_; |
}; |