Method main

src/ceph-node-proxy/ceph_node_proxy/baseredfishsystem.py:142–170

(self)

        )

    def main(self) -> None:
        self.stop = False
        self.client.login()
        self.endpoints.init()

        while not self.stop:
            self.log.debug("waiting for a lock in the update loop.")
            with self.lock:
                if not self.pending_shutdown:
                    self.log.debug("lock acquired in the update loop.")
                    try:
                        self._update_system()
                        self._update_sn()

                        with concurrent.futures.ThreadPoolExecutor() as executor:
                            executor.map(lambda f: f(), self.update_funcs)

                        self.data_ready = True
                    except RuntimeError as e:
                        self.stop = True
                        self.log.error(
                            f"Error detected, trying to gracefully log out from redfish api.\n{e}"
                        )
                        self.client.logout()
                        raise
                    sleep(self.refresh_interval)
            self.log.debug("lock released in the update loop.")
        self.log.debug("exiting update loop.")
        raise SystemExit(0)

    def flush(self) -> None:
        self.log.debug("Acquiring lock to flush data.")