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
ServiceRegistryImpl()11 ServiceRegistryImpl::ServiceRegistryImpl()
12 : bound_(false), weak_factory_(this) {
13 }
14
ServiceRegistryImpl(mojo::ScopedMessagePipeHandle handle)15 ServiceRegistryImpl::ServiceRegistryImpl(mojo::ScopedMessagePipeHandle handle)
16 : bound_(false), weak_factory_(this) {
17 BindRemoteServiceProvider(handle.Pass());
18 }
19
~ServiceRegistryImpl()20 ServiceRegistryImpl::~ServiceRegistryImpl() {
21 while (!pending_connects_.empty()) {
22 mojo::CloseRaw(pending_connects_.front().second);
23 pending_connects_.pop();
24 }
25 }
26
BindRemoteServiceProvider(mojo::ScopedMessagePipeHandle handle)27 void ServiceRegistryImpl::BindRemoteServiceProvider(
28 mojo::ScopedMessagePipeHandle handle) {
29 DCHECK(!bound_);
30 bound_ = true;
31 mojo::WeakBindToPipe(this, handle.Pass());
32 while (!pending_connects_.empty()) {
33 client()->ConnectToService(
34 mojo::String::From(pending_connects_.front().first),
35 mojo::ScopedMessagePipeHandle(pending_connects_.front().second));
36 pending_connects_.pop();
37 }
38 }
39
OnConnectionError()40 void ServiceRegistryImpl::OnConnectionError() {
41 // TODO(sammc): Support reporting this to our owner.
42 }
43
AddService(const std::string & service_name,const base::Callback<void (mojo::ScopedMessagePipeHandle)> service_factory)44 void ServiceRegistryImpl::AddService(
45 const std::string& service_name,
46 const base::Callback<void(mojo::ScopedMessagePipeHandle)> service_factory) {
47 bool inserted = service_factories_.insert(
48 std::make_pair(service_name, service_factory)).second;
49 DCHECK(inserted);
50 }
51
RemoveService(const std::string & service_name)52 void ServiceRegistryImpl::RemoveService(const std::string& service_name) {
53 service_factories_.erase(service_name);
54 }
55
ConnectToRemoteService(const base::StringPiece & service_name,mojo::ScopedMessagePipeHandle handle)56 void ServiceRegistryImpl::ConnectToRemoteService(
57 const base::StringPiece& service_name,
58 mojo::ScopedMessagePipeHandle handle) {
59 if (!bound_) {
60 pending_connects_.push(
61 std::make_pair(service_name.as_string(), handle.release()));
62 return;
63 }
64 client()->ConnectToService(mojo::String::From(service_name), handle.Pass());
65 }
66
GetWeakPtr()67 base::WeakPtr<ServiceRegistry> ServiceRegistryImpl::GetWeakPtr() {
68 return weak_factory_.GetWeakPtr();
69 }
70
ConnectToService(const mojo::String & name,mojo::ScopedMessagePipeHandle client_handle)71 void ServiceRegistryImpl::ConnectToService(
72 const mojo::String& name,
73 mojo::ScopedMessagePipeHandle client_handle) {
74 std::map<std::string,
75 base::Callback<void(mojo::ScopedMessagePipeHandle)> >::iterator it =
76 service_factories_.find(name);
77 if (it == service_factories_.end())
78 return;
79
80 it->second.Run(client_handle.Pass());
81 }
82
83 } // namespace content
84