diff options
author | deror1869107 <sungyuanyao@gmail.com> | 2016-12-14 23:29:18 +0800 |
---|---|---|
committer | deror1869107 <sungyuanyao@gmail.com> | 2016-12-15 01:16:52 +0800 |
commit | 55dddc8c41f74d628ddf409f4c0e782ec7ddc543 (patch) | |
tree | 64f6bc0b219db900b6e941c624c5b5c903174b6c /components/net/image_cache_thread.rs | |
parent | cd1d5f1cf359051eb76aa81ec3de48b84b0dab81 (diff) | |
download | servo-55dddc8c41f74d628ddf409f4c0e782ec7ddc543.tar.gz servo-55dddc8c41f74d628ddf409f4c0e782ec7ddc543.zip |
Remove-ResponseAction
Remove redundant code
Diffstat (limited to 'components/net/image_cache_thread.rs')
-rw-r--r-- | components/net/image_cache_thread.rs | 38 |
1 files changed, 9 insertions, 29 deletions
diff --git a/components/net/image_cache_thread.rs b/components/net/image_cache_thread.rs index 5976ec50885..a165c397449 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<Metadata, NetworkError>), - DataAvailable(Vec<u8>), - 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<u8>) { 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, |