Module contents
Slave classes responsible for distributing requests to replicas, proposers, …
-
class
rexfw.slaves.Slave(replicas, comm)[source]
Bases: object
-
_listen()[source]
Runs an infinite loop, polling for messages and passing them on to their
destination, which currently is only a single replica
-
_receive_parcel()[source]
Uses the communicator to receive a Parcel from any source
-
listen()[source]
Starts a thread and runs the infinite loop (_listen)
-
class
rexfw.slaves.UDCountsSlave(replicas, comm, sim_path)[source]
Bases: object
-
_listen()[source]
-
_receive_parcel()[source]
-
listen()[source]