Struct KvikioProcessConfig 

pub struct KvikioProcessConfig {
    pub compat_mode: KvikioCompatMode,
    pub thread_count: u32,
    pub task_size_bytes: u64,
}

KvikIO’s process-global settings: one thread pool and one task size shared by local compatibility-mode reads and remote range reads, across every device in the process.

Design: website/docs/design/data-path.mdx#local-nvme-and-compatibility-mode.

Fields

compat_mode: KvikioCompatMode

KVIKIO_COMPAT_MODE.

thread_count: u32

KVIKIO_NTHREADS: workers in the process-wide pool.

task_size_bytes: u64

KVIKIO_TASK_SIZE: bytes per pool task; one read splits into tasks of at most this size.

Implementations

impl KvikioProcessConfig

pub const DEFAULT: KvikioProcessConfig

Algeon’s values for the fields the KvikIO environment leaves unset.

64 threads keep a cold local NVMe read near the device’s throughput, where libcudf’s own four-thread setup reached about a quarter of it, and match the concurrency remote range reads need. 4 MiB tasks are KvikIO’s default; a larger task splits one read into fewer parallel pieces.

Trait Implementations

impl Clone for KvikioProcessConfig

fn clone(&self) -> KvikioProcessConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for KvikioProcessConfig

impl Debug for KvikioProcessConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Eq for KvikioProcessConfig

impl Hash for KvikioProcessConfig

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for KvikioProcessConfig

fn eq(&self, other: &KvikioProcessConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for KvikioProcessConfig