1use std::collections::HashMap;
6use std::sync::Arc;
7
8use base::id::PainterId;
9use embedder_traits::UntrustedNodeAddress;
10use euclid::Size2D;
11use fonts::FontContext;
12use layout_api::wrapper_traits::ThreadSafeLayoutNode;
13use layout_api::{
14 AnimatingImages, IFrameSizes, LayoutImageDestination, PendingImage, PendingImageState,
15 PendingRasterizationImage,
16};
17use net_traits::image_cache::{
18 Image as CachedImage, ImageCache, ImageCacheResult, ImageOrMetadataAvailable, PendingImageId,
19};
20use parking_lot::{Mutex, RwLock};
21use pixels::RasterImage;
22use script::layout_dom::ServoThreadSafeLayoutNode;
23use servo_url::{ImmutableOrigin, ServoUrl};
24use style::context::SharedStyleContext;
25use style::dom::OpaqueNode;
26use style::values::computed::image::{Gradient, Image};
27use webrender_api::units::{DeviceIntSize, DeviceSize};
28
29pub(crate) type CachedImageOrError = Result<CachedImage, ResolveImageError>;
30
31pub(crate) struct LayoutContext<'a> {
32 pub use_rayon: bool,
33
34 pub style_context: SharedStyleContext<'a>,
36
37 pub font_context: Arc<FontContext>,
39
40 pub iframe_sizes: Mutex<IFrameSizes>,
42
43 pub image_resolver: Arc<ImageResolver>,
46
47 pub painter_id: PainterId,
49}
50
51pub enum ResolvedImage<'a> {
52 Gradient(&'a Gradient),
53 Image {
56 image: CachedImage,
57 size: DeviceSize,
58 },
59}
60
61#[derive(Clone, Copy, Debug)]
62pub enum ResolveImageError {
63 LoadError,
64 ImagePending,
65 OnlyMetadata,
66 InvalidUrl,
67 MissingNode,
68 ImageMissingFromImageSet,
69 NotImplementedYet,
70 None,
71}
72
73pub(crate) enum LayoutImageCacheResult {
74 Pending,
75 DataAvailable(ImageOrMetadataAvailable),
76 LoadError,
77}
78
79pub(crate) struct ImageResolver {
80 pub origin: ImmutableOrigin,
82
83 pub image_cache: Arc<dyn ImageCache>,
85
86 pub pending_images: Mutex<Vec<PendingImage>>,
88
89 pub pending_rasterization_images: Mutex<Vec<PendingRasterizationImage>>,
92
93 pub pending_svg_elements_for_serialization: Mutex<Vec<UntrustedNodeAddress>>,
99
100 pub animating_images: Arc<RwLock<AnimatingImages>>,
104
105 pub resolved_images_cache: Arc<RwLock<HashMap<ServoUrl, CachedImageOrError>>>,
108
109 pub animation_timeline_value: f64,
111}
112
113impl Drop for ImageResolver {
114 fn drop(&mut self) {
115 if !std::thread::panicking() {
116 assert!(self.pending_images.lock().is_empty());
117 assert!(self.pending_rasterization_images.lock().is_empty());
118 assert!(
119 self.pending_svg_elements_for_serialization
120 .lock()
121 .is_empty()
122 );
123 }
124 }
125}
126
127impl ImageResolver {
128 pub(crate) fn get_or_request_image_or_meta(
129 &self,
130 node: OpaqueNode,
131 url: ServoUrl,
132 destination: LayoutImageDestination,
133 ) -> LayoutImageCacheResult {
134 let cache_result =
136 self.image_cache
137 .get_cached_image_status(url.clone(), self.origin.clone(), None);
138
139 match cache_result {
140 ImageCacheResult::Available(img_or_meta) => {
141 LayoutImageCacheResult::DataAvailable(img_or_meta)
142 },
143 ImageCacheResult::Pending(id) => {
146 let image = PendingImage {
147 state: PendingImageState::PendingResponse,
148 node: node.into(),
149 id,
150 origin: self.origin.clone(),
151 destination,
152 };
153 self.pending_images.lock().push(image);
154 LayoutImageCacheResult::Pending
155 },
156 ImageCacheResult::ReadyForRequest(id) => {
158 let image = PendingImage {
159 state: PendingImageState::Unrequested(url),
160 node: node.into(),
161 id,
162 origin: self.origin.clone(),
163 destination,
164 };
165 self.pending_images.lock().push(image);
166 LayoutImageCacheResult::Pending
167 },
168 ImageCacheResult::FailedToLoadOrDecode => LayoutImageCacheResult::LoadError,
170 }
171 }
172
173 pub(crate) fn handle_animated_image(&self, node: OpaqueNode, image: Arc<RasterImage>) {
174 let mut animating_images = self.animating_images.write();
175 if !image.should_animate() {
176 animating_images.remove(node);
177 } else {
178 animating_images.maybe_insert_or_update(node, image, self.animation_timeline_value);
179 }
180 }
181
182 pub(crate) fn get_cached_image_for_url(
183 &self,
184 node: OpaqueNode,
185 url: ServoUrl,
186 destination: LayoutImageDestination,
187 ) -> Result<CachedImage, ResolveImageError> {
188 if let Some(cached_image) = self.resolved_images_cache.read().get(&url) {
189 return cached_image.clone();
190 }
191
192 let result = self.get_or_request_image_or_meta(node, url.clone(), destination);
193 match result {
194 LayoutImageCacheResult::DataAvailable(img_or_meta) => match img_or_meta {
195 ImageOrMetadataAvailable::ImageAvailable { image, .. } => {
196 if let Some(image) = image.as_raster_image() {
197 self.handle_animated_image(node, image.clone());
198 }
199
200 let mut resolved_images_cache = self.resolved_images_cache.write();
201 resolved_images_cache.insert(url, Ok(image.clone()));
202 Ok(image)
203 },
204 ImageOrMetadataAvailable::MetadataAvailable(..) => {
205 Result::Err(ResolveImageError::OnlyMetadata)
206 },
207 },
208 LayoutImageCacheResult::Pending => Result::Err(ResolveImageError::ImagePending),
209 LayoutImageCacheResult::LoadError => {
210 let error = Err(ResolveImageError::LoadError);
211 self.resolved_images_cache
212 .write()
213 .insert(url, error.clone());
214 error
215 },
216 }
217 }
218
219 pub(crate) fn rasterize_vector_image(
220 &self,
221 image_id: PendingImageId,
222 size: DeviceIntSize,
223 node: OpaqueNode,
224 svg_id: Option<String>,
225 ) -> Option<RasterImage> {
226 let result = self
227 .image_cache
228 .rasterize_vector_image(image_id, size, svg_id);
229 if result.is_none() {
230 self.pending_rasterization_images
231 .lock()
232 .push(PendingRasterizationImage {
233 id: image_id,
234 node: node.into(),
235 size,
236 });
237 }
238 result
239 }
240
241 pub(crate) fn queue_svg_element_for_serialization(
242 &self,
243 element: ServoThreadSafeLayoutNode<'_>,
244 ) {
245 self.pending_svg_elements_for_serialization
246 .lock()
247 .push(element.opaque().into())
248 }
249
250 pub(crate) fn resolve_image<'a>(
251 &self,
252 node: Option<OpaqueNode>,
253 image: &'a Image,
254 ) -> Result<ResolvedImage<'a>, ResolveImageError> {
255 match image {
256 Image::None => Result::Err(ResolveImageError::None),
258 Image::CrossFade(_) => Result::Err(ResolveImageError::NotImplementedYet),
259 Image::PaintWorklet(_) => Result::Err(ResolveImageError::NotImplementedYet),
260 Image::Gradient(gradient) => Ok(ResolvedImage::Gradient(gradient)),
261 Image::Url(image_url) => {
262 let image_url = image_url.url().ok_or(ResolveImageError::InvalidUrl)?;
269 let node = node.ok_or(ResolveImageError::MissingNode)?;
270 let image = self.get_cached_image_for_url(
271 node,
272 image_url.clone().into(),
273 LayoutImageDestination::DisplayListBuilding,
274 )?;
275 let metadata = image.metadata();
276 let size = Size2D::new(metadata.width, metadata.height).to_f32();
277 Ok(ResolvedImage::Image { image, size })
278 },
279 Image::ImageSet(image_set) => {
280 image_set
281 .items
282 .get(image_set.selected_index)
283 .ok_or(ResolveImageError::ImageMissingFromImageSet)
284 .and_then(|image| {
285 self.resolve_image(node, &image.image)
286 .map(|info| match info {
287 ResolvedImage::Image {
288 image: cached_image,
289 ..
290 } => {
291 let image_metadata = cached_image.metadata();
298 let size = if cached_image.as_raster_image().is_some() {
299 let scale_factor = image.resolution.dppx();
300 Size2D::new(
301 image_metadata.width as f32 / scale_factor,
302 image_metadata.height as f32 / scale_factor,
303 )
304 } else {
305 Size2D::new(image_metadata.width, image_metadata.height)
306 .to_f32()
307 };
308
309 ResolvedImage::Image {
310 image: cached_image,
311 size,
312 }
313 },
314 _ => info,
315 })
316 })
317 },
318 Image::LightDark(..) => unreachable!("light-dark() should be disabled"),
319 }
320 }
321}