/rust/registry/src/index.crates.io-1949cf8c6b5b557f/av1-grain-0.2.5/src/diff.rs
Line | Count | Source |
1 | | use anyhow::{ensure, Result}; |
2 | | use num_rational::Rational64; |
3 | | use v_frame::{frame::Frame, pixel::Pixel}; |
4 | | |
5 | | use self::solver::{FlatBlockFinder, NoiseModel}; |
6 | | use crate::{util::frame_into_u8, GrainTableSegment}; |
7 | | |
8 | | mod solver; |
9 | | |
10 | | const BLOCK_SIZE: usize = 32; |
11 | | const BLOCK_SIZE_SQUARED: usize = BLOCK_SIZE * BLOCK_SIZE; |
12 | | |
13 | | pub struct DiffGenerator { |
14 | | fps: Rational64, |
15 | | source_bit_depth: usize, |
16 | | denoised_bit_depth: usize, |
17 | | frame_count: usize, |
18 | | prev_timestamp: u64, |
19 | | flat_block_finder: FlatBlockFinder, |
20 | | noise_model: NoiseModel, |
21 | | grain_table: Vec<GrainTableSegment>, |
22 | | } |
23 | | |
24 | | impl DiffGenerator { |
25 | | #[must_use] |
26 | | #[inline] |
27 | 0 | pub fn new(fps: Rational64, source_bit_depth: usize, denoised_bit_depth: usize) -> Self { |
28 | 0 | Self { |
29 | 0 | frame_count: 0, |
30 | 0 | fps, |
31 | 0 | flat_block_finder: FlatBlockFinder::new(), |
32 | 0 | noise_model: NoiseModel::new(), |
33 | 0 | grain_table: Vec::new(), |
34 | 0 | prev_timestamp: 0, |
35 | 0 | source_bit_depth, |
36 | 0 | denoised_bit_depth, |
37 | 0 | } |
38 | 0 | } |
39 | | |
40 | | /// Processes the next frame and adds the results to the state of this |
41 | | /// `DiffGenerator`. |
42 | | /// |
43 | | /// # Errors |
44 | | /// - If the frames do not have the same resolution |
45 | | /// - If the frames do not have the same chroma subsampling |
46 | | #[inline] |
47 | 0 | pub fn diff_frame<T: Pixel, U: Pixel>( |
48 | 0 | &mut self, |
49 | 0 | source: &Frame<T>, |
50 | 0 | denoised: &Frame<U>, |
51 | 0 | ) -> Result<()> { |
52 | 0 | self.diff_frame_internal( |
53 | 0 | &frame_into_u8(source, self.source_bit_depth), |
54 | 0 | &frame_into_u8(denoised, self.denoised_bit_depth), |
55 | | ) |
56 | 0 | } |
57 | | |
58 | | /// Finalize the state of this `DiffGenerator` and return the resulting |
59 | | /// grain table segments. |
60 | | #[must_use] |
61 | | #[inline] |
62 | 0 | pub fn finish(mut self) -> Vec<GrainTableSegment> { |
63 | 0 | log::debug!("Updating final parameters"); |
64 | 0 | self.grain_table.push( |
65 | 0 | self.noise_model |
66 | 0 | .get_grain_parameters(self.prev_timestamp, i64::MAX as u64), |
67 | | ); |
68 | | |
69 | 0 | self.grain_table |
70 | 0 | } |
71 | | |
72 | 0 | fn diff_frame_internal(&mut self, source: &Frame<u8>, denoised: &Frame<u8>) -> Result<()> { |
73 | 0 | verify_dimensions_match(source, denoised)?; |
74 | | |
75 | 0 | let (flat_blocks, num_flat_blocks) = self.flat_block_finder.run(&source.planes[0]); |
76 | 0 | log::debug!("Num flat blocks: {num_flat_blocks}"); |
77 | | |
78 | 0 | log::debug!("Updating noise model"); |
79 | 0 | let status = self.noise_model.update(source, denoised, &flat_blocks); |
80 | | |
81 | 0 | if status == NoiseStatus::DifferentType { |
82 | 0 | let cur_timestamp = self.frame_count as u64 * 10_000_000u64 * *self.fps.denom() as u64 |
83 | 0 | / *self.fps.numer() as u64; |
84 | 0 | log::debug!( |
85 | 0 | "Updating parameters for times {} to {}", |
86 | | self.prev_timestamp, |
87 | | cur_timestamp |
88 | | ); |
89 | 0 | self.grain_table.push( |
90 | 0 | self.noise_model |
91 | 0 | .get_grain_parameters(self.prev_timestamp, cur_timestamp), |
92 | | ); |
93 | 0 | self.noise_model.save_latest(); |
94 | 0 | self.prev_timestamp = cur_timestamp; |
95 | 0 | } |
96 | 0 | log::debug!("Noise model updated for frame {}", self.frame_count); |
97 | 0 | self.frame_count += 1; |
98 | | |
99 | 0 | Ok(()) |
100 | 0 | } |
101 | | } |
102 | | |
103 | | #[derive(Debug)] |
104 | | enum NoiseStatus { |
105 | | Ok, |
106 | | DifferentType, |
107 | | #[allow(dead_code)] |
108 | | Error(anyhow::Error), |
109 | | } |
110 | | |
111 | | impl PartialEq for NoiseStatus { |
112 | 0 | fn eq(&self, other: &Self) -> bool { |
113 | 0 | match (self, other) { |
114 | 0 | (&Self::Error(_), &Self::Error(_)) => true, |
115 | 0 | _ => core::mem::discriminant(self) == core::mem::discriminant(other), |
116 | | } |
117 | 0 | } |
118 | | } |
119 | | |
120 | 0 | fn verify_dimensions_match(source: &Frame<u8>, denoised: &Frame<u8>) -> Result<()> { |
121 | 0 | let res_1 = (source.planes[0].cfg.width, source.planes[0].cfg.height); |
122 | 0 | let res_2 = (denoised.planes[0].cfg.width, denoised.planes[0].cfg.height); |
123 | 0 | ensure!( |
124 | 0 | res_1 == res_2, |
125 | 0 | "Luma resolutions were not equal, {}x{} != {}x{}", |
126 | | res_1.0, |
127 | | res_1.1, |
128 | | res_2.0, |
129 | | res_2.1 |
130 | | ); |
131 | | |
132 | 0 | let res_1 = (source.planes[1].cfg.width, source.planes[1].cfg.height); |
133 | 0 | let res_2 = (denoised.planes[1].cfg.width, denoised.planes[1].cfg.height); |
134 | 0 | ensure!( |
135 | 0 | res_1 == res_2, |
136 | 0 | "Chroma resolutions were not equal, {}x{} != {}x{}", |
137 | | res_1.0, |
138 | | res_1.1, |
139 | | res_2.0, |
140 | | res_2.1 |
141 | | ); |
142 | | |
143 | 0 | Ok(()) |
144 | 0 | } |