OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/renderer/service_worker/service_worker_context_client.h" | 5 #include "content/renderer/service_worker/service_worker_context_client.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/lazy_instance.h" | 10 #include "base/lazy_instance.h" |
(...skipping 15 matching lines...) Expand all Loading... |
26 #include "content/child/service_worker/service_worker_provider_context.h" | 26 #include "content/child/service_worker/service_worker_provider_context.h" |
27 #include "content/child/service_worker/service_worker_registration_handle_refere
nce.h" | 27 #include "content/child/service_worker/service_worker_registration_handle_refere
nce.h" |
28 #include "content/child/service_worker/web_service_worker_impl.h" | 28 #include "content/child/service_worker/web_service_worker_impl.h" |
29 #include "content/child/service_worker/web_service_worker_provider_impl.h" | 29 #include "content/child/service_worker/web_service_worker_provider_impl.h" |
30 #include "content/child/service_worker/web_service_worker_registration_impl.h" | 30 #include "content/child/service_worker/web_service_worker_registration_impl.h" |
31 #include "content/child/thread_safe_sender.h" | 31 #include "content/child/thread_safe_sender.h" |
32 #include "content/child/web_data_consumer_handle_impl.h" | 32 #include "content/child/web_data_consumer_handle_impl.h" |
33 #include "content/child/web_url_loader_impl.h" | 33 #include "content/child/web_url_loader_impl.h" |
34 #include "content/child/webmessageportchannel_impl.h" | 34 #include "content/child/webmessageportchannel_impl.h" |
35 #include "content/common/devtools_messages.h" | 35 #include "content/common/devtools_messages.h" |
36 #include "content/common/message_port_messages.h" | |
37 #include "content/common/service_worker/embedded_worker_messages.h" | 36 #include "content/common/service_worker/embedded_worker_messages.h" |
38 #include "content/common/service_worker/service_worker_event_dispatcher.mojom.h" | 37 #include "content/common/service_worker/service_worker_event_dispatcher.mojom.h" |
39 #include "content/common/service_worker/service_worker_messages.h" | 38 #include "content/common/service_worker/service_worker_messages.h" |
40 #include "content/common/service_worker/service_worker_status_code.h" | 39 #include "content/common/service_worker/service_worker_status_code.h" |
41 #include "content/common/service_worker/service_worker_utils.h" | 40 #include "content/common/service_worker/service_worker_utils.h" |
42 #include "content/public/common/push_event_payload.h" | 41 #include "content/public/common/push_event_payload.h" |
43 #include "content/public/common/referrer.h" | 42 #include "content/public/common/referrer.h" |
44 #include "content/public/renderer/content_renderer_client.h" | 43 #include "content/public/renderer/content_renderer_client.h" |
45 #include "content/public/renderer/document_state.h" | 44 #include "content/public/renderer/document_state.h" |
46 #include "content/renderer/devtools/devtools_agent.h" | 45 #include "content/renderer/devtools/devtools_agent.h" |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
120 switch (result) { | 119 switch (result) { |
121 case blink::WebServiceWorkerEventResultCompleted: | 120 case blink::WebServiceWorkerEventResultCompleted: |
122 return SERVICE_WORKER_OK; | 121 return SERVICE_WORKER_OK; |
123 case blink::WebServiceWorkerEventResultRejected: | 122 case blink::WebServiceWorkerEventResultRejected: |
124 return SERVICE_WORKER_ERROR_EVENT_WAITUNTIL_REJECTED; | 123 return SERVICE_WORKER_ERROR_EVENT_WAITUNTIL_REJECTED; |
125 } | 124 } |
126 NOTREACHED() << "Got invalid result: " << result; | 125 NOTREACHED() << "Got invalid result: " << result; |
127 return SERVICE_WORKER_ERROR_FAILED; | 126 return SERVICE_WORKER_ERROR_FAILED; |
128 } | 127 } |
129 | 128 |
130 void SendPostMessageToClientOnMainThread( | |
131 ThreadSafeSender* sender, | |
132 int routing_id, | |
133 const std::string& uuid, | |
134 const base::string16& message, | |
135 std::unique_ptr<blink::WebMessagePortChannelArray> channels) { | |
136 sender->Send(new ServiceWorkerHostMsg_PostMessageToClient( | |
137 routing_id, uuid, message, | |
138 WebMessagePortChannelImpl::ExtractMessagePortIDs(std::move(channels)))); | |
139 } | |
140 | |
141 blink::WebURLRequest::FetchRequestMode GetBlinkFetchRequestMode( | 129 blink::WebURLRequest::FetchRequestMode GetBlinkFetchRequestMode( |
142 FetchRequestMode mode) { | 130 FetchRequestMode mode) { |
143 return static_cast<blink::WebURLRequest::FetchRequestMode>(mode); | 131 return static_cast<blink::WebURLRequest::FetchRequestMode>(mode); |
144 } | 132 } |
145 | 133 |
146 blink::WebURLRequest::FetchCredentialsMode GetBlinkFetchCredentialsMode( | 134 blink::WebURLRequest::FetchCredentialsMode GetBlinkFetchCredentialsMode( |
147 FetchCredentialsMode credentials_mode) { | 135 FetchCredentialsMode credentials_mode) { |
148 return static_cast<blink::WebURLRequest::FetchCredentialsMode>( | 136 return static_cast<blink::WebURLRequest::FetchCredentialsMode>( |
149 credentials_mode); | 137 credentials_mode); |
150 } | 138 } |
(...skipping 638 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
789 DCHECK(provider_context_); | 777 DCHECK(provider_context_); |
790 | 778 |
791 // Blink is responsible for deleting the returned object. | 779 // Blink is responsible for deleting the returned object. |
792 return new WebServiceWorkerProviderImpl( | 780 return new WebServiceWorkerProviderImpl( |
793 sender_.get(), provider_context_.get()); | 781 sender_.get(), provider_context_.get()); |
794 } | 782 } |
795 | 783 |
796 void ServiceWorkerContextClient::postMessageToClient( | 784 void ServiceWorkerContextClient::postMessageToClient( |
797 const blink::WebString& uuid, | 785 const blink::WebString& uuid, |
798 const blink::WebString& message, | 786 const blink::WebString& message, |
799 blink::WebMessagePortChannelArray* channels) { | 787 blink::WebMessagePortChannelArray channels) { |
800 // This may send channels for MessagePorts, and all internal book-keeping | 788 Send(new ServiceWorkerHostMsg_PostMessageToClient( |
801 // messages for MessagePort (e.g. QueueMessages) are sent from main thread | 789 GetRoutingID(), uuid.utf8(), message.utf16(), |
802 // (with thread hopping), so we need to do the same thread hopping here not | 790 WebMessagePortChannelImpl::ExtractMessagePorts(std::move(channels)))); |
803 // to overtake those messages. | |
804 std::unique_ptr<blink::WebMessagePortChannelArray> channel_array(channels); | |
805 main_thread_task_runner_->PostTask( | |
806 FROM_HERE, | |
807 base::Bind(&SendPostMessageToClientOnMainThread, | |
808 base::RetainedRef(sender_), GetRoutingID(), uuid.utf8(), | |
809 message.utf16(), base::Passed(&channel_array))); | |
810 } | 791 } |
811 | 792 |
812 void ServiceWorkerContextClient::focus( | 793 void ServiceWorkerContextClient::focus( |
813 const blink::WebString& uuid, | 794 const blink::WebString& uuid, |
814 std::unique_ptr<blink::WebServiceWorkerClientCallbacks> callback) { | 795 std::unique_ptr<blink::WebServiceWorkerClientCallbacks> callback) { |
815 DCHECK(callback); | 796 DCHECK(callback); |
816 int request_id = context_->client_callbacks.Add(std::move(callback)); | 797 int request_id = context_->client_callbacks.Add(std::move(callback)); |
817 Send(new ServiceWorkerHostMsg_FocusClient(GetRoutingID(), request_id, | 798 Send(new ServiceWorkerHostMsg_FocusClient(GetRoutingID(), request_id, |
818 uuid.utf8())); | 799 uuid.utf8())); |
819 } | 800 } |
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
913 | 894 |
914 void ServiceWorkerContextClient::DispatchExtendableMessageEvent( | 895 void ServiceWorkerContextClient::DispatchExtendableMessageEvent( |
915 mojom::ExtendableMessageEventPtr event, | 896 mojom::ExtendableMessageEventPtr event, |
916 const DispatchExtendableMessageEventCallback& callback) { | 897 const DispatchExtendableMessageEventCallback& callback) { |
917 TRACE_EVENT0("ServiceWorker", | 898 TRACE_EVENT0("ServiceWorker", |
918 "ServiceWorkerContextClient::DispatchExtendableMessageEvent"); | 899 "ServiceWorkerContextClient::DispatchExtendableMessageEvent"); |
919 int request_id = context_->message_event_callbacks.Add( | 900 int request_id = context_->message_event_callbacks.Add( |
920 base::MakeUnique<DispatchExtendableMessageEventCallback>(callback)); | 901 base::MakeUnique<DispatchExtendableMessageEventCallback>(callback)); |
921 | 902 |
922 blink::WebMessagePortChannelArray ports = | 903 blink::WebMessagePortChannelArray ports = |
923 WebMessagePortChannelImpl::CreatePorts(event->message_ports, | 904 WebMessagePortChannelImpl::CreateFromMessagePipeHandles( |
924 event->new_routing_ids, | 905 std::move(event->message_ports)); |
925 main_thread_task_runner_); | |
926 if (event->source.client_info.IsValid()) { | 906 if (event->source.client_info.IsValid()) { |
927 blink::WebServiceWorkerClientInfo web_client = | 907 blink::WebServiceWorkerClientInfo web_client = |
928 ToWebServiceWorkerClientInfo(event->source.client_info); | 908 ToWebServiceWorkerClientInfo(event->source.client_info); |
929 proxy_->dispatchExtendableMessageEvent( | 909 proxy_->dispatchExtendableMessageEvent( |
930 request_id, blink::WebString::fromUTF16(event->message), | 910 request_id, blink::WebString::fromUTF16(event->message), |
931 event->source_origin, ports, web_client); | 911 event->source_origin, std::move(ports), web_client); |
932 return; | 912 return; |
933 } | 913 } |
934 | 914 |
935 DCHECK(event->source.service_worker_info.IsValid()); | 915 DCHECK(event->source.service_worker_info.IsValid()); |
936 std::unique_ptr<ServiceWorkerHandleReference> handle = | 916 std::unique_ptr<ServiceWorkerHandleReference> handle = |
937 ServiceWorkerHandleReference::Adopt(event->source.service_worker_info, | 917 ServiceWorkerHandleReference::Adopt(event->source.service_worker_info, |
938 sender_.get()); | 918 sender_.get()); |
939 ServiceWorkerDispatcher* dispatcher = | 919 ServiceWorkerDispatcher* dispatcher = |
940 ServiceWorkerDispatcher::GetOrCreateThreadSpecificInstance( | 920 ServiceWorkerDispatcher::GetOrCreateThreadSpecificInstance( |
941 sender_.get(), main_thread_task_runner_.get()); | 921 sender_.get(), main_thread_task_runner_.get()); |
942 scoped_refptr<WebServiceWorkerImpl> worker = | 922 scoped_refptr<WebServiceWorkerImpl> worker = |
943 dispatcher->GetOrCreateServiceWorker(std::move(handle)); | 923 dispatcher->GetOrCreateServiceWorker(std::move(handle)); |
944 proxy_->dispatchExtendableMessageEvent( | 924 proxy_->dispatchExtendableMessageEvent( |
945 request_id, blink::WebString::fromUTF16(event->message), | 925 request_id, blink::WebString::fromUTF16(event->message), |
946 event->source_origin, ports, WebServiceWorkerImpl::CreateHandle(worker)); | 926 event->source_origin, std::move(ports), |
| 927 WebServiceWorkerImpl::CreateHandle(worker)); |
947 } | 928 } |
948 | 929 |
949 void ServiceWorkerContextClient::OnInstallEvent(int request_id) { | 930 void ServiceWorkerContextClient::OnInstallEvent(int request_id) { |
950 TRACE_EVENT0("ServiceWorker", | 931 TRACE_EVENT0("ServiceWorker", |
951 "ServiceWorkerContextClient::OnInstallEvent"); | 932 "ServiceWorkerContextClient::OnInstallEvent"); |
952 proxy_->dispatchInstallEvent(request_id); | 933 proxy_->dispatchInstallEvent(request_id); |
953 } | 934 } |
954 | 935 |
955 void ServiceWorkerContextClient::DispatchFetchEvent( | 936 void ServiceWorkerContextClient::DispatchFetchEvent( |
956 int fetch_event_id, | 937 int fetch_event_id, |
(...skipping 298 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1255 } | 1236 } |
1256 | 1237 |
1257 base::WeakPtr<ServiceWorkerContextClient> | 1238 base::WeakPtr<ServiceWorkerContextClient> |
1258 ServiceWorkerContextClient::GetWeakPtr() { | 1239 ServiceWorkerContextClient::GetWeakPtr() { |
1259 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); | 1240 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); |
1260 DCHECK(context_); | 1241 DCHECK(context_); |
1261 return context_->weak_factory.GetWeakPtr(); | 1242 return context_->weak_factory.GetWeakPtr(); |
1262 } | 1243 } |
1263 | 1244 |
1264 } // namespace content | 1245 } // namespace content |
OLD | NEW |