Skip to main content

Module parallel_io

Module parallel_io 

Source
Expand description

Parallel I/O utilities for large-scale distributed physics simulations.

This module provides:

  • Domain decomposition metadata – rank, ghost cells, partition boundaries
  • Chunked file I/O – fixed-size chunks with parallel writer state tracking
  • Parallel VTK output – PVTU / PVD index files for distributed meshes
  • MPI-like rank / domain storage – load-balanced partition export
  • Ghost cell metadata – halo layers for stencil communication
  • Distributed array serialization – flat binary layout for parallel restart
  • Checkpoint / restart – step-indexed checkpoint files
  • Merge of distributed outputs – reassembling per-rank files
  • Parallel HDF5-like layout – dataset headers + contiguous data blocks

Structs§

CheckpointHeader
Header record written at the start of every checkpoint file.
ChunkSpec
Specification for a single data chunk.
ChunkedTrajectory
A trajectory divided into fixed-size chunks of frames.
DatasetHeader
Header for a single named dataset within a parallel file.
DistributedArray
A distributed scalar array owned by one rank.
DomainBox
Axis-aligned bounding box in 3-D used to describe a subdomain.
GhostCellMeta
Full set of ghost-cell metadata for one rank.
GhostLayer
Describes the ghost cell layer on a single face.
IoCounters
Aggregated I/O performance counters.
ParallelFileLayout
A lightweight parallel-HDF5-like file layout description.
ParallelWriter
Tracks parallel write progress across multiple chunk files.
PartitionMap
Partition assignment for load-balanced domain decomposition.
PvtuPiece
Metadata for a single piece in a parallel VTU (PVTU) file.
RankDomain
Per-rank subdomain metadata for a domain-decomposed simulation.

Enums§

DsetType
Data-type descriptor for a dataset column.
Face
Cardinal face directions for a 3-D structured mesh.

Functions§

compress_trajectory_delta
Compress trajectory frames using delta encoding.
decompress_trajectory_delta
Reconstruct trajectory frames from delta-encoded data.
estimate_io_bandwidth
Estimate I/O bandwidth in MB/s.
io_stats
Return a formatted I/O statistics summary string.
merge_chunk_files
Concatenate n_chunks chunk files into a single output file.
merge_rank_files
Merge per-rank checkpoint position files into a single file.
read_checkpoint
Read a checkpoint file written by write_checkpoint.
read_chunked_xyz
Read chunked XYZ files written by write_chunked_xyz.
split_into_chunks
Divide total elements into at most n_chunks contiguous chunks.
write_checkpoint
Write a checkpoint file containing a header and particle positions.
write_chunked_xyz
Write a ChunkedTrajectory to XYZ files, one file per chunk.
write_pvd_xml
Generates the XML content of a .pvd (ParaView Data) time-series file.
write_pvtu_xml
Generates the XML content of a .pvtu (Parallel VTK Unstructured) index file.