pele.concurrent.ConnectServer#
- class pele.concurrent.ConnectServer(system, database, server_name=None, host=None, port=0)[source]#
Server which receives requests from, and passes connect jobs to the workers
The server also receives minima and transition states from the workers and adds them to the database.
- Parameters:
- systempele.system.BaseSystem
system class to process
- databasepele.storage.Database
working database
- server_namestring, optional
Unique name for clients to connect to this server on current host (objid for pyros). None for random
- hoststring, optional
host to setup server. default is localhost which does not allow connections from remote machines
- portinteger, optional
port to listen for connections
Methods
|
called by worker if a new minimum is found |
|
called by worker if a new transition state is found |
|
get a new connect job |
provide system class to worker |
|
|
start the server and listen for incoming connections |
|
add a custom connect manager |
Attributes