Distributed communication primitives

veros.distributed.ascontiguousarray(arr)[source]
veros.distributed.get_array_buffer(vs, arr)[source]
veros.distributed.validate_decomposition(vs)[source]
veros.distributed.get_chunk_size(vs)[source]
veros.distributed.get_global_size(vs, arr_shp, dim_grid, include_overlap=False)[source]
veros.distributed.get_local_size(vs, arr_shp, dim_grid, include_overlap=False)[source]
veros.distributed.proc_rank_to_index(rank)[source]
veros.distributed.proc_index_to_rank(ix, iy)[source]
veros.distributed.get_chunk_slices(vs, dim_grid, proc_idx=None, include_overlap=False)[source]
veros.distributed.get_process_neighbors(vs)[source]
veros.distributed.exchange_overlap(vs, arr, var_grid)[source]
veros.distributed.exchange_cyclic_boundaries(vs, arr)[source]
veros.distributed.global_and(vs, arr)[source]
veros.distributed.global_or(vs, arr)[source]
veros.distributed.global_max(vs, arr)[source]
veros.distributed.global_min(vs, arr)[source]
veros.distributed.global_sum(vs, arr)[source]
veros.distributed.gather(vs, arr, var_grid)[source]
veros.distributed.broadcast(vs, obj)[source]
veros.distributed.scatter(vs, arr, var_grid)[source]
veros.distributed.barrier()[source]
veros.distributed.abort()[source]