Home | History | Annotate | Download | only in multiprocessing

Lines Matching full:authkey

155     def __init__(self, registry, address, authkey, serializer):
156 assert isinstance(authkey, bytes)
158 self.authkey = AuthenticationString(authkey)
197 connection.deliver_challenge(c, self.authkey)
198 connection.answer_challenge(c, self.authkey)
473 def __init__(self, address=None, authkey=None, serializer='pickle'):
474 if authkey is None:
475 authkey = current_process().authkey
477 self._authkey = AuthenticationString(authkey)
500 conn = Client(self._address, authkey=self._authkey)
541 def _run_server(cls, registry, address, authkey, serializer, writer,
550 server = cls._Server(registry, address, authkey, serializer)
565 conn = self._Client(self._address, authkey=self._authkey)
582 conn = self._Client(self._address, authkey=self._authkey)
592 conn = self._Client(self._address, authkey=self._authkey)
605 def _finalize_manager(process, address, authkey, state, _Client):
612 conn = _Client(address, authkey=authkey)
670 authkey=self._authkey, exposed=exp
672 conn = self._Client(token.address, authkey=self._authkey)
700 authkey=None, exposed=None, incref=True):
725 if authkey is not None:
726 self._authkey = AuthenticationString(authkey)
730 self._authkey = current_process().authkey
742 conn = self._Client(self._token.address, authkey=self._authkey)
768 authkey=self._authkey, exposed=exposed
770 conn = self._Client(token.address, authkey=self._authkey)
782 conn = self._Client(self._token.address, authkey=self._authkey)
798 def _decref(token, authkey, state, tls, idset, _Client):
806 conn = _Client(token.address, authkey=authkey)
833 kwds['authkey'] = self._authkey
906 def AutoProxy(token, serializer, manager=None, authkey=None,
914 conn = _Client(token.address, authkey=authkey)
920 if authkey is None and manager is not None:
921 authkey = manager._authkey
922 if authkey is None:
923 authkey = current_process().authkey
926 proxy = ProxyType(token, serializer, manager=manager, authkey=authkey,