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.

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.

UnsupportedDomainId

The requested domain identifier is not supported by P0.

Enums

DomainBuildError

A managed or external Rayon domain could not be constructed.

LocalMode

Local execution policy for a domain operation.

MapInError

Failure from map_in.

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.

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.

pmap

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

scatter

Distributes one owned shard from the root to each rank.