Introduce command buffer control thread

mojo/public/cpp/bindings/strong_binding.h

 // 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.
 
 #ifndef MOJO_PUBLIC_CPP_BINDINGS_STRONG_BINDING_H_
 #define MOJO_PUBLIC_CPP_BINDINGS_STRONG_BINDING_H_
 
 #include "mojo/public/c/environment/async_waiter.h"
 #include "mojo/public/cpp/bindings/binding.h"
 #include "mojo/public/cpp/bindings/error_handler.h"
@@ skipping 49 matching lines @@
   StrongBinding(
       Interface* impl,
       InterfaceRequest<Interface> request,
       const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter())
       : StrongBinding(impl) {
     binding_.Bind(request.Pass(), waiter);
   }
 
   ~StrongBinding() override {}
 
+  void Bind(
+      ScopedMessagePipeHandle handle,
+      const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
+    binding_.Bind(handle.Pass(), waiter);

[jamesr, 2014/11/19 20:57:17]

add an assert() that we aren't already bound since if someone tries to re-bind
to a new pipe it'll operator delete the old impl and there's no way to
re-associate a binding

+  }
+
+  void Bind(
+      InterfacePtr<Interface>* ptr,
+      const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
+    binding_.Bind(ptr, waiter);
+  }
+
+  void Bind(
+      InterfaceRequest<Interface> request,
+      const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
+    binding_.Bind(request.Pass(), waiter);
+  }
+
   bool WaitForIncomingMethodCall() {
     return binding_.WaitForIncomingMethodCall();
   }
 
   void set_error_handler(ErrorHandler* error_handler) {
     error_handler_ = error_handler;
   }
 
   typename Interface::Client* client() { return binding_.client(); }
   // Exposed for testing, should not generally be used.
   internal::Router* internal_router() { return binding_.internal_router(); }
 
   // ErrorHandler implementation
   void OnConnectionError() override {
     if (error_handler_)
       error_handler_->OnConnectionError();
     delete binding_.impl();
   }
 
  private:
   ErrorHandler* error_handler_ = nullptr;
   Binding<Interface> binding_;
 };
 
 }  // namespace mojo
 
 #endif  // MOJO_PUBLIC_CPP_BINDINGS_STRONG_BINDING_H_