content/common/mojo/service_registry_impl.cc

   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     : binding_(this), weak_factory_(this) {
  13   binding_.set_error_handler(this);
  14 }
  15
  16 ServiceRegistryImpl::~ServiceRegistryImpl() {
  17   while (!pending_connects_.empty()) {
  18     mojo::CloseRaw(pending_connects_.front().second);
  19     pending_connects_.pop();
  20   }
  21 }
  22
  23 void ServiceRegistryImpl::Bind(
  24     mojo::InterfaceRequest<mojo::ServiceProvider> request) {
  25   binding_.Bind(request.Pass());
  26 }
  27
  28 void ServiceRegistryImpl::BindRemoteServiceProvider(
  29     mojo::ServiceProviderPtr service_provider) {
  30   CHECK(!remote_provider_);
  31   remote_provider_ = service_provider.Pass();
  32   while (!pending_connects_.empty()) {
  33     remote_provider_->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::AddService(
  41     const std::string& service_name,
  42     const base::Callback<void(mojo::ScopedMessagePipeHandle)> service_factory) {
  43   service_factories_[service_name] = service_factory;
  44 }
  45
  46 void ServiceRegistryImpl::RemoveService(const std::string& service_name) {
  47   service_factories_.erase(service_name);
  48 }
  49
  50 void ServiceRegistryImpl::ConnectToRemoteService(
  51     const base::StringPiece& service_name,
  52     mojo::ScopedMessagePipeHandle handle) {
  53   if (!remote_provider_) {
  54     pending_connects_.push(
  55         std::make_pair(service_name.as_string(), handle.release()));
  56     return;
  57   }
  58   remote_provider_->ConnectToService(mojo::String::From(service_name),
  59                                      handle.Pass());
  60 }
  61
  62 bool ServiceRegistryImpl::IsBound() const {
  63   return binding_.is_bound();
  64 }
  65
  66 base::WeakPtr<ServiceRegistry> ServiceRegistryImpl::GetWeakPtr() {
  67   return weak_factory_.GetWeakPtr();
  68 }
  69
  70 void ServiceRegistryImpl::ConnectToService(
  71     const mojo::String& name,
  72     mojo::ScopedMessagePipeHandle client_handle) {
  73   std::map<std::string,
  74            base::Callback<void(mojo::ScopedMessagePipeHandle)> >::iterator it =
  75       service_factories_.find(name);
  76   if (it == service_factories_.end())
  77     return;
  78
  79   it->second.Run(client_handle.Pass());
  80 }
  81
  82 void ServiceRegistryImpl::OnConnectionError() {
  83   binding_.Close();
  84 }
  85
  86 }  // namespace content