Mojo C++ bindings: introduce MultiplexRouter and related classes.

mojo/public/cpp/bindings/lib/router.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "mojo/public/cpp/bindings/lib/router.h"
 
 #include "mojo/public/cpp/environment/logging.h"
 
 namespace mojo {
 namespace internal {
 
 // ----------------------------------------------------------------------------
 
+namespace {
+
 class ResponderThunk : public MessageReceiverWithStatus {
  public:
   explicit ResponderThunk(const SharedData<Router*>& router)
       : router_(router), accept_was_invoked_(false) {}
   ~ResponderThunk() override {
     if (!accept_was_invoked_) {
       // The Mojo application handled a message that was expecting a response
       // but did not send a response.
       Router* router = router_.value();
       if (router) {
@@ skipping 23 matching lines @@
   bool IsValid() override {
     Router* router = router_.value();
     return router && !router->encountered_error() && router->is_valid();
   }
 
  private:
   SharedData<Router*> router_;
   bool accept_was_invoked_;
 };
 
+}  // namespace
+
 // ----------------------------------------------------------------------------
 
 Router::HandleIncomingMessageThunk::HandleIncomingMessageThunk(Router* router)
     : router_(router) {
 }
 
 Router::HandleIncomingMessageThunk::~HandleIncomingMessageThunk() {
 }
 
 bool Router::HandleIncomingMessageThunk::Accept(Message* message) {
   return router_->HandleIncomingMessage(message);
 }
 
 // ----------------------------------------------------------------------------
 
 Router::Router(ScopedMessagePipeHandle message_pipe,
                FilterChain filters,
                const MojoAsyncWaiter* waiter)
     : thunk_(this),
       filters_(filters.Pass()),
-      connector_(message_pipe.Pass(), waiter),
+      connector_(message_pipe.Pass(), Connector::SINGLE_THREADED_SEND, waiter),
       weak_self_(this),
       incoming_receiver_(nullptr),
       next_request_id_(0),
       testing_mode_(false) {
   filters_.SetSink(&thunk_);
   connector_.set_incoming_receiver(filters_.GetHead());
 }
 
 Router::~Router() {
   weak_self_.set_value(nullptr);
@@ skipping 61 matching lines @@
       return false;
 
     return incoming_receiver_->Accept(message);
   }
 }
 
 // ----------------------------------------------------------------------------
 
 }  // namespace internal
 }  // namespace mojo