service_registry.cc revision 6d86b77056ed63eb6871182f42a9fd5f07550f90
1f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)// Copyright 2014 The Chromium Authors. All rights reserved. 2f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 3f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)// found in the LICENSE file. 4f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 5f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)#include "mojo/public/cpp/application/lib/service_registry.h" 6f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 7f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)#include "mojo/public/cpp/application/application.h" 8f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)#include "mojo/public/cpp/application/lib/service_connector.h" 9f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 10f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)namespace mojo { 11f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)namespace internal { 12f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 13f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)ServiceRegistry::ServiceRegistry(Application* application) 14f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) : application_(application) { 15f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 16f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 17f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)ServiceRegistry::ServiceRegistry( 18f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) Application* application, 19f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) ScopedMessagePipeHandle service_provider_handle) 20f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) : application_(application) { 21f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) remote_service_provider_.Bind(service_provider_handle.Pass()); 22f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) remote_service_provider_.set_client(this); 23f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 24f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 25f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)ServiceRegistry::~ServiceRegistry() { 26f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) for (NameToServiceConnectorMap::iterator i = 27f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) name_to_service_connector_.begin(); 28f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) i != name_to_service_connector_.end(); ++i) { 29f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) delete i->second; 30f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) } 31f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) name_to_service_connector_.clear(); 32f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 33f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 34f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)void ServiceRegistry::AddServiceConnector( 35f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) ServiceConnectorBase* service_connector) { 36f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) name_to_service_connector_[service_connector->name()] = service_connector; 37f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) service_connector->set_registry(this); 38f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 39f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 40f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)void ServiceRegistry::RemoveServiceConnector( 41f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) ServiceConnectorBase* service_connector) { 42f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) NameToServiceConnectorMap::iterator it = 43f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) name_to_service_connector_.find(service_connector->name()); 44f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) assert(it != name_to_service_connector_.end()); 45f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) delete it->second; 46f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) name_to_service_connector_.erase(it); 47f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) if (name_to_service_connector_.empty()) 48f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) remote_service_provider_.reset(); 49f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 50f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 51f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)void ServiceRegistry::BindRemoteServiceProvider( 52f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) ScopedMessagePipeHandle service_provider_handle) { 53f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) remote_service_provider_.Bind(service_provider_handle.Pass()); 54f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) remote_service_provider_.set_client(this); 55f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 56f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 57f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)void ServiceRegistry::ConnectToService(const mojo::String& service_url, 58f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) const mojo::String& service_name, 59f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) ScopedMessagePipeHandle client_handle, 60f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) const mojo::String& requestor_url) { 616d86b77056ed63eb6871182f42a9fd5f07550f90Torne (Richard Coles) if (name_to_service_connector_.find(service_name) == 626d86b77056ed63eb6871182f42a9fd5f07550f90Torne (Richard Coles) name_to_service_connector_.end() || 636d86b77056ed63eb6871182f42a9fd5f07550f90Torne (Richard Coles) !application_->AllowIncomingConnection(service_name, requestor_url)) { 64f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) client_handle.reset(); 65f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return; 66f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) } 67f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 68f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) internal::ServiceConnectorBase* service_connector = 69f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) name_to_service_connector_[service_name]; 70f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) assert(service_connector); 71f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // requestor_url is ignored because the service_connector stores the url 72f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) // of the requestor safely. 73f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return service_connector->ConnectToService( 74f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) service_url, service_name, client_handle.Pass()); 75f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 76f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 77f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} // namespace internal 78f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} // namespace mojo 79