etha.comm.get_buckets

Group chunks into buckets for coalesced transfer.

Functions

chunk_to_bucket_ops(→ list[etha.comm.ir.Bucket])

Bundle same-route chunks (shared bucket_key) up to bucket_size bytes.

Module Contents

etha.comm.get_buckets.chunk_to_bucket_ops(chunks: list[etha.comm.ir.Chunk], bucket_size: int) → list[etha.comm.ir.Bucket]

Bundle same-route chunks (shared bucket_key) up to bucket_size bytes.

A chunk at least bucket_size becomes its own bucket; bucket_size=1 therefore gives one chunk per bucket (no coalescing).