Lines Matching full:address
78 __slots__ = ('typeid', 'address', 'id')
80 def __init__(self, typeid, address, id):
81 (self.typeid, self.address, self.id) = (typeid, address, id)
84 return (self.typeid, self.address, self.id)
87 (self.typeid, self.address, self.id) = state
90 return 'Token(typeid=%r, address=%r, id=%r)' % \
91 (self.typeid, self.address, self.id)
155 def __init__(self, registry, address, authkey, serializer):
162 self.listener = Listener(address=address, backlog=16)
163 self.address = self.listener.address
260 token = Token(typeid, self.address, rident)
473 def __init__(self, address=None, authkey=None, serializer='pickle'):
476 self._address = address # XXX not final address if eg ('', 0)
489 Return server object with serve_forever() method and address attribute
513 address of server
526 # get address of server
541 def _run_server(cls, registry, address, authkey, serializer, writer,
544 Create a server, report its address and run it
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)
605 def _finalize_manager(process, address, authkey, state, _Client):
612 conn = _Client(address, authkey=authkey)
632 del BaseProxy._address_to_local[address]
636 address = property(lambda self: self._address)
672 conn = self._Client(token.address, authkey=self._authkey)
703 tls_idset = BaseProxy._address_to_local.get(token.address, None)
706 BaseProxy._address_to_local[token.address] = tls_idset
711 # thread to communicate with the manager at token.address
716 # which are in the manager at token.address
742 conn = self._Client(self._token.address, authkey=self._authkey)
770 conn = self._Client(token.address, authkey=self._authkey)
782 conn = self._Client(self._token.address, authkey=self._authkey)
806 conn = _Client(token.address, authkey=authkey)
871 if server and server.address == token.address:
914 conn = _Client(token.address, authkey=authkey)
