3.1.4.11. c3po.mpi.MPIMasterPhysicsDriver module

Contain the class MPIMasterPhysicsDriver.

class c3po.mpi.MPIMasterPhysicsDriver.MPIMasterPhysicsDriver(workerProcess, localPhysicsDriver=None)

Bases: PhysicsDriver

MPIMasterPhysicsDriver is used by a master process to control a (set of) remote c3po.PhysicsDriver.PhysicsDriver as a local one.

It can, in addition, be in charge of a local one (can be usefull for codes using an internal collaborative MPI parallelization).

Inherits from c3po.PhysicsDriver.PhysicsDriver. All the methods of c3po.PhysicsDriver.PhysicsDriver are implemented and consist in commanding the worker to execute them. Methods inherited from c3po.DataAccessor.DataAccessor are NOT implemented (apart from the setInput(Double/Int/String)Value methods, for convenience). Use an c3po.mpi.MPIMasterExchanger.MPIMasterExchanger to exchange data with the worker.

__init__(workerProcess, localPhysicsDriver=None)

Build a MPIMasterPhysicsDriver object.

Parameters:

• workerProcess (MPIRemoteProcess, MPIRemoteProcesses or MPICollectiveProcess) – A c3po.mpi.MPIRemoteProcess.MPIRemoteProcess, a c3po.mpi.MPIRemoteProcesses.MPIRemoteProcesses or a c3po.mpi.MPICollectiveProcess.MPICollectiveProcess identifying the worker process(es). Each worker process can be in charge of only one c3po.PhysicsDriver.PhysicsDriver. In case of a c3po.mpi.MPICollectiveProcess.MPICollectiveProcess, the MPIComm must include all the workers + the master, and only them.

• localPhysicsDriver – A c3po.PhysicsDriver.PhysicsDriver the MPIMasterPhysicsDriver object will run in the same time than the workers. It enables the master to contribute to a collaborative calculations.

abortTimeStep()

See PhysicsDriver.abortTimeStep().

computeTimeStep()

See PhysicsDriver.computeTimeStep().

forget(label, method)

See PhysicsDriver.forget().

getInitStatus()

See PhysicsDriver.getInitStatus().

getInputValuesNames()

See c3po.DataAccessor.DataAccessor.getInputValuesNames().

getIterateStatus()

See PhysicsDriver.getIterateStatus().

getMPIComm()

See PhysicsDriver.getMPIComm().

getOutputDoubleValue(name)

See c3po.DataAccessor.DataAccessor.getOutputDoubleValue().

getOutputIntValue(name)

See c3po.DataAccessor.DataAccessor.getOutputIntValue().

getOutputStringValue(name)

See c3po.DataAccessor.DataAccessor.getOutputStringValue().

getOutputValuesNames()

See c3po.DataAccessor.DataAccessor.getOutputValuesNames().

getSolveStatus()

See PhysicsDriver.getSolveStatus().

getStationaryMode()

See PhysicsDriver.getStationaryMode().

getValueType(name)

See c3po.DataAccessor.DataAccessor.getValueType().

getValueUnit(name)

See c3po.DataAccessor.DataAccessor.getValueUnit().

init()

See PhysicsDriver.init().

initTimeStep(dt)

See PhysicsDriver.initTimeStep().

initialize()

See PhysicsDriver.initialize().

isStationary()

See PhysicsDriver.isStationary().

iterate()

See PhysicsDriver.iterate().

iterateTimeStep()

See PhysicsDriver.iterateTimeStep().

presentTime()

See PhysicsDriver.presentTime().

recvData(data, collectiveOperator=mpi4py.MPI.MIN)

INTERNAL

resetTime(time_)

See PhysicsDriver.resetTime().

restore(label, method)

See PhysicsDriver.restore().

save(label, method)

See PhysicsDriver.save().

sendData(tag, data=None)

INTERNAL

setDataFile(datafile)

See PhysicsDriver.setDataFile().

setDataManagerToFree(idDataManager)

INTERNAL

setInputDoubleValue(name, value)

See c3po.DataAccessor.DataAccessor.setInputDoubleValue().

setInputIntValue(name, value)

See c3po.DataAccessor.DataAccessor.setInputIntValue().

setInputStringValue(name, value)

See c3po.DataAccessor.DataAccessor.setInputStringValue().

setStationaryMode(stationaryMode)

See PhysicsDriver.setStationaryMode().

solve()

See PhysicsDriver.solve().

solveTimeStep()

See PhysicsDriver.solveTimeStep().

terminate()

See PhysicsDriver.terminate().

validateTimeStep()

See PhysicsDriver.validateTimeStep().