Skip to content

Commit

Permalink
Add useful debug information to image cache.
Browse files Browse the repository at this point in the history
  • Loading branch information
jdm committed Feb 22, 2017
1 parent 646d48a commit b174a68
Showing 1 changed file with 25 additions and 10 deletions.
35 changes: 25 additions & 10 deletions components/net/image_cache_thread.rs
Expand Up @@ -414,6 +414,7 @@ impl ImageCache {
(FetchResponseMsg::ProcessRequestEOF, _) => return,
(FetchResponseMsg::ProcessResponse(_response), _) => {}
(FetchResponseMsg::ProcessResponseChunk(data), _) => {
debug!("got some data for {:?}", msg.key);
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?
Expand All @@ -430,19 +431,22 @@ impl ImageCache {
}
}
(FetchResponseMsg::ProcessResponseEOF(result), key) => {
debug!("received EOF for {:?}", key);
match result {
Ok(()) => {
let pending_load = self.pending_loads.get_by_key_mut(&msg.key).unwrap();
pending_load.result = Some(result);
let bytes = pending_load.bytes.mark_complete();
let sender = self.decoder_sender.clone();
debug!("async decoding {} ({:?})", pending_load.url, key);

self.thread_pool.execute(move || {
let msg = decode_bytes_sync(key, &*bytes);
sender.send(msg).unwrap();
});
}
Err(_) => {
debug!("processing error for {:?}", key);
match self.placeholder_image.clone() {
Some(placeholder_image) => {
self.complete_load(msg.key, LoadResult::PlaceholderLoaded(
Expand Down Expand Up @@ -553,24 +557,35 @@ impl ImageCache {
can_request: CanRequestImages)
-> Result<ImageOrMetadataAvailable, ImageState> {
if let Some(result) = self.get_completed_image_if_available(&url, placeholder) {
debug!("{} is available", url);
return result;
}

let decoded = {
let result = self.pending_loads.get_cached(url.clone(), can_request);
match result {
CacheResult::Hit(key, pl) => match (&pl.result, &pl.metadata) {
(&Some(Ok(_)), _) =>
decode_bytes_sync(key, &pl.bytes.as_slice()),
(&None, &Some(ref meta)) =>
return Ok(ImageOrMetadataAvailable::MetadataAvailable(meta.clone())),
(&Some(Err(_)), _) | (&None, &None) =>
return Err(ImageState::Pending(key)),
(&Some(Ok(_)), _) => {
debug!("sync decoding {} ({:?})", url, key);
decode_bytes_sync(key, &pl.bytes.as_slice())
}
(&None, &Some(ref meta)) => {
debug!("metadata available for {} ({:?})", url, key);
return Ok(ImageOrMetadataAvailable::MetadataAvailable(meta.clone()))
}
(&Some(Err(_)), _) | (&None, &None) => {
debug!("{} ({:?}) is still pending", url, key);
return Err(ImageState::Pending(key));
}
},
CacheResult::Miss(Some((key, _pl))) =>
return Err(ImageState::NotRequested(key)),
CacheResult::Miss(None) =>
return Err(ImageState::LoadError),
CacheResult::Miss(Some((key, _pl))) => {
debug!("should be requesting {} ({:?})", url, key);
return Err(ImageState::NotRequested(key));
}
CacheResult::Miss(None) => {
debug!("couldn't find an entry for {}", url);
return Err(ImageState::LoadError);
}
}
};

Expand Down

0 comments on commit b174a68

Please sign in to comment.