(self)
| 808 | util.register_after_fork(self, BaseProxy._after_fork) |
| 809 | |
| 810 | def _connect(self): |
| 811 | util.debug('making connection to manager') |
| 812 | name = process.current_process().name |
| 813 | if threading.current_thread().name != 'MainThread': |
| 814 | name += '|' + threading.current_thread().name |
| 815 | conn = self._Client(self._token.address, authkey=self._authkey) |
| 816 | dispatch(conn, None, 'accept_connection', (name,)) |
| 817 | self._tls.connection = conn |
| 818 | |
| 819 | def _callmethod(self, methodname, args=(), kwds={}): |
| 820 | ''' |
no test coverage detected