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