diff options
author | bors-servo <lbergstrom+bors@mozilla.com> | 2018-09-19 17:47:27 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-09-19 17:47:27 -0400 |
commit | df2adebefdfa3da49f173e480fa1e56450f9bda2 (patch) | |
tree | 1f05b49bac02318455a59d5b143c186fd872bdb9 /components/script/fetch.rs | |
parent | 2ca7a134736bb4759ff209c1bc0b6dc3cc1984c9 (diff) | |
parent | c37a345dc9f4dda6ea29c42f96f6c7201c42cbac (diff) | |
download | servo-df2adebefdfa3da49f173e480fa1e56450f9bda2.tar.gz servo-df2adebefdfa3da49f173e480fa1e56450f9bda2.zip |
Auto merge of #21737 - chansuke:format_script, r=jdm
Format script component
---
<!-- Thank you for contributing to Servo! Please replace each `[ ]` by `[X]` when the step is complete, and replace `__` with appropriate data: -->
- [x] `./mach build -d` does not report any errors
- [x] `./mach test-tidy` does not report any errors
- [ ] These changes fix part of #21373.
- [x] These changes do not require tests because they format code only.
<!-- Also, please make sure that "Allow edits from maintainers" checkbox is checked, so that we can help you if you get stuck somewhere along the way.-->
<!-- Pull requests that do not address these steps are welcome, but they will require additional verification as part of the review process. -->
<!-- Reviewable:start -->
---
This change is [<img src="https://reviewable.io/review_button.svg" height="34" align="absmiddle" alt="Reviewable"/>](https://reviewable.io/reviews/servo/servo/21737)
<!-- Reviewable:end -->
Diffstat (limited to 'components/script/fetch.rs')
-rw-r--r-- | components/script/fetch.rs | 82 |
1 files changed, 52 insertions, 30 deletions
diff --git a/components/script/fetch.rs b/components/script/fetch.rs index 7f866ca8633..6590b17a4e7 100644 --- a/components/script/fetch.rs +++ b/components/script/fetch.rs @@ -46,7 +46,7 @@ struct FetchContext { #[derive(Default, JSTraceable, MallocSizeOf)] pub struct FetchCanceller { #[ignore_malloc_size_of = "channels are hard"] - cancel_chan: Option<ipc::IpcSender<()>> + cancel_chan: Option<ipc::IpcSender<()>>, } impl FetchCanceller { @@ -108,7 +108,11 @@ fn request_init_from_request(request: NetTraitsRequest) -> NetTraitsRequestInit use_cors_preflight: request.use_cors_preflight, credentials_mode: request.credentials_mode, use_url_credentials: request.use_url_credentials, - origin: GlobalScope::current().expect("No current global object").origin().immutable().clone(), + origin: GlobalScope::current() + .expect("No current global object") + .origin() + .immutable() + .clone(), referrer_url: from_referrer_to_referrer_url(&request), referrer_policy: request.referrer_policy, pipeline_id: request.pipeline_id, @@ -120,7 +124,11 @@ fn request_init_from_request(request: NetTraitsRequest) -> NetTraitsRequestInit // https://fetch.spec.whatwg.org/#fetch-method #[allow(unrooted_must_root)] -pub fn Fetch(global: &GlobalScope, input: RequestInfo, init: RootedTraceableBox<RequestInit>) -> Rc<Promise> { +pub fn Fetch( + global: &GlobalScope, + input: RequestInfo, + init: RootedTraceableBox<RequestInit>, +) -> Rc<Promise> { let core_resource_thread = global.core_resource_thread(); // Step 1 @@ -155,14 +163,20 @@ pub fn Fetch(global: &GlobalScope, input: RequestInfo, init: RootedTraceableBox< let listener = NetworkListener { context: fetch_context, task_source: global.networking_task_source(), - canceller: Some(global.task_canceller(TaskSourceName::Networking)) + canceller: Some(global.task_canceller(TaskSourceName::Networking)), }; - ROUTER.add_route(action_receiver.to_opaque(), Box::new(move |message| { - listener.notify_fetch(message.to().unwrap()); - })); - core_resource_thread.send( - NetTraitsFetch(request_init, FetchChannels::ResponseMsg(action_sender, None))).unwrap(); + ROUTER.add_route( + action_receiver.to_opaque(), + Box::new(move |message| { + listener.notify_fetch(message.to().unwrap()); + }), + ); + core_resource_thread + .send(NetTraitsFetch( + request_init, + FetchChannels::ResponseMsg(action_sender, None), + )).unwrap(); promise } @@ -180,7 +194,11 @@ impl FetchResponseListener for FetchContext { #[allow(unrooted_must_root)] fn process_response(&mut self, fetch_metadata: Result<FetchMetadata, NetworkError>) { - let promise = self.fetch_promise.take().expect("fetch promise is missing").root(); + let promise = self + .fetch_promise + .take() + .expect("fetch promise is missing") + .root(); // JSAutoCompartment needs to be manually made. // Otherwise, Servo will crash. @@ -195,28 +213,32 @@ impl FetchResponseListener for FetchContext { return; }, // Step 4.2 - Ok(metadata) => { - match metadata { - FetchMetadata::Unfiltered(m) => { + Ok(metadata) => match metadata { + FetchMetadata::Unfiltered(m) => { + fill_headers_with_metadata(self.response_object.root(), m); + self.response_object + .root() + .set_type(DOMResponseType::Default); + }, + FetchMetadata::Filtered { filtered, .. } => match filtered { + FilteredMetadata::Basic(m) => { + fill_headers_with_metadata(self.response_object.root(), m); + self.response_object.root().set_type(DOMResponseType::Basic); + }, + FilteredMetadata::Cors(m) => { fill_headers_with_metadata(self.response_object.root(), m); - self.response_object.root().set_type(DOMResponseType::Default); + self.response_object.root().set_type(DOMResponseType::Cors); }, - FetchMetadata::Filtered { filtered, .. } => match filtered { - FilteredMetadata::Basic(m) => { - fill_headers_with_metadata(self.response_object.root(), m); - self.response_object.root().set_type(DOMResponseType::Basic); - }, - FilteredMetadata::Cors(m) => { - fill_headers_with_metadata(self.response_object.root(), m); - self.response_object.root().set_type(DOMResponseType::Cors); - }, - FilteredMetadata::Opaque => - self.response_object.root().set_type(DOMResponseType::Opaque), - FilteredMetadata::OpaqueRedirect => - self.response_object.root().set_type(DOMResponseType::Opaqueredirect) - } - } - } + FilteredMetadata::Opaque => self + .response_object + .root() + .set_type(DOMResponseType::Opaque), + FilteredMetadata::OpaqueRedirect => self + .response_object + .root() + .set_type(DOMResponseType::Opaqueredirect), + }, + }, } // Step 4.3 promise.resolve_native(&self.response_object.root()); |