Index: components/webmessaging/broadcast_channel_provider.cc |
diff --git a/components/webmessaging/broadcast_channel_provider.cc b/components/webmessaging/broadcast_channel_provider.cc |
deleted file mode 100644 |
index 78d3dc6cc5a6c740e74203448f71d4c587f4c420..0000000000000000000000000000000000000000 |
--- a/components/webmessaging/broadcast_channel_provider.cc |
+++ /dev/null |
@@ -1,115 +0,0 @@ |
-// Copyright 2016 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 "components/webmessaging/broadcast_channel_provider.h" |
- |
-#include "base/bind.h" |
-#include "base/stl_util.h" |
-#include "mojo/public/cpp/bindings/associated_binding.h" |
-#include "mojo/public/cpp/bindings/interface_ptr_set.h" |
-#include "mojo/public/cpp/bindings/strong_binding.h" |
- |
-namespace webmessaging { |
- |
-// There is a one-to-one mapping of BroadcastChannel instances in the renderer |
-// and Connection instances in the browser. The Connection is owned by a |
-// BroadcastChannelProvider. |
-class BroadcastChannelProvider::Connection |
- : public mojom::BroadcastChannelClient { |
- public: |
- Connection(const url::Origin& origin, |
- const mojo::String& name, |
- mojom::BroadcastChannelClientAssociatedPtrInfo client, |
- mojom::BroadcastChannelClientAssociatedRequest connection, |
- webmessaging::BroadcastChannelProvider* service); |
- |
- void OnMessage(const mojo::String& message) override; |
- void MessageToClient(const mojo::String& message) const { |
- client_->OnMessage(message); |
- } |
- const url::Origin& origin() const { return origin_; } |
- const std::string& name() const { return name_; } |
- |
- void set_connection_error_handler(const base::Closure& error_handler) { |
- binding_.set_connection_error_handler(error_handler); |
- client_.set_connection_error_handler(error_handler); |
- } |
- |
- private: |
- mojo::AssociatedBinding<mojom::BroadcastChannelClient> binding_; |
- mojom::BroadcastChannelClientAssociatedPtr client_; |
- |
- webmessaging::BroadcastChannelProvider* service_; |
- url::Origin origin_; |
- std::string name_; |
-}; |
- |
-BroadcastChannelProvider::Connection::Connection( |
- const url::Origin& origin, |
- const mojo::String& name, |
- mojom::BroadcastChannelClientAssociatedPtrInfo client, |
- mojom::BroadcastChannelClientAssociatedRequest connection, |
- webmessaging::BroadcastChannelProvider* service) |
- : binding_(this, std::move(connection)), |
- service_(service), |
- origin_(origin), |
- name_(name) { |
- client_.Bind(std::move(client)); |
-} |
- |
-void BroadcastChannelProvider::Connection::OnMessage( |
- const mojo::String& message) { |
- service_->ReceivedMessageOnConnection(this, message); |
-} |
- |
-BroadcastChannelProvider::BroadcastChannelProvider() {} |
- |
-void BroadcastChannelProvider::Connect( |
- mojo::InterfaceRequest<mojom::BroadcastChannelProvider> request) { |
- bindings_.AddBinding(this, std::move(request)); |
-} |
- |
-void BroadcastChannelProvider::ConnectToChannel( |
- const url::Origin& origin, |
- const mojo::String& name, |
- mojom::BroadcastChannelClientAssociatedPtrInfo client, |
- mojom::BroadcastChannelClientAssociatedRequest connection) { |
- std::unique_ptr<Connection> c(new Connection(origin, name, std::move(client), |
- std::move(connection), this)); |
- c->set_connection_error_handler( |
- base::Bind(&BroadcastChannelProvider::UnregisterConnection, |
- base::Unretained(this), c.get())); |
- connections_[origin].insert(std::make_pair(name, std::move(c))); |
-} |
- |
-BroadcastChannelProvider::~BroadcastChannelProvider() {} |
- |
-void BroadcastChannelProvider::UnregisterConnection(Connection* c) { |
- url::Origin origin = c->origin(); |
- auto& connections = connections_[origin]; |
- for (auto it = connections.lower_bound(c->name()), |
- end = connections.upper_bound(c->name()); |
- it != end; ++it) { |
- if (it->second.get() == c) { |
- connections.erase(it); |
- break; |
- } |
- } |
- if (connections.empty()) |
- connections_.erase(origin); |
-} |
- |
-void BroadcastChannelProvider::ReceivedMessageOnConnection( |
- Connection* c, |
- const mojo::String& message) { |
- auto& connections = connections_[c->origin()]; |
- for (auto it = connections.lower_bound(c->name()), |
- end = connections.upper_bound(c->name()); |
- it != end; ++it) { |
- if (it->second.get() != c) |
- it->second->MessageToClient(message); |
- } |
-} |
- |
-} // namespace webmessaging |