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.
-
close()[source]
Closes the stream.
-
class
sfepy.base.multiproc_mpi.MPILogFile[source]
-
write(*args, **kwargs)[source]
-
class
sfepy.base.multiproc_mpi.RemoteDict(name, mutable=False)[source]
Remote dictionary class - slave side.
-
get(key, default=None)[source]
-
keys()[source]
-
update(other)[source]
-
class
sfepy.base.multiproc_mpi.RemoteDictMaster(name, mutable=False, soft_set=False, *args)[source]
Remote dictionary class - master side.
-
remote_get(key, slave)[source]
-
remote_get_in(key, slave)[source]
-
remote_get_keys(slave)[source]
-
remote_get_len(slave)[source]
-
remote_set(data, slave, mutable=False)[source]
-
class
sfepy.base.multiproc_mpi.RemoteInt(remote_dict, value=None)[source]
Remote intiger class, data saved in RemoteDict.
-
class
IntDesc[source]
-
value
-
class
sfepy.base.multiproc_mpi.RemoteLock[source]
Remote lock class - lock and unlock restricted access to the master.
-
acquire()[source]
-
release()[source]
-
class
sfepy.base.multiproc_mpi.RemoteQueue(name)[source]
Remote queue class - slave side.
-
get()[source]
-
put(value)[source]
-
class
sfepy.base.multiproc_mpi.RemoteQueueMaster(name, mode='fifo', *args)[source]
Remote queue class - master side.
-
clean()[source]
-
get()[source]
-
static
get_gdict_key(name)[source]
-
put(value)[source]
-
remote_get(slave)[source]
-
remote_put(value, slave)[source]
-
sfepy.base.multiproc_mpi.cpu_count()[source]
Get the number of MPI nodes.
-
sfepy.base.multiproc_mpi.enum(*sequential)[source]
-
sfepy.base.multiproc_mpi.get_dict(name, mutable=False, clear=False, soft_set=False)[source]
Get the remote dictionary.
-
sfepy.base.multiproc_mpi.get_int_value(name, init_value=0)[source]
Get the remote integer value.
-
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.get_queue(name)[source]
Get the queue.
-
sfepy.base.multiproc_mpi.get_slaves()[source]
Get the list of slave nodes
-
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.master_send_continue()[source]
Send ‘continue’ to all slaves.
-
sfepy.base.multiproc_mpi.master_send_task(task, data)[source]
Send task to all slaves.
-
sfepy.base.multiproc_mpi.set_logging_level(log_level='info')[source]
-
sfepy.base.multiproc_mpi.slave_get_task(name='')[source]
Start the slave nodes.
-
sfepy.base.multiproc_mpi.slave_task_done(task='')[source]
Stop the slave nodes.
-
sfepy.base.multiproc_mpi.tags
alias of sfepy.base.multiproc_mpi.Enum
-
sfepy.base.multiproc_mpi.wait_for_tag(wtag, num=1)[source]
