From 55dddc8c41f74d628ddf409f4c0e782ec7ddc543 Mon Sep 17 00:00:00 2001 From: deror1869107 Date: Wed, 14 Dec 2016 23:29:18 +0800 Subject: [PATCH] Remove-ResponseAction Remove redundant code --- components/net/image_cache_thread.rs | 38 +++++++--------------------- 1 file changed, 9 insertions(+), 29 deletions(-) diff --git a/components/net/image_cache_thread.rs b/components/net/image_cache_thread.rs index 5976ec508854..a165c3974497 100644 --- a/components/net/image_cache_thread.rs +++ b/components/net/image_cache_thread.rs @@ -225,17 +225,8 @@ impl ImageListener { } } -/// A legacy type that's mostly redundant with FetchResponseMsg. -// FIXME(#13717): remove this type. -#[derive(Deserialize, Serialize)] -enum ResponseAction { - HeadersAvailable(Result), - DataAvailable(Vec), - ResponseComplete(Result<(), NetworkError>) -} - struct ResourceLoadInfo { - action: ResponseAction, + action: FetchResponseMsg, key: LoadKey, } @@ -417,8 +408,10 @@ impl ImageCache { // Handle progress messages from the resource thread fn handle_progress(&mut self, msg: ResourceLoadInfo) { match (msg.action, msg.key) { - (ResponseAction::HeadersAvailable(_), _) => {} - (ResponseAction::DataAvailable(data), _) => { + (FetchResponseMsg::ProcessRequestBody, _) | + (FetchResponseMsg::ProcessRequestEOF, _) => return, + (FetchResponseMsg::ProcessResponse(_), _) => {} + (FetchResponseMsg::ProcessResponseChunk(data), _) => { let pending_load = self.pending_loads.get_by_key_mut(&msg.key).unwrap(); pending_load.bytes.extend_from_slice(&data); //jmr0 TODO: possibly move to another task? @@ -434,7 +427,7 @@ impl ImageCache { } } } - (ResponseAction::ResponseComplete(result), key) => { + (FetchResponseMsg::ProcessResponseEOF(result), key) => { match result { Ok(()) => { let pending_load = self.pending_loads.get_by_key_mut(&msg.key).unwrap(); @@ -550,20 +543,7 @@ impl ImageCache { let action = match action { FetchResponseMsg::ProcessRequestBody | FetchResponseMsg::ProcessRequestEOF => return, - FetchResponseMsg::ProcessResponse(meta_result) => { - ResponseAction::HeadersAvailable(meta_result.map(|m| { - match m { - FetchMetadata::Unfiltered(m) => m, - FetchMetadata::Filtered { unsafe_, .. } => unsafe_ - } - })) - } - FetchResponseMsg::ProcessResponseChunk(new_bytes) => { - ResponseAction::DataAvailable(new_bytes) - } - FetchResponseMsg::ProcessResponseEOF(response) => { - ResponseAction::ResponseComplete(response) - } + a => a }; progress_sender.send(ResourceLoadInfo { action: action, @@ -630,12 +610,12 @@ impl ImageCache { loaded_bytes: Vec) { let (cache_result, load_key, _) = self.pending_loads.get_cached(ref_url.clone()); assert!(cache_result == CacheResult::Miss); - let action = ResponseAction::DataAvailable(loaded_bytes); + let action = FetchResponseMsg::ProcessResponseChunk(loaded_bytes); let _ = self.progress_sender.send(ResourceLoadInfo { action: action, key: load_key, }); - let action = ResponseAction::ResponseComplete(Ok(())); + let action = FetchResponseMsg::ProcessResponseEOF(Ok(())); let _ = self.progress_sender.send(ResourceLoadInfo { action: action, key: load_key,