hippylib.scheduling package

Submodules

hippylib.scheduling.collective module

class hippylib.scheduling.collective.MultipleSamePartitioningPDEsCollective(comm, is_serial_check=False)[source]

Bases: object

Parallel reduction utilities when several serial systems of PDEs (one per process) are solved concurrently.

comm is mpi4py.MPI comm

_allReduce_array(v, op)[source]
allReduce(v, op)[source]

Case handled: - v is a scalar (float, int); - v is a numpy array (NOTE: v will be overwritten) - v is a dolfin.Vector (NOTE: v will be overwritten) Operation: op = "Sum" or “Avg” (case insentive).

bcast(v, root=0)[source]

Case handled: - v is a scalar (float, int); - v is a numpy array (NOTE: v will be overwritten) - v is a dolfin.Vector (NOTE: v will be overwritten) - root refers to the process rank within the communicator for which the data to be broadcasted lives.

rank()[source]
size()[source]
hippylib.scheduling.collective.MultipleSerialPDEsCollective(comm)[source]
class hippylib.scheduling.collective.NullCollective[source]

Bases: object

No-overhead “Parallel” reduction utilities when a serial system of PDEs is solved on 1 process.

allReduce(v, op)[source]
bcast(v, root=0)[source]
rank()[source]
size()[source]

Module contents