Crate hataori 

Hataori: local data parallelism and an optional long-lived distributed runtime.

Structs

Domain

A P0 execution domain.

DomainAdmission

RAII ownership of a domain’s one running-operation slot.

DomainBusy

The domain’s admission slot is already occupied.

DomainId

The P0 execution-domain identifier.

LaneControl

A cancellation capability shared by a coordinator and its lanes.

LaneExecutorError

A lane executor failure during a local fan-out.

MapError

The first callback error returned by map.

NegativeRank

A negative rank was supplied to Place::new.

Place

A rank and its execution-domain identifier.

PlacementError

Error converged across every rank in a placement collective.

PmapError

Error converged across every rank in a collective pmap call.

PmapOptions

Options shared by every rank in one collective pmap call.

RayonLanes

The Lanes implementation over a domain’s Rayon pool.

UnsupportedDomainId

The requested domain identifier is not supported by P0.

Enums

DomainBuildError

A managed or external Rayon domain could not be constructed.

LanesError

Failure from a Lanes run.

LocalMode

Local execution policy for a domain operation.

MapInError

Failure from a local fan-out over Lanes.

PlacementErrorKind

Stable category of a collective placement failure.

PlacementStatus

Whether the domain’s CPU placement was verified.

PmapErrorKind

Stable category of a collective pmap failure.

PoolOwnership

Whether a Rayon pool is owned by Hataori or by its caller.

RayonLanesError

Why a RayonLanes executor could not be created for a domain.

Traits

Lanes

A per-worker execution lanes executor plus a caller-thread coordinator.

Functions

broadcast

Copies one root-owned value to every rank.

gather

Collects one value from every rank in rank order on the root.

map

Applies f to items sequentially and returns results in their original order.

map_in

Maps items through an explicit Rayon domain.

map_in_lanes

Maps items through a Lanes executor with LocalMode::Outer semantics.

pmap

Dynamically maps root-owned items across MPI ranks and each rank’s explicit Rayon domain.

pmap_lanes

Dynamically maps root-owned items across MPI ranks and caller-supplied lanes for each rank’s local batches.

scatter

Distributes one owned shard from the root to each rank.