Lines Matching full:conn
225 def serve_client(self, conn):
232 recv = conn.recv
233 send = conn.send
259 rident, rexposed = self.create(conn, typeid, res)
272 self, conn, ident, obj, *args, **kwds
296 conn.close()
299 def fallback_getvalue(self, conn, ident, obj):
302 def fallback_str(self, conn, ident, obj):
305 def fallback_repr(self, conn, ident, obj):
500 conn = Client(self._address, authkey=self._authkey)
501 dispatch(conn, None, 'dummy')
565 conn = self._Client(self._address, authkey=self._authkey)
567 id, exposed = dispatch(conn, None, 'create', (typeid,)+args, kwds)
569 conn.close()
582 conn = self._Client(self._address, authkey=self._authkey)
584 return dispatch(conn, None, 'debug_info')
586 conn.close()
592 conn = self._Client(self._address, authkey=self._authkey)
594 return dispatch(conn, None, 'number_of_objects')
596 conn.close()
612 conn = _Client(address, authkey=authkey)
614 dispatch(conn, None, 'shutdown')
616 conn.close()
672 conn = self._Client(token.address, authkey=self._authkey)
673 dispatch(conn, None, 'decref', (token.id,))
742 conn = self._Client(self._token.address, authkey=self._authkey)
743 dispatch(conn, None, 'accept_connection', (name,))
744 self._tls.connection = conn
751 conn = self._tls.connection
756 conn = self._tls.connection
758 conn.send((self._id, methodname, args, kwds))
759 kind, result = conn.recv()
770 conn = self._Client(token.address, authkey=self._authkey)
771 dispatch(conn, None, 'decref', (token.id,))
782 conn = self._Client(self._token.address, authkey=self._authkey)
783 dispatch(conn, None, 'incref', (self._id,))
806 conn = _Client(token.address, authkey=authkey)
807 dispatch(conn, None, 'decref', (token.id,))
817 util.debug('thread %r has no more proxies so closing conn',
914 conn = _Client(token.address, authkey=authkey)
916 exposed = dispatch(conn, None, 'get_methods', (token,))
918 conn.close()
