#[cfg(target_os = "macos")]
use std::sync::Arc;
use j2k_core::BackendRequest;
#[cfg(target_os = "macos")]
use j2k_core::PixelFormat;
use crate::{Error, J2kDecoder, MetalBackendSession, MetalDecodeRequest, Surface};
use super::heuristics::{
is_distinct_full_color_metal_candidate, is_distinct_full_grayscale_metal_candidate,
is_region_scaled_direct_batch_candidate, is_repeated_full_color_candidate,
is_repeated_full_grayscale_candidate,
};
#[cfg(target_os = "macos")]
use super::request::batch_scheduler_invariant;
use super::request::{BatchOp, QueuedRequest};
pub(super) fn decode_repeated_full_grayscale(
request: &QueuedRequest,
count: usize,
backend: Option<&MetalBackendSession>,
) -> Option<Result<Vec<Surface>, Error>> {
if !is_repeated_full_grayscale_candidate(request) || count <= 1 {
return None;
}
#[cfg(target_os = "macos")]
{
let result =
J2kDecoder::new(request.input.as_ref()).and_then(|mut decoder| match request.backend {
BackendRequest::Auto => {
decoder.decode_repeated_grayscale_auto_to_device(request.fmt, count)
}
BackendRequest::Metal => decoder.decode_repeated_grayscale_direct_to_device_routed(
request.fmt,
count,
backend,
),
_ => Err(batch_scheduler_invariant(
"repeated grayscale batch contains an unsupported backend",
)),
});
Some(result)
}
#[cfg(not(target_os = "macos"))]
{
let _ = backend;
None
}
}
pub(super) fn decode_repeated_full_color(
request: &QueuedRequest,
count: usize,
backend: Option<&MetalBackendSession>,
) -> Option<Result<Vec<Surface>, Error>> {
if !is_repeated_full_color_candidate(request) || count <= 1 {
return None;
}
#[cfg(target_os = "macos")]
{
Some(J2kDecoder::new(request.input.as_ref()).and_then(
|mut decoder| match request.backend {
BackendRequest::Auto => {
decoder.decode_repeated_color_auto_to_device_routed(request.fmt, count, backend)
}
BackendRequest::Metal => decoder.decode_repeated_color_direct_to_device_routed(
request.fmt,
count,
backend,
),
_ => Err(batch_scheduler_invariant(
"repeated color batch contains an unsupported backend",
)),
},
))
}
#[cfg(not(target_os = "macos"))]
{
let _ = backend;
None
}
}
pub(super) fn decode_distinct_full_grayscale_batch(
requests: &[QueuedRequest],
backend: Option<&MetalBackendSession>,
) -> Option<Result<Vec<Surface>, Error>> {
let first = requests.first()?;
if requests.len() <= 1
|| !requests.iter().all(|request| {
is_distinct_full_grayscale_metal_candidate(request) && request.fmt == first.fmt
})
{
return None;
}
#[cfg(target_os = "macos")]
{
let inputs = match collect_inputs(requests, "J2K Metal distinct grayscale input handles") {
Ok(inputs) => inputs,
Err(error) => return Some(Err(error)),
};
Some(
crate::decoder::decode_full_grayscale_batch_direct_to_device_routed(
&inputs, first.fmt, backend,
),
)
}
#[cfg(not(target_os = "macos"))]
{
let _ = backend;
None
}
}
pub(super) fn decode_distinct_full_color_batch(
requests: &[QueuedRequest],
backend: Option<&MetalBackendSession>,
) -> Option<Result<Vec<Surface>, Error>> {
let first = requests.first()?;
if requests.len() <= 1
|| !requests.iter().all(|request| {
is_distinct_full_color_metal_candidate(request) && request.fmt == first.fmt
})
{
return None;
}
#[cfg(target_os = "macos")]
{
let inputs = match collect_inputs(requests, "J2K Metal distinct color input handles") {
Ok(inputs) => inputs,
Err(error) => return Some(Err(error)),
};
Some(
crate::decoder::decode_full_color_batch_direct_to_device_routed(
&inputs, first.fmt, backend,
),
)
}
#[cfg(not(target_os = "macos"))]
{
let _ = backend;
None
}
}
#[cfg(target_os = "macos")]
fn collect_inputs(requests: &[QueuedRequest], what: &'static str) -> Result<Vec<Arc<[u8]>>, Error> {
let mut budget = crate::batch_allocation::BatchMetadataBudget::new(what);
let mut inputs = budget.try_vec(requests.len(), what)?;
inputs.extend(requests.iter().map(|request| request.input.clone()));
Ok(inputs)
}
pub(super) fn decode_distinct_region_scaled_direct_batch(
requests: &[QueuedRequest],
backend: Option<&MetalBackendSession>,
) -> Option<Result<Vec<Surface>, Error>> {
let first = requests.first()?;
if requests.len() <= 1
|| !requests.iter().all(|request| {
is_region_scaled_direct_batch_candidate(request)
&& request.fmt == first.fmt
&& request.backend == first.backend
})
{
return None;
}
if first.backend == BackendRequest::Auto {
return None;
}
#[cfg(target_os = "macos")]
{
let mut budget = crate::batch_allocation::BatchMetadataBudget::new(
"J2K Metal direct batch request specifications",
);
let mut request_specs = match budget.try_vec(
requests.len(),
"J2K Metal direct batch request specifications",
) {
Ok(specs) => specs,
Err(error) => return Some(Err(error.into())),
};
for request in requests {
let BatchOp::RegionScaled { roi, scale } = request.op else {
return Some(Err(batch_scheduler_invariant(
"direct region-scaled batch contains a non-region-scaled request",
)));
};
request_specs.push((request.input.clone(), roi, scale));
}
let result = match first.fmt {
PixelFormat::Gray8 | PixelFormat::Gray16 => {
crate::hybrid::decode_region_scaled_grayscale_batch_direct_to_device_routed(
&request_specs,
first.fmt,
backend,
)
}
PixelFormat::Rgb8 | PixelFormat::Rgba8 | PixelFormat::Rgb16 => {
crate::hybrid::decode_region_scaled_color_batch_direct_to_device_routed(
&request_specs,
first.fmt,
backend,
)
}
_ => Err(batch_scheduler_invariant(
"direct region-scaled batch contains an unsupported pixel format",
)),
};
Some(result)
}
#[cfg(not(target_os = "macos"))]
{
let _ = backend;
None
}
}
pub(super) fn decode_individual(
request: &QueuedRequest,
backend: Option<&MetalBackendSession>,
) -> Result<Surface, Error> {
let mut decoder = J2kDecoder::new(request.input.as_ref())?;
if let Some(backend) = backend {
return decoder.decode_request_to_device_with_session(
MetalDecodeRequest {
fmt: request.fmt,
op: request.op.into(),
backend: request.backend,
},
backend,
);
}
decoder.decode_op_to_surface_impl(MetalDecodeRequest {
fmt: request.fmt,
op: request.op.into(),
backend: request.backend,
})
}
impl From<BatchOp> for crate::MetalDecodeOp {
fn from(value: BatchOp) -> Self {
match value {
BatchOp::Full => Self::Full,
BatchOp::Region(roi) => Self::Region(roi),
BatchOp::Scaled(scale) => Self::Scaled(scale),
BatchOp::RegionScaled { roi, scale } => Self::RegionScaled { roi, scale },
}
}
}