WISDEM / WEIS / 11937535308

    """Return True if we're being executed under mpirun."""

    # this is a bit of a hack, but there appears to be

    # no consistent set of environment vars between MPI

    # implementations.

            name == "OMPI_COMM_WORLD_RANK"

            or name == "MPIEXEC_HOSTNAME"

            or name.startswith("MPIR_")

            or name.startswith("MPICH_")

            or name.startswith("INTEL_ONEAPI_MPI_")

            or name.startswith("I_MPI_")

        ):

    def debug(*msg):  # pragma: no cover

        newmsg = ["%d: " % MPI.COMM_WORLD.rank] + list(msg)

        for m in newmsg:

            sys.stdout.write("%s " % m)

        sys.stdout.write("\n")

        sys.stdout.flush()

else:

    """

    Heirarchical parallelization communicator mapping.  Assumes a number of top level processes

    equal to the number of design variables (x2 if central finite differencing is used), each

    with its associated number of openfast simulations.

    When openmp flag is turned on, the code spreads the openfast simulations across nodes to

    lavereage the opnemp parallelization of OpenFAST. The cores that will run under openmp, are marked

    in the color map as 1000000. The ones handling python and the DV are marked as 0, and

    finally the master ones for each openfast run are marked with a 1.

    """

        # for m in range(n_DV_per_node):

                    int(n_DV_per_node) + n_dv * n_OF + nn * (n_procs_per_node) + j for j in range(n_OF)

                ]

                # This core handles python, so in the colormap the entry is 0

                # These cores handles openfast, so in the colormap the entry is 1

    else:

    """

    Subprocessors loop, waiting to receive a function and its arguements to evaluate.

    Output of the function is returned.  Loops until a stop signal is received

    Input data format:

    data[0] = function to be evaluated

    data[1] = [list of arguments]

    If the function to be evaluated does not fit this format, then a wrapper function

    should be created and passed, that handles the setup, argument assignment, etc

    for the actual function.

    Stop sigal:

    data[0] = False

    """

    # comm        = impl.world_comm()

        else:

    """

    Send stop signal to subprocessors

    """

    # comm = MPI.COMM_WORLD

        _,

        _,

        _,

    ) = map_comm_heirarchical(2, 4)