Home | History | Annotate | Download | only in multiprocessing

Lines Matching defs:Server

94 # Function for communication with a manager's server process
145 # Server which is run in a process controlled by a manager
148 class Server(object):
150 Server class which runs in a process controlled by a manager object
172 Run the server forever
229 util.debug('starting server thread to service %r',
471 _Server = Server
489 Return server object with serve_forever() method and address attribute
492 return Server(self._registry, self._address,
497 Connect manager object to the server process
506 Spawn a server process for this manager object
513 server
516 # spawn process which runs a server
526 # get address of server
544 Create a server, report its address and run it
549 # create server
550 server = cls._Server(registry, address, authkey, serializer)
552 # inform parent process of the server's address
553 writer.send(server.address)
557 util.info('manager serving at %r', server.address)
558 server.serve_forever()
564 assert self._state.value == State.STARTED, 'server not yet started'
869 server = getattr(current_process(), '_manager_server', None)
871 if server and server.address == token.address:
872 return server.id_to_obj[token.id][0]