OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2013 Google Inc. All rights reserved. | 2 * Copyright (C) 2013 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
6 * met: | 6 * met: |
7 * | 7 * |
8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
57 #include "modules/serviceworkers/WaitUntilObserver.h" | 57 #include "modules/serviceworkers/WaitUntilObserver.h" |
58 #include "platform/RuntimeEnabledFeatures.h" | 58 #include "platform/RuntimeEnabledFeatures.h" |
59 #include "public/platform/modules/notifications/WebNotificationData.h" | 59 #include "public/platform/modules/notifications/WebNotificationData.h" |
60 #include "public/platform/modules/serviceworker/WebServiceWorkerEventResult.h" | 60 #include "public/platform/modules/serviceworker/WebServiceWorkerEventResult.h" |
61 #include "public/platform/modules/serviceworker/WebServiceWorkerRequest.h" | 61 #include "public/platform/modules/serviceworker/WebServiceWorkerRequest.h" |
62 #include "public/web/WebSerializedScriptValue.h" | 62 #include "public/web/WebSerializedScriptValue.h" |
63 #include "public/web/modules/serviceworker/WebServiceWorkerContextClient.h" | 63 #include "public/web/modules/serviceworker/WebServiceWorkerContextClient.h" |
64 #include "web/WebEmbeddedWorkerImpl.h" | 64 #include "web/WebEmbeddedWorkerImpl.h" |
65 #include "wtf/Assertions.h" | 65 #include "wtf/Assertions.h" |
66 #include "wtf/Functional.h" | 66 #include "wtf/Functional.h" |
67 #include "wtf/PassOwnPtr.h" | 67 #include "wtf/PtrUtil.h" |
68 | 68 #include <memory> |
69 #include <utility> | 69 #include <utility> |
70 | 70 |
71 namespace blink { | 71 namespace blink { |
72 | 72 |
73 ServiceWorkerGlobalScopeProxy* ServiceWorkerGlobalScopeProxy::create(WebEmbedded
WorkerImpl& embeddedWorker, Document& document, WebServiceWorkerContextClient& c
lient) | 73 ServiceWorkerGlobalScopeProxy* ServiceWorkerGlobalScopeProxy::create(WebEmbedded
WorkerImpl& embeddedWorker, Document& document, WebServiceWorkerContextClient& c
lient) |
74 { | 74 { |
75 return new ServiceWorkerGlobalScopeProxy(embeddedWorker, document, client); | 75 return new ServiceWorkerGlobalScopeProxy(embeddedWorker, document, client); |
76 } | 76 } |
77 | 77 |
78 ServiceWorkerGlobalScopeProxy::~ServiceWorkerGlobalScopeProxy() | 78 ServiceWorkerGlobalScopeProxy::~ServiceWorkerGlobalScopeProxy() |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
117 workerGlobalScope()->dispatchExtendableEvent(event, observer); | 117 workerGlobalScope()->dispatchExtendableEvent(event, observer); |
118 } | 118 } |
119 | 119 |
120 void ServiceWorkerGlobalScopeProxy::dispatchExtendableMessageEvent(int eventID,
const WebString& message, const WebSecurityOrigin& sourceOrigin, const WebMessag
ePortChannelArray& webChannels, std::unique_ptr<WebServiceWorker::Handle> handle
) | 120 void ServiceWorkerGlobalScopeProxy::dispatchExtendableMessageEvent(int eventID,
const WebString& message, const WebSecurityOrigin& sourceOrigin, const WebMessag
ePortChannelArray& webChannels, std::unique_ptr<WebServiceWorker::Handle> handle
) |
121 { | 121 { |
122 WebSerializedScriptValue value = WebSerializedScriptValue::fromString(messag
e); | 122 WebSerializedScriptValue value = WebSerializedScriptValue::fromString(messag
e); |
123 MessagePortArray* ports = MessagePort::toMessagePortArray(m_workerGlobalScop
e, webChannels); | 123 MessagePortArray* ports = MessagePort::toMessagePortArray(m_workerGlobalScop
e, webChannels); |
124 String origin; | 124 String origin; |
125 if (!sourceOrigin.isUnique()) | 125 if (!sourceOrigin.isUnique()) |
126 origin = sourceOrigin.toString(); | 126 origin = sourceOrigin.toString(); |
127 ServiceWorker* source = ServiceWorker::from(m_workerGlobalScope->getExecutio
nContext(), adoptPtr(handle.release())); | 127 ServiceWorker* source = ServiceWorker::from(m_workerGlobalScope->getExecutio
nContext(), wrapUnique(handle.release())); |
128 WaitUntilObserver* observer = WaitUntilObserver::create(workerGlobalScope(),
WaitUntilObserver::Message, eventID); | 128 WaitUntilObserver* observer = WaitUntilObserver::create(workerGlobalScope(),
WaitUntilObserver::Message, eventID); |
129 | 129 |
130 Event* event = ExtendableMessageEvent::create(value, origin, ports, source,
observer); | 130 Event* event = ExtendableMessageEvent::create(value, origin, ports, source,
observer); |
131 workerGlobalScope()->dispatchExtendableEvent(event, observer); | 131 workerGlobalScope()->dispatchExtendableEvent(event, observer); |
132 } | 132 } |
133 | 133 |
134 void ServiceWorkerGlobalScopeProxy::dispatchFetchEvent(int eventID, const WebSer
viceWorkerRequest& webRequest) | 134 void ServiceWorkerGlobalScopeProxy::dispatchFetchEvent(int eventID, const WebSer
viceWorkerRequest& webRequest) |
135 { | 135 { |
136 RespondWithObserver* observer = RespondWithObserver::create(workerGlobalScop
e(), eventID, webRequest.url(), webRequest.mode(), webRequest.frameType(), webRe
quest.requestContext()); | 136 RespondWithObserver* observer = RespondWithObserver::create(workerGlobalScop
e(), eventID, webRequest.url(), webRequest.mode(), webRequest.frameType(), webRe
quest.requestContext()); |
137 Request* request = Request::create(workerGlobalScope()->scriptController()->
getScriptState(), webRequest); | 137 Request* request = Request::create(workerGlobalScope()->scriptController()->
getScriptState(), webRequest); |
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
210 Event* event = SyncEvent::create(EventTypeNames::sync, tag, lastChance == Is
LastChance, observer); | 210 Event* event = SyncEvent::create(EventTypeNames::sync, tag, lastChance == Is
LastChance, observer); |
211 workerGlobalScope()->dispatchExtendableEvent(event, observer); | 211 workerGlobalScope()->dispatchExtendableEvent(event, observer); |
212 } | 212 } |
213 | 213 |
214 bool ServiceWorkerGlobalScopeProxy::hasFetchEventHandler() | 214 bool ServiceWorkerGlobalScopeProxy::hasFetchEventHandler() |
215 { | 215 { |
216 DCHECK(m_workerGlobalScope); | 216 DCHECK(m_workerGlobalScope); |
217 return m_workerGlobalScope->hasEventListeners(EventTypeNames::fetch); | 217 return m_workerGlobalScope->hasEventListeners(EventTypeNames::fetch); |
218 } | 218 } |
219 | 219 |
220 void ServiceWorkerGlobalScopeProxy::reportException(const String& errorMessage,
PassOwnPtr<SourceLocation> location) | 220 void ServiceWorkerGlobalScopeProxy::reportException(const String& errorMessage,
std::unique_ptr<SourceLocation> location) |
221 { | 221 { |
222 client().reportException(errorMessage, location->lineNumber(), location->col
umnNumber(), location->url()); | 222 client().reportException(errorMessage, location->lineNumber(), location->col
umnNumber(), location->url()); |
223 } | 223 } |
224 | 224 |
225 void ServiceWorkerGlobalScopeProxy::reportConsoleMessage(ConsoleMessage* console
Message) | 225 void ServiceWorkerGlobalScopeProxy::reportConsoleMessage(ConsoleMessage* console
Message) |
226 { | 226 { |
227 client().reportConsoleMessage(consoleMessage->source(), consoleMessage->leve
l(), consoleMessage->message(), consoleMessage->location()->lineNumber(), consol
eMessage->location()->url()); | 227 client().reportConsoleMessage(consoleMessage->source(), consoleMessage->leve
l(), consoleMessage->message(), consoleMessage->location()->lineNumber(), consol
eMessage->location()->url()); |
228 } | 228 } |
229 | 229 |
230 void ServiceWorkerGlobalScopeProxy::postMessageToPageInspector(const String& mes
sage) | 230 void ServiceWorkerGlobalScopeProxy::postMessageToPageInspector(const String& mes
sage) |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
298 return *m_document; | 298 return *m_document; |
299 } | 299 } |
300 | 300 |
301 ServiceWorkerGlobalScope* ServiceWorkerGlobalScopeProxy::workerGlobalScope() con
st | 301 ServiceWorkerGlobalScope* ServiceWorkerGlobalScopeProxy::workerGlobalScope() con
st |
302 { | 302 { |
303 DCHECK(m_workerGlobalScope); | 303 DCHECK(m_workerGlobalScope); |
304 return m_workerGlobalScope; | 304 return m_workerGlobalScope; |
305 } | 305 } |
306 | 306 |
307 } // namespace blink | 307 } // namespace blink |
OLD | NEW |