1 /*
2 * Copyright (C) 2009 Google Inc. All rights reserved.
3 *
4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions are
6 * met:
7 *
8 * * Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * * Redistributions in binary form must reproduce the above
11 * copyright notice, this list of conditions and the following disclaimer
12 * in the documentation and/or other materials provided with the
13 * distribution.
14 * * Neither the name of Google Inc. nor the names of its
15 * contributors may be used to endorse or promote products derived from
16 * this software without specific prior written permission.
17 *
18 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
19 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
20 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
21 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
22 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
23 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
24 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
25 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
26 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
29 */
30
31 #include "config.h"
32 #include "WebSharedWorkerImpl.h"
33
34 #include "CrossThreadTask.h"
35 #include "KURL.h"
36 #include "MessageEvent.h"
37 #include "MessagePortChannel.h"
38 #include "PlatformMessagePortChannel.h"
39 #include "ScriptExecutionContext.h"
40 #include "SharedWorkerContext.h"
41 #include "SharedWorkerThread.h"
42
43 #include "WebMessagePortChannel.h"
44 #include "WebString.h"
45 #include "WebURL.h"
46
47 using namespace WebCore;
48
49 namespace WebKit {
50
51 #if ENABLE(SHARED_WORKERS)
52
WebSharedWorkerImpl(WebCommonWorkerClient * client)53 WebSharedWorkerImpl::WebSharedWorkerImpl(WebCommonWorkerClient* client)
54 : m_client(client)
55 {
56 }
57
~WebSharedWorkerImpl()58 WebSharedWorkerImpl::~WebSharedWorkerImpl()
59 {
60 }
61
isStarted()62 bool WebSharedWorkerImpl::isStarted()
63 {
64 // Should not ever be called from the worker thread (this API is only called on WebSharedWorkerProxy on the renderer thread).
65 ASSERT_NOT_REACHED();
66 return workerThread();
67 }
68
connect(WebMessagePortChannel * webChannel,ConnectListener * listener)69 void WebSharedWorkerImpl::connect(WebMessagePortChannel* webChannel, ConnectListener* listener)
70 {
71 // Convert the WebMessagePortChanel to a WebCore::MessagePortChannel.
72 RefPtr<PlatformMessagePortChannel> platform_channel =
73 PlatformMessagePortChannel::create(webChannel);
74 webChannel->setClient(platform_channel.get());
75 OwnPtr<MessagePortChannel> channel =
76 MessagePortChannel::create(platform_channel);
77
78 workerThread()->runLoop().postTask(
79 createCallbackTask(&connectTask, this, channel.release()));
80 if (listener)
81 listener->connected();
82 }
83
connectTask(ScriptExecutionContext * context,WebSharedWorkerImpl * worker,PassOwnPtr<MessagePortChannel> channel)84 void WebSharedWorkerImpl::connectTask(ScriptExecutionContext* context, WebSharedWorkerImpl* worker, PassOwnPtr<MessagePortChannel> channel)
85 {
86 // Wrap the passed-in channel in a MessagePort, and send it off via a connect event.
87 RefPtr<MessagePort> port = MessagePort::create(*context);
88 port->entangle(channel);
89 ASSERT(context->isWorkerContext());
90 WorkerContext* workerContext = static_cast<WorkerContext*>(context);
91 ASSERT(workerContext->isSharedWorkerContext());
92 workerContext->toSharedWorkerContext()->dispatchEvent(createConnectEvent(port));
93 }
94
startWorkerContext(const WebURL & url,const WebString & name,const WebString & userAgent,const WebString & sourceCode,long long)95 void WebSharedWorkerImpl::startWorkerContext(const WebURL& url, const WebString& name, const WebString& userAgent, const WebString& sourceCode, long long)
96 {
97 initializeLoader(url);
98 setWorkerThread(SharedWorkerThread::create(name, url, userAgent, sourceCode, *this, *this));
99 workerThread()->start();
100 }
101
terminateWorkerContext()102 void WebSharedWorkerImpl::terminateWorkerContext()
103 {
104 stopWorkerThread();
105 }
106
clientDestroyed()107 void WebSharedWorkerImpl::clientDestroyed()
108 {
109 m_client = 0;
110 }
111
client()112 WebWorkerClient* WebSharedWorkerImpl::client()
113 {
114 // We should never be asked for a WebWorkerClient (only dedicated workers have an associated WebWorkerClient).
115 // It should not be possible for SharedWorkerContext to generate an API call outside those supported by WebCommonWorkerClient.
116 ASSERT_NOT_REACHED();
117 return 0;
118 }
119
create(WebCommonWorkerClient * client)120 WebSharedWorker* WebSharedWorker::create(WebCommonWorkerClient* client)
121 {
122 return new WebSharedWorkerImpl(client);
123 }
124
125 #endif // ENABLE(SHARED_WORKERS)
126
127 } // namespace WebKit
128