source: CPL/oasis3-mct/branches/OASIS3-MCT_5.0_branch/pyoasis/examples/4-orange/python/sender-orange.py @ 6331

#!/usr/bin/env python3

import pyoasis
from pyoasis import OASIS
import numpy

from mpi4py import MPI

comm = MPI.COMM_WORLD

component_name = "sender-orange"

comp = pyoasis.Component(component_name, True, comm)

local_comm_rank = comp.localcomm.rank
local_comm_size = comp.localcomm.size

coupled = True
if local_comm_size > 3:
    if local_comm_rank >= local_comm_size - 2:
        coupled = False

print(comp, flush=True)

comp.create_couplcomm(coupled)

if coupled:
    comm_rank = comp.couplcomm.rank
    comm_size = comp.couplcomm.size

    n_points = 16
    extent = int(n_points / comm_size)
    offset = comm_rank * extent

    offsets = [offset]
    extents = [extent]

    partition = pyoasis.OrangePartition(offsets, extents)
    print(partition, flush=True)

    variable = pyoasis.Var("FSENDOCN", partition, OASIS.OUT)
    print(variable, flush=True)

comp.enddef()

if coupled:
    date = int(0)

    field = pyoasis.asarray(numpy.zeros(extent))
    for i in range(extent):
        field[i] = offset + i

    variable.put(date, field)

del comp