| Index: mojo/application/public/cpp/lib/service_registry.cc
|
| diff --git a/mojo/application/public/cpp/lib/service_registry.cc b/mojo/application/public/cpp/lib/service_registry.cc
|
| deleted file mode 100644
|
| index 808cef20610da1c37ec4a753fd5af59f2c82e9c9..0000000000000000000000000000000000000000
|
| --- a/mojo/application/public/cpp/lib/service_registry.cc
|
| +++ /dev/null
|
| @@ -1,138 +0,0 @@
|
| -// Copyright 2014 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "mojo/application/public/cpp/lib/service_registry.h"
|
| -
|
| -#include <stdint.h>
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/logging.h"
|
| -#include "mojo/application/public/cpp/application_connection.h"
|
| -#include "mojo/application/public/cpp/service_connector.h"
|
| -
|
| -namespace mojo {
|
| -namespace internal {
|
| -
|
| -ServiceRegistry::ServiceRegistry(
|
| - const std::string& connection_url,
|
| - const std::string& remote_url,
|
| - ServiceProviderPtr remote_services,
|
| - InterfaceRequest<ServiceProvider> local_services,
|
| - const std::set<std::string>& allowed_interfaces)
|
| - : connection_url_(connection_url),
|
| - remote_url_(remote_url),
|
| - local_binding_(this),
|
| - remote_service_provider_(std::move(remote_services)),
|
| - allowed_interfaces_(allowed_interfaces),
|
| - allow_all_interfaces_(allowed_interfaces_.size() == 1 &&
|
| - allowed_interfaces_.count("*") == 1),
|
| - content_handler_id_(0u),
|
| - is_content_handler_id_valid_(false),
|
| - weak_factory_(this) {
|
| - if (local_services.is_pending())
|
| - local_binding_.Bind(std::move(local_services));
|
| -}
|
| -
|
| -ServiceRegistry::ServiceRegistry()
|
| - : local_binding_(this),
|
| - allow_all_interfaces_(true),
|
| - weak_factory_(this) {
|
| -}
|
| -
|
| -ServiceRegistry::~ServiceRegistry() {
|
| -}
|
| -
|
| -Shell::ConnectToApplicationCallback
|
| -ServiceRegistry::GetConnectToApplicationCallback() {
|
| - return base::Bind(&ServiceRegistry::OnGotContentHandlerID,
|
| - weak_factory_.GetWeakPtr());
|
| -}
|
| -
|
| -void ServiceRegistry::SetServiceConnector(ServiceConnector* connector) {
|
| - service_connector_registry_.set_service_connector(connector);
|
| -}
|
| -
|
| -bool ServiceRegistry::SetServiceConnectorForName(
|
| - ServiceConnector* service_connector,
|
| - const std::string& interface_name) {
|
| - if (allow_all_interfaces_ ||
|
| - allowed_interfaces_.count(interface_name)) {
|
| - service_connector_registry_.SetServiceConnectorForName(service_connector,
|
| - interface_name);
|
| - return true;
|
| - }
|
| - LOG(WARNING) << "CapabilityFilter prevented connection to interface: "
|
| - << interface_name << " connection_url:" << connection_url_
|
| - << " remote_url:" << remote_url_;
|
| - return false;
|
| -}
|
| -
|
| -ServiceProvider* ServiceRegistry::GetLocalServiceProvider() {
|
| - return this;
|
| -}
|
| -
|
| -void ServiceRegistry::SetRemoteServiceProviderConnectionErrorHandler(
|
| - const Closure& handler) {
|
| - remote_service_provider_.set_connection_error_handler(handler);
|
| -}
|
| -
|
| -bool ServiceRegistry::GetContentHandlerID(uint32_t* content_handler_id) {
|
| - if (!is_content_handler_id_valid_)
|
| - return false;
|
| -
|
| - *content_handler_id = content_handler_id_;
|
| - return true;
|
| -}
|
| -
|
| -void ServiceRegistry::AddContentHandlerIDCallback(const Closure& callback) {
|
| - if (is_content_handler_id_valid_) {
|
| - callback.Run();
|
| - return;
|
| - }
|
| - content_handler_id_callbacks_.push_back(callback);
|
| -}
|
| -
|
| -base::WeakPtr<ApplicationConnection> ServiceRegistry::GetWeakPtr() {
|
| - return weak_factory_.GetWeakPtr();
|
| -}
|
| -
|
| -void ServiceRegistry::RemoveServiceConnectorForName(
|
| - const std::string& interface_name) {
|
| - service_connector_registry_.RemoveServiceConnectorForName(interface_name);
|
| - if (service_connector_registry_.empty())
|
| - remote_service_provider_.reset();
|
| -}
|
| -
|
| -const std::string& ServiceRegistry::GetConnectionURL() {
|
| - return connection_url_;
|
| -}
|
| -
|
| -const std::string& ServiceRegistry::GetRemoteApplicationURL() {
|
| - return remote_url_;
|
| -}
|
| -
|
| -ServiceProvider* ServiceRegistry::GetServiceProvider() {
|
| - return remote_service_provider_.get();
|
| -}
|
| -
|
| -void ServiceRegistry::OnGotContentHandlerID(uint32_t content_handler_id) {
|
| - DCHECK(!is_content_handler_id_valid_);
|
| - is_content_handler_id_valid_ = true;
|
| - content_handler_id_ = content_handler_id;
|
| - std::vector<Closure> callbacks;
|
| - callbacks.swap(content_handler_id_callbacks_);
|
| - for (auto callback : callbacks)
|
| - callback.Run();
|
| -}
|
| -
|
| -void ServiceRegistry::ConnectToService(const mojo::String& service_name,
|
| - ScopedMessagePipeHandle client_handle) {
|
| - service_connector_registry_.ConnectToService(this, service_name,
|
| - std::move(client_handle));
|
| -}
|
| -
|
| -} // namespace internal
|
| -} // namespace mojo
|
|
|