Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(386)

Side by Side Diff: third_party/WebKit/Source/modules/broadcastchannel/BroadcastChannel.cpp

Issue 2004643002: Implement BroadcastChannel (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: address comments Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright 2016 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 "modules/broadcastchannel/BroadcastChannel.h"
6
7 #include "bindings/core/v8/SerializedScriptValue.h"
8 #include "core/dom/ExceptionCode.h"
9 #include "core/events/EventQueue.h"
10 #include "core/events/MessageEvent.h"
11 #include "platform/ThreadSafeFunctional.h"
12 #include "platform/mojo/MojoHelper.h"
13 #include "public/platform/Platform.h"
14 #include "public/platform/ServiceRegistry.h"
15 #include "public/platform/WebTaskRunner.h"
16 #include "public/platform/WebTraceLocation.h"
17
18 namespace blink {
19
20 namespace {
21
22 void connectToService(webmessaging::mojom::blink::BroadcastChannelServiceRequest request)
23 {
24 DCHECK(isMainThread());
25 Platform::current()->serviceRegistry()->connectToRemoteService(std::move(req uest));
26 }
27
28 // To ensure proper ordering of messages send to/from multiple BroadcastChannel
29 // instances in the same thread this uses one BroadcastChannelService
30 // connection as basis for all connections to channels from the same thread. The
31 // actual connections used to send/receive messages are then created using
32 // associated interfaces, ensuring proper message ordering.
33 webmessaging::mojom::blink::BroadcastChannelServicePtr& getThreadSpecificService ()
34 {
35 DEFINE_THREAD_SAFE_STATIC_LOCAL(ThreadSpecific<webmessaging::mojom::blink::B roadcastChannelServicePtr>, service, new ThreadSpecific<webmessaging::mojom::bli nk::BroadcastChannelServicePtr>);
36 if (!service.isSet()) {
37 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE,
38 threadSafeBind(&connectToService, passed(mojo::GetProxy(&*service))) );
kinuko 2016/06/23 15:29:57 I was looking into connectToRemoteService impl and
Marijn Kruisselbrink 2016/06/23 16:32:32 Ah yes, seems that was changed recently to work fr
39 }
40 return *service;
41 }
42
43 } // namespace
44
45 // static
46 BroadcastChannel* BroadcastChannel::create(ExecutionContext* executionContext, c onst String& name, ExceptionState& exceptionState)
47 {
48 if (executionContext->getSecurityOrigin()->isUnique()) {
49 // TODO(mek): Decide what to do here depending on https://github.com/wha twg/html/issues/1319
50 exceptionState.throwDOMException(NotSupportedError, "Can't create Broadc astChannel in an opaque origin");
51 return nullptr;
52 }
53 return new BroadcastChannel(executionContext, name);
54 }
55
56 BroadcastChannel::~BroadcastChannel()
57 {
58 }
59
60 void BroadcastChannel::dispose()
61 {
62 close();
63 }
64
65 void BroadcastChannel::postMessage(const ScriptValue& message, ExceptionState& e xceptionState)
66 {
67 if (!m_binding.is_bound()) {
68 exceptionState.throwDOMException(InvalidStateError, "Channel is closed") ;
69 return;
70 }
71 RefPtr<SerializedScriptValue> value = SerializedScriptValue::serialize(messa ge.isolate(), message.v8Value(), nullptr, nullptr, exceptionState);
72 if (exceptionState.hadException())
73 return;
74
75 String data = value->toWireString();
76 m_remoteClient->OnMessage(data);
77 }
78
79 void BroadcastChannel::close()
80 {
81 m_remoteClient.reset();
82 if (m_binding.is_bound())
83 m_binding.Close();
84 }
85
86 const AtomicString& BroadcastChannel::interfaceName() const
87 {
88 return EventTargetNames::BroadcastChannel;
89 }
90
91 bool BroadcastChannel::hasPendingActivity() const
92 {
93 return m_binding.is_bound() && hasEventListeners(EventTypeNames::message);
94 }
95
96 void BroadcastChannel::contextDestroyed()
97 {
98 close();
99 }
100
101 DEFINE_TRACE(BroadcastChannel)
102 {
103 ContextLifecycleObserver::trace(visitor);
104 EventTargetWithInlineData::trace(visitor);
105 }
106
107 void BroadcastChannel::OnMessage(const String& message)
108 {
109 // Queue a task to dispatch the event.
110 RefPtr<SerializedScriptValue> value = SerializedScriptValue::create(message) ;
111 MessageEvent* event = MessageEvent::create(nullptr, value.release(), getExec utionContext()->getSecurityOrigin()->toString());
112 event->setTarget(this);
113 bool success = getExecutionContext()->getEventQueue()->enqueueEvent(event);
114 DCHECK(success);
115 ALLOW_UNUSED_LOCAL(success);
116 }
117
118 void BroadcastChannel::onError()
119 {
120 close();
121 }
122
123 BroadcastChannel::BroadcastChannel(ExecutionContext* executionContext, const Str ing& name)
124 : ActiveScriptWrappable(this)
125 , ContextLifecycleObserver(executionContext)
126 , m_origin(executionContext->getSecurityOrigin())
127 , m_name(name)
128 , m_binding(this)
129 {
130 webmessaging::mojom::blink::BroadcastChannelServicePtr& service = getThreadS pecificService();
131
132 // Local BroadcastChannelClient for messages send from the browser to this c hannel.
133 webmessaging::mojom::blink::BroadcastChannelClientAssociatedPtrInfo localCli entInfo;
134 m_binding.Bind(&localClientInfo, service.associated_group());
135 m_binding.set_connection_error_handler(createBaseCallback(bind(&BroadcastCha nnel::onError, WeakPersistentThisPointer<BroadcastChannel>(this))));
136
137 // Remote BroadcastChannelClient for messages send from this channel to the browser.
138 webmessaging::mojom::blink::BroadcastChannelClientAssociatedPtrInfo remoteCl ientInfo;
139 mojo::AssociatedInterfaceRequest<webmessaging::mojom::blink::BroadcastChanne lClient> remoteCientRequest;
140 service.associated_group()->CreateAssociatedInterface(mojo::AssociatedGroup: :WILL_PASS_REQUEST, &remoteClientInfo, &remoteCientRequest);
141 m_remoteClient.Bind(std::move(remoteClientInfo));
142 m_remoteClient.set_connection_error_handler(createBaseCallback(bind(&Broadca stChannel::onError, WeakPersistentThisPointer<BroadcastChannel>(this))));
143
144 service->ConnectToChannel(m_origin, m_name, std::move(localClientInfo), std: :move(remoteCientRequest));
145 }
146
147 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698