use cubecl::prelude::*;
use crate::{ComputeScope, Coverage, CubeAxis, Level, Region, Walk, WalkExpand};
#[derive(CubeType)]
pub struct Portion {
regions: Walk,
first: usize,
start: usize,
end: usize,
stride: usize,
}
#[cube]
impl Portion {
pub fn touched(&self) -> usize {
self.regions.total()
}
pub fn region(&self, i: usize) -> Region {
self.regions.region(i)
}
pub fn steps(&self, i: usize) -> (usize, usize) {
let base = (self.first + i) * self.stride;
let from = select(base < self.start, self.start - base, 0);
let to = select(self.end < base + self.stride, self.end - base, self.stride);
(from, to - from)
}
}
#[cube]
impl Walk {
pub fn portion(self, #[comptime] below: Level) -> Portion {
let instances = comptime!(
self.level
.shared_by()
.expect("Walk::portion: this level distributes no grid as one; say `shared_by`")
);
let stride = self.region(0).over(&below).total();
let steps = self.total() * stride;
let pos = match comptime!(self.level.coverage()) {
Coverage::Distribute(ComputeScope::Cube) => CubeAxis::position(CubeAxis::X),
Coverage::Distribute(ComputeScope::Plane) => {
ComputeScope::position(ComputeScope::Plane)
}
Coverage::Distribute(ComputeScope::Unit) | Coverage::Walk => {
panic!("Walk::portion: only cubes or planes share a grid as one index")
}
};
let start = pos * steps / instances;
let end = (pos + 1) * steps / instances;
let first = start / stride;
let touched = select(start < end, (end - 1) / stride + 1 - first, 0);
Portion {
regions: self.range(first, touched),
first,
start,
end,
stride,
}
}
}