sfepy.base.multiproc_mpi module¶
Multiprocessing functions.
- class sfepy.base.multiproc_mpi.MPIFileHandler(filename, mode=4, encoding=None, delay=0, comm=<mpi4py.MPI.Intracomm object>)[source]¶
MPI file class for logging process communication.
- class sfepy.base.multiproc_mpi.RemoteDict(name, mutable=False)[source]¶
Remote dictionary class - slave side.
- class sfepy.base.multiproc_mpi.RemoteDictMaster(name, mutable=False, soft_set=False, *args)[source]¶
Remote dictionary class - master side.
- class sfepy.base.multiproc_mpi.RemoteInt(remote_dict, value=None)[source]¶
Remote intiger class, data saved in RemoteDict.
- value¶
- class sfepy.base.multiproc_mpi.RemoteLock[source]¶
Remote lock class - lock and unlock restricted access to the master.
- class sfepy.base.multiproc_mpi.RemoteQueueMaster(name, mode='fifo', *args)[source]¶
Remote queue class - master side.
- sfepy.base.multiproc_mpi.get_dict(name, mutable=False, clear=False, soft_set=False)[source]¶
Get the remote dictionary.
- sfepy.base.multiproc_mpi.get_logger(log_filename='multiproc_mpi.log')[source]¶
Get the MPI logger which log information into a shared file.
- sfepy.base.multiproc_mpi.is_remote_dict(d)[source]¶
Return True if ‘d’ is RemoteDict or RemoteDictMaster instance.
- sfepy.base.multiproc_mpi.master_loop()[source]¶
Run the master loop - wait for requests from slaves.
- sfepy.base.multiproc_mpi.tags¶
alias of
Enum