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

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: revert to mojo interface of PS4 to have less logic in renderer 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(Platform::current()->mainThread()->isCurrentThread());
kinuko 2016/06/09 09:14:58 nit: DCHECK(isMainThread()) ?
Marijn Kruisselbrink 2016/06/22 18:46:57 Done
25 Platform::current()->serviceRegistry()->connectToRemoteService(std::move(req uest));
26 }
27
28 webmessaging::mojom::blink::BroadcastChannelServicePtr& getThreadSpecificService ()
haraken 2016/06/09 02:09:36 Add a comment why you need to use a thread-local s
Marijn Kruisselbrink 2016/06/22 18:46:56 Done
29 {
30 DEFINE_THREAD_SAFE_STATIC_LOCAL(ThreadSpecific<webmessaging::mojom::blink::B roadcastChannelServicePtr>, service, new ThreadSpecific<webmessaging::mojom::bli nk::BroadcastChannelServicePtr>);
31 if (!service.isSet()) {
32 Platform::current()->mainThread()->getWebTaskRunner()->postTask(BLINK_FR OM_HERE,
33 threadSafeBind(&connectToService, passed(mojo::GetProxy(&*service))) );
34 }
35 return *service;
36 }
37
38 } // namespace
39
40 // static
41 BroadcastChannel* BroadcastChannel::create(ExecutionContext* executionContext, c onst String& name, ExceptionState& exceptionState)
42 {
43 if (executionContext->getSecurityOrigin()->isUnique()) {
44 // TODO(mek): Decide what to do here depending on https://github.com/wha twg/html/issues/1319
45 exceptionState.throwDOMException(NotSupportedError, "Can't create Broadc astChannel in an opaque origin");
46 return nullptr;
47 }
48 return new BroadcastChannel(executionContext, name);
49 }
50
51 BroadcastChannel::~BroadcastChannel()
52 {
53 }
54
55 void BroadcastChannel::dispose()
56 {
57 close();
58 }
59
60 void BroadcastChannel::postMessage(const ScriptValue& message, ExceptionState& e xceptionState)
61 {
62 if (!m_binding.is_bound()) {
63 exceptionState.throwDOMException(InvalidStateError, "Channel is closed") ;
64 return;
65 }
66 RefPtr<SerializedScriptValue> value = SerializedScriptValue::serialize(messa ge.isolate(), message.v8Value(), nullptr, nullptr, exceptionState);
67 if (exceptionState.hadException())
68 return;
69
70 String data = value->toWireString();
71 m_remoteClient->OnMessage(data);
72 }
73
74 void BroadcastChannel::close()
75 {
76 m_remoteClient.reset();
77 if (m_binding.is_bound())
78 m_binding.Close();
79 }
80
81 const AtomicString& BroadcastChannel::interfaceName() const
82 {
83 return EventTargetNames::BroadcastChannel;
84 }
85
86 bool BroadcastChannel::hasPendingActivity() const
87 {
88 return m_binding.is_bound() && hasEventListeners(EventTypeNames::message);
89 }
90
91 void BroadcastChannel::contextDestroyed()
92 {
93 close();
94 }
95
96 DEFINE_TRACE(BroadcastChannel)
97 {
98 ContextLifecycleObserver::trace(visitor);
99 EventTargetWithInlineData::trace(visitor);
100 }
101
102 void BroadcastChannel::OnMessage(const String& message)
103 {
104 // Queue a task to dispatch the event.
105 RefPtr<SerializedScriptValue> value = SerializedScriptValue::create(message) ;
106 MessageEvent* event = MessageEvent::create(nullptr, value.release(), getExec utionContext()->getSecurityOrigin()->toString());
107 event->setTarget(this);
108 bool success = getExecutionContext()->getEventQueue()->enqueueEvent(event);
109 DCHECK(success);
110 ALLOW_UNUSED_LOCAL(success);
111 }
112
113 void BroadcastChannel::onError()
114 {
115 close();
116 }
117
118 BroadcastChannel::BroadcastChannel(ExecutionContext* executionContext, const Str ing& name)
119 : ActiveScriptWrappable(this)
120 , ContextLifecycleObserver(executionContext)
121 , m_origin(executionContext->getSecurityOrigin())
122 , m_name(name)
123 , m_binding(this)
124 {
125 webmessaging::mojom::blink::BroadcastChannelServicePtr& service = getThreadS pecificService();
126
127 // Local BroadcastChannelClient for messages send from the browser to this c hannel.
128 webmessaging::mojom::blink::BroadcastChannelClientAssociatedPtrInfo localCli entInfo;
129 m_binding.Bind(&localClientInfo, service.associated_group());
130 m_binding.set_connection_error_handler(createBaseCallback(bind(&BroadcastCha nnel::onError, WeakPersistentThisPointer<BroadcastChannel>(this))));
131
132 // Remove BroadcastChannelClient for messages send from this channel to the browser.
kinuko 2016/06/09 09:14:58 Um... I guess s/Remove/Remote/ ?
Marijn Kruisselbrink 2016/06/22 18:46:57 Ah yes, done.
133 webmessaging::mojom::blink::BroadcastChannelClientAssociatedPtrInfo remoteCl ientInfo;
134 mojo::AssociatedInterfaceRequest<webmessaging::mojom::blink::BroadcastChanne lClient> remoteCientRequest;
135 service.associated_group()->CreateAssociatedInterface(mojo::AssociatedGroup: :WILL_PASS_REQUEST, &remoteClientInfo, &remoteCientRequest);
136 m_remoteClient.Bind(std::move(remoteClientInfo));
137 m_remoteClient.set_connection_error_handler(createBaseCallback(bind(&Broadca stChannel::onError, WeakPersistentThisPointer<BroadcastChannel>(this))));
138
139 service->ConnectToChannel(m_origin, m_name, std::move(localClientInfo), std: :move(remoteCientRequest));
140 }
141
142 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698