| 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 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 126 origin = sourceOrigin.toString(); | 126 origin = sourceOrigin.toString(); |
| 127 ServiceWorker* source = ServiceWorker::from(m_workerGlobalScope->getExecutio
nContext(), wrapUnique(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 responseID, int event
FinishID, const WebServiceWorkerRequest& webRequest) | 134 void ServiceWorkerGlobalScopeProxy::dispatchFetchEvent(int responseID, int event
FinishID, const WebServiceWorkerRequest& webRequest) |
| 135 { | 135 { |
| 136 ScriptState::Scope scope(workerGlobalScope()->scriptController()->getScriptS
tate()); |
| 136 WaitUntilObserver* waitUntilObserver = WaitUntilObserver::create(workerGloba
lScope(), WaitUntilObserver::Fetch, eventFinishID); | 137 WaitUntilObserver* waitUntilObserver = WaitUntilObserver::create(workerGloba
lScope(), WaitUntilObserver::Fetch, eventFinishID); |
| 137 RespondWithObserver* respondWithObserver = RespondWithObserver::create(worke
rGlobalScope(), responseID, webRequest.url(), webRequest.mode(), webRequest.fram
eType(), webRequest.requestContext(), waitUntilObserver); | 138 RespondWithObserver* respondWithObserver = RespondWithObserver::create(worke
rGlobalScope(), responseID, webRequest.url(), webRequest.mode(), webRequest.fram
eType(), webRequest.requestContext(), waitUntilObserver); |
| 138 Request* request = Request::create(workerGlobalScope()->scriptController()->
getScriptState(), webRequest); | 139 Request* request = Request::create(workerGlobalScope()->scriptController()->
getScriptState(), webRequest); |
| 139 request->getHeaders()->setGuard(Headers::ImmutableGuard); | 140 request->getHeaders()->setGuard(Headers::ImmutableGuard); |
| 140 FetchEventInit eventInit; | 141 FetchEventInit eventInit; |
| 141 eventInit.setCancelable(true); | 142 eventInit.setCancelable(true); |
| 142 eventInit.setRequest(request); | 143 eventInit.setRequest(request); |
| 143 eventInit.setClientId(webRequest.isMainResourceLoad() ? WebString() : webReq
uest.clientId()); | 144 eventInit.setClientId(webRequest.isMainResourceLoad() ? WebString() : webReq
uest.clientId()); |
| 144 eventInit.setIsReload(webRequest.isReload()); | 145 eventInit.setIsReload(webRequest.isReload()); |
| 145 FetchEvent* fetchEvent = FetchEvent::create(workerGlobalScope()->scriptContr
oller()->getScriptState(), EventTypeNames::fetch, eventInit, respondWithObserver
, waitUntilObserver); | 146 FetchEvent* fetchEvent = FetchEvent::create(workerGlobalScope()->scriptContr
oller()->getScriptState(), EventTypeNames::fetch, eventInit, respondWithObserver
, waitUntilObserver); |
| 146 waitUntilObserver->willDispatchEvent(); | 147 waitUntilObserver->willDispatchEvent(); |
| 147 DispatchEventResult dispatchResult = workerGlobalScope()->dispatchEvent(fetc
hEvent); | 148 DispatchEventResult dispatchResult = workerGlobalScope()->dispatchEvent(fetc
hEvent); |
| 148 respondWithObserver->didDispatchEvent(dispatchResult); | 149 respondWithObserver->didDispatchEvent(dispatchResult); |
| 149 // false is okay because waitUntil for fetch event doesn't care about the | 150 // false is okay because waitUntil for fetch event doesn't care about the |
| 150 // promise rejection or an uncaught runtime script error. | 151 // promise rejection or an uncaught runtime script error. |
| 151 waitUntilObserver->didDispatchEvent(false /* errorOccurred */); | 152 waitUntilObserver->didDispatchEvent(false /* errorOccurred */); |
| 152 } | 153 } |
| 153 | 154 |
| 154 void ServiceWorkerGlobalScopeProxy::dispatchForeignFetchEvent(int responseID, in
t eventFinishID, const WebServiceWorkerRequest& webRequest) | 155 void ServiceWorkerGlobalScopeProxy::dispatchForeignFetchEvent(int responseID, in
t eventFinishID, const WebServiceWorkerRequest& webRequest) |
| 155 { | 156 { |
| 157 ScriptState::Scope scope(workerGlobalScope()->scriptController()->getScriptS
tate()); |
| 156 RefPtr<SecurityOrigin> origin = SecurityOrigin::create(webRequest.referrerUr
l()); | 158 RefPtr<SecurityOrigin> origin = SecurityOrigin::create(webRequest.referrerUr
l()); |
| 157 WaitUntilObserver* waitUntilObserver = WaitUntilObserver::create(workerGloba
lScope(), WaitUntilObserver::Fetch, eventFinishID); | 159 WaitUntilObserver* waitUntilObserver = WaitUntilObserver::create(workerGloba
lScope(), WaitUntilObserver::Fetch, eventFinishID); |
| 158 ForeignFetchRespondWithObserver* respondWithObserver = ForeignFetchRespondWi
thObserver::create(workerGlobalScope(), responseID, webRequest.url(), webRequest
.mode(), webRequest.frameType(), webRequest.requestContext(), origin, waitUntilO
bserver); | 160 ForeignFetchRespondWithObserver* respondWithObserver = ForeignFetchRespondWi
thObserver::create(workerGlobalScope(), responseID, webRequest.url(), webRequest
.mode(), webRequest.frameType(), webRequest.requestContext(), origin, waitUntilO
bserver); |
| 159 Request* request = Request::create(workerGlobalScope()->scriptController()->
getScriptState(), webRequest); | 161 Request* request = Request::create(workerGlobalScope()->scriptController()->
getScriptState(), webRequest); |
| 160 request->getHeaders()->setGuard(Headers::ImmutableGuard); | 162 request->getHeaders()->setGuard(Headers::ImmutableGuard); |
| 161 ForeignFetchEventInit eventInit; | 163 ForeignFetchEventInit eventInit; |
| 162 eventInit.setCancelable(true); | 164 eventInit.setCancelable(true); |
| 163 eventInit.setRequest(request); | 165 eventInit.setRequest(request); |
| 164 eventInit.setOrigin(origin->toString()); | 166 eventInit.setOrigin(origin->toString()); |
| 165 ForeignFetchEvent* fetchEvent = ForeignFetchEvent::create(workerGlobalScope(
)->scriptController()->getScriptState(), EventTypeNames::foreignfetch, eventInit
, respondWithObserver, waitUntilObserver); | 167 ForeignFetchEvent* fetchEvent = ForeignFetchEvent::create(workerGlobalScope(
)->scriptController()->getScriptState(), EventTypeNames::foreignfetch, eventInit
, respondWithObserver, waitUntilObserver); |
| (...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 308 return *m_document; | 310 return *m_document; |
| 309 } | 311 } |
| 310 | 312 |
| 311 ServiceWorkerGlobalScope* ServiceWorkerGlobalScopeProxy::workerGlobalScope() con
st | 313 ServiceWorkerGlobalScope* ServiceWorkerGlobalScopeProxy::workerGlobalScope() con
st |
| 312 { | 314 { |
| 313 DCHECK(m_workerGlobalScope); | 315 DCHECK(m_workerGlobalScope); |
| 314 return m_workerGlobalScope; | 316 return m_workerGlobalScope; |
| 315 } | 317 } |
| 316 | 318 |
| 317 } // namespace blink | 319 } // namespace blink |
| OLD | NEW |