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 Enum

sfepy.base.multiproc_mpi.wait_for_tag(wtag, num=1)[source]¶