j2k 0.7.2

Safe public JPEG 2000 and HTJ2K CPU codec APIs with optional CUDA and Metal adapters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

// SPDX-License-Identifier: MIT OR Apache-2.0

use super::*;

#[test]
fn empty_batch_plan_is_a_typed_infrastructure_error() {
    assert_eq!(
        select_batch_plan(0, 1),
        Err(BatchInfrastructureError::EmptyBatchPlan)
    );
}

#[test]
fn exact_aggregate_cap_is_accepted_and_one_over_is_rejected() {
    let (metadata, _) = batch_metadata_bytes(1, 1).expect("small metadata");
    let exact_cap = GENERIC_WORKER_CLAIM_BYTES + metadata;
    let plan = select_batch_plan_with_limits(1, 1, GENERIC_WORKER_CLAIM_BYTES, metadata, exact_cap)
        .expect("exact aggregate boundary");
    assert_eq!(plan.live_bytes, exact_cap);

    let error =
        select_batch_plan_with_limits(1, 1, GENERIC_WORKER_CLAIM_BYTES, metadata, exact_cap - 1)
            .expect_err("one byte above aggregate cap");
    assert!(matches!(
        error,
        BatchInfrastructureError::AllocationTooLarge {
            requested,
            cap,
            ..
        } if requested == exact_cap && cap == exact_cap - 1
    ));
}

#[test]
fn requested_worker_count_reduces_to_fit_aggregate_claims() {
    let (two_worker_metadata, _) = batch_metadata_bytes(4, 2).expect("small metadata");
    let two_worker_cap = GENERIC_WORKER_CLAIM_BYTES
        .checked_mul(2)
        .and_then(|bytes| bytes.checked_add(two_worker_metadata))
        .expect("test cap");
    let plan = select_batch_plan_with_limits(
        4,
        4,
        GENERIC_WORKER_CLAIM_BYTES,
        J2K_BATCH_METADATA_ALLOWANCE_BYTES,
        two_worker_cap,
    )
    .expect("two workers fit");
    assert_eq!(plan.worker_count, 2);
    assert_eq!(plan.chunk_size, 2);
}

#[test]
fn one_worker_rejects_when_claim_and_metadata_cannot_fit() {
    let (metadata, _) = batch_metadata_bytes(1, 1).expect("small metadata");
    let cap = GENERIC_WORKER_CLAIM_BYTES + metadata - 1;
    assert!(matches!(
        select_batch_plan_with_limits(1, 1, GENERIC_WORKER_CLAIM_BYTES, metadata, cap,),
        Err(BatchInfrastructureError::AllocationTooLarge { .. })
    ));
}

#[test]
fn metadata_one_over_is_public_infrastructure_error() {
    let (metadata, _) = batch_metadata_bytes(1, 1).expect("small metadata");
    let metadata_cap = metadata - 1;
    let infrastructure =
        select_batch_plan_with_limits(1, 1, GENERIC_WORKER_CLAIM_BYTES, metadata_cap, usize::MAX)
            .expect_err("metadata is one byte over policy");
    let public_error: super::super::TileBatchError = infrastructure.into();
    assert!(matches!(
        public_error,
        super::super::TileBatchError::Infrastructure(
            BatchInfrastructureError::AllocationTooLarge {
                what: "J2K batch metadata",
                requested,
                cap,
            }
        ) if requested == metadata && cap == metadata_cap
    ));
}

#[test]
fn aggregate_overflow_is_a_typed_cap_failure() {
    assert!(matches!(
        select_batch_plan_with_limits(1, 1, usize::MAX, usize::MAX, usize::MAX),
        Err(BatchInfrastructureError::AllocationTooLarge {
            requested: usize::MAX,
            ..
        })
    ));
}

#[test]
fn planning_claims_do_not_allocate_worker_workspace() {
    let plan = select_batch_plan(8, usize::MAX).expect("bounded arithmetic plan");
    assert_eq!(plan.worker_count, MAX_GENERIC_BATCH_WORKERS);
    assert!(plan.live_bytes <= J2K_BATCH_HOST_CAP_BYTES);
}

#[test]
fn dynamically_admitted_direct_batch_is_not_clamped_to_generic_workers() {
    let plan = select_direct_batch_plan(16, 12).expect("bounded direct metadata plan");

    // The scheduler's chunking contract turns 12 desired workers over 16 jobs
    // into eight two-job workers. Aggregate direct allocations are admitted at
    // runtime, so the fixed four-generic-worker ceiling must not truncate this
    // metadata-only plan.
    assert_eq!(plan.worker_count, 8);
    assert_eq!(plan.chunk_size, 2);
    assert!(plan.metadata_bytes <= J2K_BATCH_METADATA_ALLOWANCE_BYTES);
}

#[test]
fn dynamically_admitted_workers_remain_structurally_bounded() {
    let plan = select_direct_batch_plan(64, 64).expect("bounded direct metadata plan");

    assert_eq!(plan.worker_count, MAX_ADMITTED_BATCH_WORKERS);
    assert_eq!(plan.chunk_size, 8);
}