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
ServiceRegistry(Application * application)13 ServiceRegistry::ServiceRegistry(Application* application)
14 : application_(application) {
15 }
16
ServiceRegistry(Application * application,ScopedMessagePipeHandle service_provider_handle)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
~ServiceRegistry()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
AddServiceConnector(ServiceConnectorBase * service_connector)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
RemoveServiceConnector(ServiceConnectorBase * service_connector)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
BindRemoteServiceProvider(ScopedMessagePipeHandle service_provider_handle)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
ConnectToService(const mojo::String & service_url,const mojo::String & service_name,ScopedMessagePipeHandle client_handle,const mojo::String & requestor_url)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