Home | History | Annotate | Download | only in mojo 
      1 // Copyright 2014 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #include "content/common/mojo/service_registry_impl.h"
      6 
      7 #include "mojo/common/common_type_converters.h"
      8 
      9 namespace content {
     10 
     11 ServiceRegistryImpl::ServiceRegistryImpl()
     12     : bound_(false), weak_factory_(this) {
     13 }
     14 
     15 ServiceRegistryImpl::ServiceRegistryImpl(mojo::ScopedMessagePipeHandle handle)
     16     : bound_(false), weak_factory_(this) {
     17   BindRemoteServiceProvider(handle.Pass());
     18 }
     19 
     20 ServiceRegistryImpl::~ServiceRegistryImpl() {
     21   while (!pending_connects_.empty()) {
     22     mojo::CloseRaw(pending_connects_.front().second);
     23     pending_connects_.pop();
     24   }
     25 }
     26 
     27 void ServiceRegistryImpl::BindRemoteServiceProvider(
     28     mojo::ScopedMessagePipeHandle handle) {
     29   DCHECK(!bound_);
     30   bound_ = true;
     31   mojo::WeakBindToPipe(this, handle.Pass());
     32   while (!pending_connects_.empty()) {
     33     client()->ConnectToService(
     34         mojo::String::From(pending_connects_.front().first),
     35         mojo::ScopedMessagePipeHandle(pending_connects_.front().second));
     36     pending_connects_.pop();
     37   }
     38 }
     39 
     40 void ServiceRegistryImpl::OnConnectionError() {
     41   // TODO(sammc): Support reporting this to our owner.
     42 }
     43 
     44 void ServiceRegistryImpl::AddService(
     45     const std::string& service_name,
     46     const base::Callback<void(mojo::ScopedMessagePipeHandle)> service_factory) {
     47   bool inserted = service_factories_.insert(
     48       std::make_pair(service_name, service_factory)).second;
     49   DCHECK(inserted);
     50 }
     51 
     52 void ServiceRegistryImpl::RemoveService(const std::string& service_name) {
     53   service_factories_.erase(service_name);
     54 }
     55 
     56 void ServiceRegistryImpl::ConnectToRemoteService(
     57     const base::StringPiece& service_name,
     58     mojo::ScopedMessagePipeHandle handle) {
     59   if (!bound_) {
     60     pending_connects_.push(
     61         std::make_pair(service_name.as_string(), handle.release()));
     62     return;
     63   }
     64   client()->ConnectToService(mojo::String::From(service_name), handle.Pass());
     65 }
     66 
     67 base::WeakPtr<ServiceRegistry> ServiceRegistryImpl::GetWeakPtr() {
     68   return weak_factory_.GetWeakPtr();
     69 }
     70 
     71 void ServiceRegistryImpl::ConnectToService(
     72     const mojo::String& name,
     73     mojo::ScopedMessagePipeHandle client_handle) {
     74   std::map<std::string,
     75            base::Callback<void(mojo::ScopedMessagePipeHandle)> >::iterator it =
     76       service_factories_.find(name);
     77   if (it == service_factories_.end())
     78     return;
     79 
     80   it->second.Run(client_handle.Pass());
     81 }
     82 
     83 }  // namespace content
     84