[OLD ATTEMPT, DO NOT REVIEW] mustash: Enable connections to mus from the Chrome renderer

content/common/mojo/mojo_shell_connection_impl.cc

 // Copyright 2015 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 "content/common/mojo/mojo_shell_connection_impl.h"
 
 #include "base/command_line.h"
 #include "base/lazy_instance.h"
+#include "base/process/process_handle.h"

[Fady Samuel, 2015/11/24 04:42:38]

delete this.

 #include "base/threading/thread_local.h"
 #include "mojo/application/public/cpp/application_delegate.h"
 #include "mojo/application/public/cpp/application_impl.h"
 #include "mojo/converters/network/network_type_converters.h"
 #include "mojo/runner/child/runner_connection.h"
 
 namespace content {
 namespace {
 using MojoShellConnectionPtr =
     base::ThreadLocalPointer<MojoShellConnectionImpl>;
@@ skipping 36 matching lines @@
       this, application_request.Pass()));
   application_impl_->WaitForInitialize();
 }
 
 void MojoShellConnectionImpl::Initialize(mojo::ApplicationImpl* application) {
   initialized_ = true;
 }
 
 bool MojoShellConnectionImpl::ConfigureIncomingConnection(
     mojo::ApplicationConnection* connection) {
+  fprintf(stderr, "[%d] >>>%s url %s \n", base::GetCurrentProcId(),
+          __PRETTY_FUNCTION__, connection->GetRemoteApplicationURL().c_str());
   bool found = false;
   for (auto listener : listeners_)
     found |= listener->ConfigureIncomingConnection(connection);
   return found;
 }
 
 mojo::ApplicationImpl* MojoShellConnectionImpl::GetApplication() {
   DCHECK(initialized_);
   return application_impl_.get();
 }
 
 void MojoShellConnectionImpl::AddListener(Listener* listener) {
   DCHECK(std::find(listeners_.begin(), listeners_.end(), listener) ==
          listeners_.end());
   listeners_.push_back(listener);
 }
 
 void MojoShellConnectionImpl::RemoveListener(Listener* listener) {
   auto it = std::find(listeners_.begin(), listeners_.end(), listener);
   DCHECK(it != listeners_.end());
   listeners_.erase(it);
 }
 
+void MojoShellConnectionImpl::OnDestroy() {
+  for (auto listener : listeners_)
+    listener->OnDestroy();
+}
+
 // static
 MojoShellConnection* MojoShellConnection::Get() {
   return lazy_tls_ptr.Pointer()->Get();
 }
 
 // static
 void MojoShellConnection::Destroy() {
+  static_cast<MojoShellConnectionImpl*>(Get())->OnDestroy();
   // This joins the shell controller thread.
   delete Get();
   lazy_tls_ptr.Pointer()->Set(nullptr);
 }
 
 MojoShellConnection::~MojoShellConnection() {}
 
 }  // namespace content