subscription.py 文件源码

def make_connection(self, endpoint, api_path):
        conn = Connection(endpoint, api_path, self._event_handler,
                          principal=self.principal, secret=self.secret)
        try:
            yield conn.ping()
        except MasterRedirect as ex:  # pragma: no cover
            if ex.location == self.master_info.current_location:
                log.warn('Leading Master not elected yet')
            else:  # pragma: no cover
                log.warn('Master not leading')
                self.master_info.redirected_uri(ex.location)
            conn = None
        except ConnectionRefusedError as ex:  # pragma: no cover
            conn = None
        except Exception:  # pragma: no cover
            conn = None

        raise gen.Return(conn)