Home | History | Annotate | Download | only in lib 
      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 "mojo/public/cpp/application/lib/service_registry.h"
      6 
      7 #include "mojo/public/cpp/application/application.h"
      8 #include "mojo/public/cpp/application/lib/service_connector.h"
      9 
     10 namespace mojo {
     11 namespace internal {
     12 
     13 ServiceRegistry::ServiceRegistry(Application* application)
     14     : application_(application) {
     15 }
     16 
     17 ServiceRegistry::ServiceRegistry(
     18     Application* application,
     19     ScopedMessagePipeHandle service_provider_handle)
     20         : application_(application) {
     21   remote_service_provider_.Bind(service_provider_handle.Pass());
     22   remote_service_provider_.set_client(this);
     23 }
     24 
     25 ServiceRegistry::~ServiceRegistry() {
     26   for (NameToServiceConnectorMap::iterator i =
     27            name_to_service_connector_.begin();
     28        i != name_to_service_connector_.end(); ++i) {
     29     delete i->second;
     30   }
     31   name_to_service_connector_.clear();
     32 }
     33 
     34 void ServiceRegistry::AddServiceConnector(
     35     ServiceConnectorBase* service_connector) {
     36   name_to_service_connector_[service_connector->name()] = service_connector;
     37   service_connector->set_registry(this);
     38 }
     39 
     40 void ServiceRegistry::RemoveServiceConnector(
     41     ServiceConnectorBase* service_connector) {
     42   NameToServiceConnectorMap::iterator it =
     43       name_to_service_connector_.find(service_connector->name());
     44   assert(it != name_to_service_connector_.end());
     45   delete it->second;
     46   name_to_service_connector_.erase(it);
     47   if (name_to_service_connector_.empty())
     48     remote_service_provider_.reset();
     49 }
     50 
     51 void ServiceRegistry::BindRemoteServiceProvider(
     52     ScopedMessagePipeHandle service_provider_handle) {
     53   remote_service_provider_.Bind(service_provider_handle.Pass());
     54   remote_service_provider_.set_client(this);
     55 }
     56 
     57 void ServiceRegistry::ConnectToService(const mojo::String& service_url,
     58                                        const mojo::String& service_name,
     59                                        ScopedMessagePipeHandle client_handle,
     60                                        const mojo::String& requestor_url) {
     61   if (name_to_service_connector_.find(service_name) ==
     62           name_to_service_connector_.end() ||
     63       !application_->AllowIncomingConnection(service_name, requestor_url)) {
     64     client_handle.reset();
     65     return;
     66   }
     67 
     68   internal::ServiceConnectorBase* service_connector =
     69       name_to_service_connector_[service_name];
     70   assert(service_connector);
     71   // requestor_url is ignored because the service_connector stores the url
     72   // of the requestor safely.
     73   return service_connector->ConnectToService(
     74       service_url, service_name, client_handle.Pass());
     75 }
     76 
     77 }  // namespace internal
     78 }  // namespace mojo
     79